Loading sharding-jdbc/src/test/java/io/shardingsphere/dbtest/env/authority/AuthorityEnvironmentManager.java +16 −16 Original line number Diff line number Diff line Loading @@ -62,7 +62,7 @@ public final class AuthorityEnvironmentManager { if (initSQLs.isEmpty()) { return; } Connection connection = dataSource.getConnection(); try (Connection connection = dataSource.getConnection()) { for (String each : initSQLs) { try { connection.createStatement().execute(each); Loading @@ -70,7 +70,7 @@ public final class AuthorityEnvironmentManager { log.warn("Init SQL: " + ex.getMessage()); } } connection.close(); } } /** Loading @@ -83,7 +83,7 @@ public final class AuthorityEnvironmentManager { if (cleanSQLs.isEmpty()) { return; } Connection connection = dataSource.getConnection(); try (Connection connection = dataSource.getConnection()) { for (String each : cleanSQLs) { try { connection.createStatement().execute(each); Loading @@ -91,6 +91,6 @@ public final class AuthorityEnvironmentManager { log.warn("Clean SQL: " + ex.getMessage()); } } connection.close(); } } } Loading
sharding-jdbc/src/test/java/io/shardingsphere/dbtest/env/authority/AuthorityEnvironmentManager.java +16 −16 Original line number Diff line number Diff line Loading @@ -62,7 +62,7 @@ public final class AuthorityEnvironmentManager { if (initSQLs.isEmpty()) { return; } Connection connection = dataSource.getConnection(); try (Connection connection = dataSource.getConnection()) { for (String each : initSQLs) { try { connection.createStatement().execute(each); Loading @@ -70,7 +70,7 @@ public final class AuthorityEnvironmentManager { log.warn("Init SQL: " + ex.getMessage()); } } connection.close(); } } /** Loading @@ -83,7 +83,7 @@ public final class AuthorityEnvironmentManager { if (cleanSQLs.isEmpty()) { return; } Connection connection = dataSource.getConnection(); try (Connection connection = dataSource.getConnection()) { for (String each : cleanSQLs) { try { connection.createStatement().execute(each); Loading @@ -91,6 +91,6 @@ public final class AuthorityEnvironmentManager { log.warn("Clean SQL: " + ex.getMessage()); } } connection.close(); } } }