Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

添加ConnectionChecker

Browse Source 
git-svn-id: http://code.alibabatech.com/svn/druid/trunk@295 b9813039-fb51-4c41-a8b9-e21c2acb5095
This commit is contained in:
wenshao
2011-06-29 05:41:49 +00:00
parent e0eaf4f531
commit 146b3a9c3a
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/pool/DruidDataSource.java
+2 -2
View File
@@ -34,7 +34,7 @@ import javax.naming.StringRefAddr;
import com.alibaba.druid.filter.Filter;
import com.alibaba.druid.pool.vendor.MSSQLValidConnectionChecker;
import com.alibaba.druid.pool.vendor.MySQLValidConnectionChecker;
import com.alibaba.druid.pool.vendor.MySqlValidConnectionChecker1;
import com.alibaba.druid.pool.vendor.OracleValidConnectionChecker;
import com.alibaba.druid.proxy.jdbc.DataSourceProxyConfig;
import com.alibaba.druid.util.JdbcUtils;
@@ -131,7 +131,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
this.dbType = JdbcUtils.getDbType(jdbcUrl, driverClass.getClass().getName());
if ("mysql".equals(dbType)) {
this.validConnectionChecker = new MySQLValidConnectionChecker();
this.validConnectionChecker = new MySqlValidConnectionChecker1();
} else if ("oracle".equals(dbType)) {
this.validConnectionChecker = new OracleValidConnectionChecker();
} else if ("sqlserver".equals(dbType)) {
src/main/java/com/alibaba/druid/pool/vendor/MySQLValidConnectionChecker.java → src/main/java/com/alibaba/druid/pool/vendor/MySqlValidConnectionChecker1.java
Vendored
+3 -3
View File
@@ -12,10 +12,10 @@ import com.alibaba.druid.logging.LogFactory;
import com.alibaba.druid.pool.ValidConnectionChecker;
import com.alibaba.druid.util.JdbcUtils;
public class MySQLValidConnectionChecker implements ValidConnectionChecker, Serializable {
public class MySqlValidConnectionChecker1 implements ValidConnectionChecker, Serializable {
private static final long serialVersionUID = 1L;
private static final Log LOG = LogFactory.getLog(MySQLValidConnectionChecker.class);
private static final Log LOG = LogFactory.getLog(MySqlValidConnectionChecker1.class);
private Method ping;
private boolean driverHasPingMethod = false;
@@ -24,7 +24,7 @@ public class MySQLValidConnectionChecker implements ValidConnectionChecker, Seri
private static Object[] params = new Object[] {};
@SuppressWarnings({ "unchecked", "rawtypes" })
public MySQLValidConnectionChecker(){
public MySqlValidConnectionChecker1(){
try {
Class mysqlConnection = Thread.currentThread().getContextClassLoader().loadClass("com.mysql.jdbc.Connection");
ping = mysqlConnection.getMethod("ping", new Class[] {});