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 b2e17db560..a99c6eb72c 100644 --- a/src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker.java +++ b/src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker.java @@ -44,8 +44,8 @@ public class MySqlValidConnectionChecker extends ValidConnectionCheckerAdapter i public MySqlValidConnectionChecker(){ try { - clazz = Utils.loadClass("com.mysql.jdbc.Connection"); - ping = clazz.getMethod("ping"); + clazz = Utils.loadClass("com.mysql.jdbc.MySQLConnection"); + ping = clazz.getMethod("pingInternal", boolean.class, int.class); if (ping != null) { usePingMethod = true; } @@ -95,7 +95,7 @@ public class MySqlValidConnectionChecker extends ValidConnectionCheckerAdapter i if (clazz.isAssignableFrom(conn.getClass())) { try { - ping.invoke(conn); + ping.invoke(conn, true, validationQueryTimeout); return true; } catch (InvocationTargetException e) { Throwable cause = e.getCause();