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 eaa7090cb5..ecc2cba3ae 100644 --- a/src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker.java +++ b/src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker.java @@ -46,7 +46,7 @@ public class MySqlValidConnectionChecker implements ValidConnectionChecker, Seri // if there is a ping method then use it, otherwise just use a 'SELECT 1' statement if (conn != null && driverHasPingMethod) { try { - ping.invoke(c); + ping.invoke(conn); return true; } catch (Exception e) { LOG.warn("Unexpected error in ping", e); diff --git a/src/test/java/com/alibaba/druid/pool/MySqlValdConnectionTest.java b/src/test/java/com/alibaba/druid/pool/MySqlValdConnectionTest.java index 4af98edb3e..ce9c93b556 100644 --- a/src/test/java/com/alibaba/druid/pool/MySqlValdConnectionTest.java +++ b/src/test/java/com/alibaba/druid/pool/MySqlValdConnectionTest.java @@ -4,7 +4,7 @@ import java.sql.Connection; import junit.framework.TestCase; -import com.alibaba.druid.pool.vendor.OracleExceptionSorter; +import com.alibaba.druid.pool.vendor.MySqlExceptionSorter; public class MySqlValdConnectionTest extends TestCase { private String jdbcUrl; @@ -25,7 +25,7 @@ public class MySqlValdConnectionTest extends TestCase { dataSource.setUsername(user); dataSource.setPassword(password); dataSource.setFilters("stat"); - dataSource.setExceptionSoter(OracleExceptionSorter.class.getName()); + dataSource.setExceptionSoter(MySqlExceptionSorter.class.getName()); Connection conn = dataSource.getConnection(); conn.close();