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 9278799d55..a67352af80 100644 --- a/src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker.java +++ b/src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker.java @@ -33,7 +33,8 @@ import com.alibaba.druid.util.Utils; public class MySqlValidConnectionChecker extends ValidConnectionCheckerAdapter implements ValidConnectionChecker, Serializable { - public static final int DEFAULT_VALIDATION_QUERY_TIMEOUT = 1000; + public static final int DEFAULT_VALIDATION_QUERY_TIMEOUT = 1; + public static final String DEFAULT_VALIDATION_QUERY = "SELECT 1"; private static final long serialVersionUID = 1L; private static final Log LOG = LogFactory.getLog(MySqlValidConnectionChecker.class); @@ -105,8 +106,9 @@ public class MySqlValidConnectionChecker extends ValidConnectionCheckerAdapter i } } - if (validateQuery == null || validateQuery.length() == 0) { - return true; + String query = validateQuery; + if (validateQuery == null || validateQuery.isEmpty()) { + query = DEFAULT_VALIDATION_QUERY; } Statement stmt = null; @@ -116,7 +118,7 @@ public class MySqlValidConnectionChecker extends ValidConnectionCheckerAdapter i if (validationQueryTimeout > 0) { stmt.setQueryTimeout(validationQueryTimeout); } - rs = stmt.executeQuery(validateQuery); + rs = stmt.executeQuery(query); return true; } finally { JdbcUtils.close(rs);