添加ConnectionChecker

git-svn-id: http://code.alibabatech.com/svn/druid/trunk@294 b9813039-fb51-4c41-a8b9-e21c2acb5095
This commit is contained in:
wenshao
2011-06-29 04:44:48 +00:00
parent d71767db94
commit e0eaf4f531
3 changed files with 13 additions and 4 deletions
@@ -33,6 +33,9 @@ import javax.naming.Referenceable;
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.OracleValidConnectionChecker;
import com.alibaba.druid.proxy.jdbc.DataSourceProxyConfig;
import com.alibaba.druid.util.JdbcUtils;
@@ -74,8 +77,6 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
private final CountDownLatch initedLatch = new CountDownLatch(
2);
public DruidDataSource(){
}
@@ -129,6 +130,14 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
this.dbType = JdbcUtils.getDbType(jdbcUrl, driverClass.getClass().getName());
if ("mysql".equals(dbType)) {
this.validConnectionChecker = new MySQLValidConnectionChecker();
} else if ("oracle".equals(dbType)) {
this.validConnectionChecker = new OracleValidConnectionChecker();
} else if ("sqlserver".equals(dbType)) {
this.validConnectionChecker = new MSSQLValidConnectionChecker();
}
for (Filter filter : filters) {
filter.init(this);
}