From 427f19901a92a54bb3046bd16ab43caa890aec48 Mon Sep 17 00:00:00 2001 From: aaron-congo Date: Tue, 21 Jan 2025 10:16:19 -0800 Subject: [PATCH] Fix checkstyle --- .../container/tests/FailoverTest.java | 32 ++++++++++--------- 1 file changed, 17 insertions(+), 15 deletions(-) diff --git a/wrapper/src/test/java/integration/container/tests/FailoverTest.java b/wrapper/src/test/java/integration/container/tests/FailoverTest.java index f2aa9cd1b..2a0b7c13e 100644 --- a/wrapper/src/test/java/integration/container/tests/FailoverTest.java +++ b/wrapper/src/test/java/integration/container/tests/FailoverTest.java @@ -27,7 +27,9 @@ import integration.DatabaseEngineDeployment; import integration.DriverHelper; import integration.TestEnvironmentFeatures; +import integration.TestEnvironmentInfo; import integration.TestInstanceInfo; +import integration.TestProxyDatabaseInfo; import integration.container.ConnectionStringHelper; import integration.container.ProxyHelper; import integration.container.TestDriver; @@ -102,7 +104,7 @@ public void tearDownEach() { } /** - * Current writer dies, driver failover occurs when executing a method against the connection + * Current writer dies, driver failover occurs when executing a method against the connection. */ @TestTemplate @EnableOnNumOfInstances(min = 2) @@ -317,7 +319,8 @@ public void test_writerFailWithinTransaction_startTransaction() public void testServerFailoverWithIdleConnections() throws SQLException, InterruptedException { final List idleConnections = new ArrayList<>(); final String clusterEndpoint = TestEnvironment.getCurrent().getInfo().getProxyDatabaseInfo().getClusterEndpoint(); - final int clusterEndpointPort = TestEnvironment.getCurrent().getInfo().getProxyDatabaseInfo().getClusterEndpointPort(); + final int clusterEndpointPort = + TestEnvironment.getCurrent().getInfo().getProxyDatabaseInfo().getClusterEndpointPort(); final Properties props = initDefaultProxiedProps(); props.setProperty(PropertyDefinition.PLUGINS.name, "auroraConnectionTracker,failover"); @@ -394,11 +397,12 @@ public void testServerFailoverWithIdleConnections() throws SQLException, Interru @TestTemplate @EnableOnNumOfInstances(min = 2) public void test_DataSourceWriterConnection_BasicFailover() throws SQLException { + TestEnvironmentInfo envInfo = TestEnvironment.getCurrent().getInfo(); + TestProxyDatabaseInfo proxyInfo = envInfo.getProxyDatabaseInfo(); + List instances = proxyInfo.getInstances(); - TestInstanceInfo initialWriterInstanceInfo = - TestEnvironment.getCurrent().getInfo().getProxyDatabaseInfo().getInstances().get(0); - TestInstanceInfo newWriterInstanceInfo = - TestEnvironment.getCurrent().getInfo().getProxyDatabaseInfo().getInstances().get(1); + TestInstanceInfo initialWriterInstanceInfo = instances.get(0); + TestInstanceInfo newWriterInstanceInfo = instances.get(1); final String newWriterId = newWriterInstanceInfo.getInstanceId(); try (final Connection conn = @@ -413,23 +417,21 @@ public void test_DataSourceWriterConnection_BasicFailover() throws SQLException LOGGER.fine("currentConnectionId: " + currentConnectionId); List instanceIDs = null; - for (TestInstanceInfo instanceInfo : TestEnvironment.getCurrent().getInfo().getProxyDatabaseInfo().getInstances()) { + for (TestInstanceInfo instanceInfo : instances) { if (instanceInfo == initialWriterInstanceInfo - && TestEnvironment.getCurrent().getInfo().getRequest().getDatabaseEngineDeployment() - == DatabaseEngineDeployment.RDS_MULTI_AZ_CLUSTER) { + && envInfo.getRequest().getDatabaseEngineDeployment() == DatabaseEngineDeployment.RDS_MULTI_AZ_CLUSTER) { // Old writer node for RDS MultiAz clusters (usually) isn't available for a long time after failover. // Let's skip this node and fetch topology from another node. continue; } try { instanceIDs = auroraUtil.getAuroraInstanceIds( - TestEnvironment.getCurrent().getInfo().getRequest().getDatabaseEngine(), - TestEnvironment.getCurrent().getInfo().getRequest().getDatabaseEngineDeployment(), + envInfo.getRequest().getDatabaseEngine(), + envInfo.getRequest().getDatabaseEngineDeployment(), ConnectionStringHelper.getUrl( - instanceInfo.getHost(), instanceInfo.getPort(), - TestEnvironment.getCurrent().getInfo().getProxyDatabaseInfo().getDefaultDbName()), - TestEnvironment.getCurrent().getInfo().getProxyDatabaseInfo().getUsername(), - TestEnvironment.getCurrent().getInfo().getProxyDatabaseInfo().getPassword()); + instanceInfo.getHost(), instanceInfo.getPort(), proxyInfo.getDefaultDbName()), + proxyInfo.getUsername(), + proxyInfo.getPassword()); if (!instanceIDs.isEmpty()) { break; }