fix issue with blue/green metadata for PG databases

Author: sergiyvamz

.github/workflows/run-bg-integration-tests-latest.yml

@@ -0,0 +1,67 @@
+name: Run Blue/Green Integration Tests Latest
+
+on:
+  workflow_dispatch:
+  push:
+    branches:
+      - main
+
+permissions:
+  id-token: write   # This is required for requesting the JWT
+  contents: read    # This is required for actions/checkout
+
+jobs:
+  all-bg-integration-tests-latest:
+    name: Run Blue/Green integration tests with latest engine version
+    runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        testTask: [ "mysql-aurora-mariadb-driver", "mysql-aurora-mysql-driver", "mysql-rds-instance-mariadb-driver", "mysql-rds-instance-mysql-driver", "pg-aurora", "pg-rds-instance" ]
+    steps:
+      - name: 'Clone repository'
+        uses: actions/checkout@v4
+        with:
+          fetch-depth: 50
+      - name: 'Set up JDK 8'
+        uses: actions/setup-java@v4
+        with:
+          distribution: 'corretto'
+          java-version: 8
+      - name: 'Configure AWS credentials'
+        uses: aws-actions/configure-aws-credentials@v4
+        id: creds
+        with:
+          role-to-assume: arn:aws:iam::${{ secrets.AWS_ACCOUNT_ID }}:role/${{ secrets.AWS_DEPLOY_ROLE }}
+          role-session-name: run_bg_integration_test_latest
+          role-duration-seconds: 21600
+          aws-region: ${{ secrets.AWS_DEFAULT_REGION }}
+          output-credentials: true
+      - name: Run Blue/Green integration tests
+        run: |
+          ./gradlew --no-parallel --no-daemon test-bgd-${{ matrix.testTask }}
+        env:
+          AURORA_CLUSTER_DOMAIN: ${{ secrets.DB_CONN_SUFFIX }}
+          RDS_DB_REGION: ${{ secrets.AWS_DEFAULT_REGION }}
+          AWS_ACCESS_KEY_ID: ${{ steps.creds.outputs.aws-access-key-id }}
+          AWS_SECRET_ACCESS_KEY: ${{ steps.creds.outputs.aws-secret-access-key }}
+          AWS_SESSION_TOKEN: ${{ steps.creds.outputs.aws-session-token }}
+          MYSQL_VERSION: "latest"
+          PG_VERSION: "latest"
+      - name: Mask data
+        run: |
+          ./gradlew --no-parallel --no-daemon maskJunitHtmlReport
+      - name: Archive junit results for ${{ matrix.testTask }}
+        if: always()
+        uses: actions/upload-artifact@v4
+        with:
+          name: junit-report-latest-${{ matrix.testTask }}
+          path: ./wrapper/build/test-results
+          retention-days: 5
+      - name: Archive html summary report for ${{ matrix.testTask }}
+        if: always()
+        uses: actions/upload-artifact@v4
+        with:
+          name: html-summary-report-latest-${{ matrix.testTask }}
+          path: ./wrapper/build/report
+          retention-days: 5

wrapper/src/main/java/software/amazon/jdbc/plugin/bluegreen/BlueGreenStatusMonitor.java

@@ -428,8 +428,10 @@ protected void collectStatus() {
           // It's normal to expect that the status table has no entries after BGD is completed.
           // Old1 cluster/instance has been separated and no longer receives
           // updates from related green cluster/instance.
+          // Metadata at new blue cluster/instance can be removed after switchover, and it's also expected to get
+          // no records.
           if (this.role != BlueGreenRole.SOURCE) {
-            LOGGER.warning(() -> Messages.get("bgd.noEntriesInStatusTable", new Object[] {this.role}));
+            LOGGER.finest(() -> Messages.get("bgd.noEntriesInStatusTable", new Object[] {this.role}));
           }
           this.currentPhase = null;
         }
@@ -489,6 +491,15 @@ protected void collectStatus() {
       if (!this.isConnectionClosed(conn)) {
         // It's normal to get connection closed during BGD switchover.
         // If connection isn't closed but there's an exception then let's log it.
+
+        // For PG databases
+        if (e.getMessage() != null
+            && e.getMessage().contains("An error occured while retrieving the blue/green fast switchover metadata")) {
+          this.currentPhase = BlueGreenPhase.NOT_CREATED;
+          return;
+        }
+
+        // Let's log it.
         if (LOGGER.isLoggable(Level.FINEST)) {
           LOGGER.log(Level.FINEST, Messages.get("bgd.unhandledSqlException", new Object[] {this.role}), e);
         }

wrapper/src/test/java/integration/container/tests/hibernate/HibernateTests.java

@@ -58,6 +58,7 @@
     TestEnvironmentFeatures.PERFORMANCE,
     TestEnvironmentFeatures.RUN_HIBERNATE_TESTS_ONLY,
     TestEnvironmentFeatures.RUN_AUTOSCALING_TESTS_ONLY,
+    TestEnvironmentFeatures.BLUE_GREEN_DEPLOYMENT,
     TestEnvironmentFeatures.RUN_DB_METRICS_ONLY})
 @MakeSureFirstInstanceWriter
 @Order(21)

wrapper/src/test/java/integration/util/AuroraTestUtility.java

@@ -1048,6 +1048,9 @@ public DatabaseEngine getRdsInstanceEngine(final DBInstance instance) {
   public String getAuroraParameterGroupFamily(String engine, String engineVersion) {
     switch (engine) {
       case "aurora-postgresql":
+        if (StringUtils.isNullOrEmpty(engineVersion) || engineVersion.startsWith("17.")) {
+          return "aurora-postgresql17";
+        }
         return "aurora-postgresql16";
       case "aurora-mysql":
         if (StringUtils.isNullOrEmpty(engineVersion) || engineVersion.contains("8.0")) {