diff --git a/src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker.java b/src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker.java index df840af2d1..97aaf38d68 100644 --- a/src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker.java +++ b/src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker.java @@ -81,7 +81,7 @@ public class MySqlValidConnectionChecker extends ValidConnectionCheckerAdapter i this.usePingMethod = usePingMethod; } - public boolean validConnection(Connection conn, String validateQuery, int validationQueryTimeout) throws Exception { + public boolean isValidConnection(Connection conn, String validateQuery, int validationQueryTimeout) throws Exception { if (conn.isClosed()) { return false; } @@ -105,6 +105,10 @@ public class MySqlValidConnectionChecker extends ValidConnectionCheckerAdapter i } } + if (validateQuery == null) { + return true; + } + Statement stmt = null; ResultSet rs = null; try { diff --git a/src/main/java/com/alibaba/druid/pool/vendor/OracleValidConnectionChecker.java b/src/main/java/com/alibaba/druid/pool/vendor/OracleValidConnectionChecker.java index 616e0b7f6e..383869bfec 100644 --- a/src/main/java/com/alibaba/druid/pool/vendor/OracleValidConnectionChecker.java +++ b/src/main/java/com/alibaba/druid/pool/vendor/OracleValidConnectionChecker.java @@ -53,7 +53,7 @@ public class OracleValidConnectionChecker extends ValidConnectionCheckerAdapter this.timeout = seconds; } - public boolean validConnection(Connection conn, String validateQuery, int validationQueryTimeout) throws Exception { + public boolean isValidConnection(Connection conn, String validateQuery, int validationQueryTimeout) throws Exception { if (validateQuery == null || validateQuery.isEmpty()) { validateQuery = this.defaultValidateQuery; }