Disable failing integration test for PG driver

wrapper/src/test/java/integration/container/TestDriverProvider.java

@@ -59,6 +59,8 @@
 public class TestDriverProvider implements TestTemplateInvocationContextProvider {
   private static final Logger LOGGER = Logger.getLogger(TestDriverProvider.class.getName());
 
+  private static final String POSTGRES_AUTH_ERROR_CODE = "28P01";
+
   @Override
   public boolean supportsTestTemplate(ExtensionContext context) {
     return true;
@@ -165,6 +167,10 @@ public void beforeEach(ExtensionContext context) throws Exception {
                       try {
                         instanceIDs = auroraUtil.getAuroraInstanceIds();
                       } catch (SQLException ex) {
+                        if (POSTGRES_AUTH_ERROR_CODE.equals(ex.getSQLState())) {
+                          // This authentication error for PG is caused by test environment configuration.
+                          throw ex;
+                        }
                         instanceIDs = new ArrayList<>();
                       }
                     }

wrapper/src/test/java/integration/container/tests/ReadWriteSplittingTests.java

@@ -36,8 +36,10 @@
 import integration.TestInstanceInfo;
 import integration.container.ConnectionStringHelper;
 import integration.container.ProxyHelper;
+import integration.container.TestDriver;
 import integration.container.TestDriverProvider;
 import integration.container.TestEnvironment;
+import integration.container.condition.DisableOnTestDriver;
 import integration.container.condition.DisableOnTestFeature;
 import integration.container.condition.EnableOnDatabaseEngine;
 import integration.container.condition.EnableOnDatabaseEngineDeployment;
@@ -106,8 +108,10 @@ protected static Properties getProxiedProps() {
 
   protected static Properties getDefaultPropsNoPlugins() {
     final Properties props = ConnectionStringHelper.getDefaultProperties();
-    DriverHelper.setSocketTimeout(props, 10, TimeUnit.SECONDS);
-    DriverHelper.setConnectTimeout(props, 10, TimeUnit.SECONDS);
+    props.setProperty(
+        PropertyDefinition.SOCKET_TIMEOUT.name, String.valueOf(TimeUnit.SECONDS.toMillis(10)));
+    props.setProperty(
+        PropertyDefinition.CONNECT_TIMEOUT.name, String.valueOf(TimeUnit.SECONDS.toMillis(10)));
     return props;
   }
 
@@ -338,8 +342,13 @@ public void test_setReadOnly_closedConnection() throws SQLException {
     }
   }
 
+  /**
+   * PG driver has check of internal readOnly flag and doesn't communicate to a DB server
+   * if there's no changes. Thus, network exception is not raised.
+   */
   @TestTemplate
   @EnableOnTestFeature(TestEnvironmentFeatures.NETWORK_OUTAGES_ENABLED)
+  @DisableOnTestDriver(TestDriver.PG) // see comments above
   public void test_setReadOnlyFalse_allInstancesDown() throws SQLException {
     try (final Connection conn = DriverManager.getConnection(
         ConnectionStringHelper.getProxyWrapperUrl(), getProxiedProps())) {
@@ -359,6 +368,24 @@ public void test_setReadOnlyFalse_allInstancesDown() throws SQLException {
     }
   }
 
+  @TestTemplate
+  @EnableOnTestFeature(TestEnvironmentFeatures.NETWORK_OUTAGES_ENABLED)
+  public void test_setReadOnlyFalse_whenAllInstancesDown() throws SQLException {
+    try (final Connection conn = DriverManager.getConnection(
+        ConnectionStringHelper.getWrapperReaderClusterUrl(), getProxiedProps())) {
+
+      // Kill all instances
+      ProxyHelper.disableAllConnectivity();
+
+      // setReadOnly(false) triggers switching reader connection to a new writer connection.
+      // Since connectivity to all instances are down, it's expected to get a network-bound exception
+      // while opening a new connection to a writer node.
+      final SQLException exception =
+          assertThrows(SQLException.class, () -> conn.setReadOnly(false));
+      assertEquals(SqlState.CONNECTION_UNABLE_TO_CONNECT.getState(), exception.getSQLState());
+    }
+  }
+
   @TestTemplate
   public void test_executeWithOldConnection() throws SQLException {
     try (final Connection conn = DriverManager.getConnection(ConnectionStringHelper.getWrapperUrl(), getProps())) {