fix dialect detection

Author: sergiyvamz

wrapper/src/main/java/software/amazon/jdbc/dialect/GlobalAuroraMysqlDialect.java

@@ -32,6 +32,9 @@ public class GlobalAuroraMysqlDialect extends AuroraMysqlDialect {
       "SELECT 1 AS tmp FROM information_schema.tables WHERE"
           + " upper(table_schema) = 'INFORMATION_SCHEMA' AND upper(table_name) = 'AURORA_GLOBAL_DB_STATUS'";
 
+  protected final String globalDbStatusQuery =
+      "SELECT count(1) FROM information_schema.aurora_global_db_status";
+
   protected final String globalDbInstanceStatusTableExistQuery =
       "SELECT 1 AS tmp FROM information_schema.tables WHERE"
           + " upper(table_schema) = 'INFORMATION_SCHEMA' AND upper(table_name) = 'AURORA_GLOBAL_DB_INSTANCE_STATUS'";
@@ -59,7 +62,18 @@ public boolean isDialect(final Connection connection) {
         stmt = connection.createStatement();
         rs = stmt.executeQuery(this.globalDbInstanceStatusTableExistQuery);
 
-        return rs.next();
+        if (rs.next()) {
+          rs.close();
+          stmt.close();
+
+          stmt = connection.createStatement();
+          rs = stmt.executeQuery(this.globalDbStatusQuery);
+
+          if (rs.next()) {
+            int awsRegionCount = rs.getInt(1);
+            return awsRegionCount > 1;
+          }
+        }
       }
       return false;
     } catch (final SQLException ex) {

wrapper/src/main/java/software/amazon/jdbc/dialect/GlobalAuroraPgDialect.java

@@ -42,6 +42,9 @@ public class GlobalAuroraPgDialect extends AuroraPgDialect {
           + "VISIBILITY_LAG_IN_MSEC, AWS_REGION "
           + "FROM aurora_global_db_instance_status()";
 
+  protected final String globalDbStatusQuery =
+      "SELECT count(1) FROM aurora_global_db_status()";
+
   protected final String regionByNodeIdQuery =
       "SELECT AWS_REGION FROM aurora_global_db_instance_status() WHERE SERVER_ID = ?";
 
@@ -72,7 +75,18 @@ public boolean isDialect(final Connection connection) {
         stmt = connection.createStatement();
         rs = stmt.executeQuery(this.globalDbInstanceStatusFuncExistQuery);
 
-        return rs.next();
+        if (rs.next()) {
+          rs.close();
+          stmt.close();
+
+          stmt = connection.createStatement();
+          rs = stmt.executeQuery(this.globalDbStatusQuery);
+
+          if (rs.next()) {
+            int awsRegionCount = rs.getInt(1);
+            return awsRegionCount > 1;
+          }
+        }
       }
       return false;
     } catch (final SQLException ex) {