From 7ba4c72e76f21ad312eef809600cd34c4f1ad7e1 Mon Sep 17 00:00:00 2001 From: wenshao Date: Mon, 10 Jun 2013 15:06:11 +0800 Subject: [PATCH 1/5] log error, if fatal exception throw --- src/main/java/com/alibaba/druid/pool/DruidDataSource.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java index 9642bbd78f..424cb19bd0 100644 --- a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java +++ b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java @@ -1032,6 +1032,8 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat this.discardConnection(holder.getConnection()); holder.setDiscard(true); pooledConnection.disable(t); + + LOG.error("discard connection", sqlEx); } throw sqlEx; From ab5b7884fefe8ea28c0304248e9674dfb519650a Mon Sep 17 00:00:00 2001 From: wenshao Date: Thu, 13 Jun 2013 14:07:53 +0800 Subject: [PATCH 2/5] 0.2.21 --- pom.xml | 1076 +++++++++++++++++++++++++++---------------------------- 1 file changed, 538 insertions(+), 538 deletions(-) diff --git a/pom.xml b/pom.xml index b7e4b307d5..f534b99eea 100644 --- a/pom.xml +++ b/pom.xml @@ -1,538 +1,538 @@ - - 4.0.0 - - com.alibaba - druid - 0.2.21-SNAPSHOT - - jar - druid - An JDBC datasource implementation. - https://github.com/AlibabaTech/druid - 2012 - - - 3.1.1.RELEASE - 4.11 - - true - true - - UTF-8 - 1.6 - - - - - local-file - file://${basedir}/lib/ - default - - - - - - opensesame - dav:http://code.alibabatech.com/mvn/releases/ - - - opensesame - dav:http://code.alibabatech.com/mvn/snapshots/ - - - - - - wenshao - wenshao - szujobs@hotmail.com - - - - - https://wenshao@github.com/AlibabaTech/druid.git - scm:git:https://wenshao@github.com/AlibabaTech/druid.git - - - - Alibaba Group - http://code.alibabatech.com/ - - - - - Apache 2 - http://www.apache.org/licenses/LICENSE-2.0.txt - repo - A business-friendly OSS license - - - - - Jira - http://code.alibabatech.com/jira/browse/DRUID - - - - - org.apache.maven.wagon - wagon-webdav - 1.0-beta-2 - - - - - org.apache.maven.plugins - maven-compiler-plugin - 3.0 - - UTF-8 - 1.6 - 1.6 - - - - - org.apache.maven.plugins - maven-surefire-plugin - 2.12.4 - - - **/bvt/**/*.java - - - - - - org.apache.maven.plugins - maven-source-plugin - 2.2.1 - - - attach-sources - - jar-no-fork - - - - - true - - - - - maven-javadoc-plugin - 2.9 - - - attach-javadoc - - jar - - - - - ${javadoc.skip} - public - UTF-8 - UTF-8 - UTF-8 - - http://docs.oracle.com/javase/6/docs/api - - - - - - maven-gpg-plugin - 1.4 - - ${gpg.skip} - - - - sign-artifacts - verify - - sign - - - - - - - - - false - com.mycila.maven-license-plugin - maven-license-plugin - 1.10.b1 - -
${basedir}/doc/license.txt
- true - true - true - - - - - SLASHSTAR_STYLE - - - src/main/java/**/*.java - - UTF-8 - - - - check-headers - verify - - check - - - - - - org.apache.maven.plugins - maven-jar-plugin - 2.4 - - - - true - - - ${buildNumber} - - - - - - org.codehaus.mojo - buildnumber-maven-plugin - 1.1 - - - validate - - create - - - - - {0,date,yyyy-MM-dd HH:mm:ss} - - timestamp - - false - true - - - - - - - - mc-release - Local Maven repository of releases - http://mc-repo.googlecode.com/svn/maven2/releases - - true - - - false - - - - - - - default-profile - - true - - ${java.home}/../lib/jconsole.jar - - - - ${java.home}/../lib/tools.jar - ${java.home}/../lib/jconsole.jar - - - - - com.alibaba - jconsole - 1.6.0 - system - ${jconsolejar} - true - - - com.alibaba - tools - 1.6.0 - system - ${toolsjar} - true - - - - - mac-profile - - false - - ${java.home}/../Classes/jconsole.jar - - - - - com.alibaba - jconsole - 1.6.0 - system - ${java.home}/../Classes/jconsole.jar - - - - - - - - javax.transaction - jta - 1.1 - provided - true - - - - javax.servlet - servlet-api - 2.5 - provided - true - - - commons-logging - commons-logging - 1.1.1 - provided - true - - - - org.springframework - spring-core - ${spring.version} - provided - true - - - org.springframework - spring-beans - ${spring.version} - provided - true - - - org.springframework - spring-orm - ${spring.version} - provided - true - - - org.springframework - spring-test - ${spring.version} - test - - - - org.springframework - spring-ibatis - 2.0.8 - provided - true - - - org.mybatis - mybatis - 3.1.1 - provided - true - - - org.mybatis - mybatis-spring - 1.1.1 - provided - true - - - - log4j - log4j - 1.2.16 - provided - - - org.slf4j - slf4j-api - 1.6.1 - provided - - - org.slf4j - slf4j-log4j12 - 1.6.1 - provided - - - - mysql - mysql-connector-java - 5.1.24 - provided - - - net.sourceforge.jtds - jtds - 1.3.0 - provided - - - - postgresql - postgresql - 9.1-901-1.jdbc4 - provided - - - - - com.oracle - ojdbc14 - 10.2.0.2 - provided - - - - com.microsoft.sqlserver - sqljdbc4 - 4.0.2206.100 - test - - - - org.nutz - nutz - 1.b.40 - test - - - - junit - junit - ${junit.version} - test - - - org.apache.derby - derby - 10.9.1.0 - test - - - - commons-dbcp - commons-dbcp - 1.4 - test - - - com.jolbox - bonecp - 0.7.1.RELEASE - test - - - com.jolbox - bonecp-spring - 0.7.1.RELEASE - test - - - proxool - proxool - 0.9.1 - test - - - proxool - proxool-cglib - 0.9.1 - test - - - - c3p0 - c3p0 - 0.9.1.2 - test - - - - org.apache.tomcat - tomcat-jdbc - 7.0.34 - test - - - - org.apache.ibatis - ibatis-sqlmap - 2.3.4.726 - provided - - - - com.h2database - h2 - 1.3.170 - provided - - - - org.hibernate - hibernate-core - 4.1.9.Final - provided - - - - commons-dbutils - commons-dbutils - 1.5 - test - - - - org.nutz - nutz - 1.b.47 - test - - - com.taobao.tbdatasource - tbdatasource - 2.0.2 - test - - - + + 4.0.0 + + com.alibaba + druid + 0.2.21 + + jar + druid + An JDBC datasource implementation. + https://github.com/AlibabaTech/druid + 2012 + + + 3.1.1.RELEASE + 4.11 + + true + true + + UTF-8 + 1.6 + + + + + local-file + file://${basedir}/lib/ + default + + + + + + opensesame + dav:http://code.alibabatech.com/mvn/releases/ + + + opensesame + dav:http://code.alibabatech.com/mvn/snapshots/ + + + + + + wenshao + wenshao + szujobs@hotmail.com + + + + + https://wenshao@github.com/AlibabaTech/druid.git + scm:git:https://wenshao@github.com/AlibabaTech/druid.git + + + + Alibaba Group + http://code.alibabatech.com/ + + + + + Apache 2 + http://www.apache.org/licenses/LICENSE-2.0.txt + repo + A business-friendly OSS license + + + + + Jira + http://code.alibabatech.com/jira/browse/DRUID + + + + + org.apache.maven.wagon + wagon-webdav + 1.0-beta-2 + + + + + org.apache.maven.plugins + maven-compiler-plugin + 3.0 + + UTF-8 + 1.6 + 1.6 + + + + + org.apache.maven.plugins + maven-surefire-plugin + 2.12.4 + + + **/bvt/**/*.java + + + + + + org.apache.maven.plugins + maven-source-plugin + 2.2.1 + + + attach-sources + + jar-no-fork + + + + + true + + + + + maven-javadoc-plugin + 2.9 + + + attach-javadoc + + jar + + + + + ${javadoc.skip} + public + UTF-8 + UTF-8 + UTF-8 + + http://docs.oracle.com/javase/6/docs/api + + + + + + maven-gpg-plugin + 1.4 + + ${gpg.skip} + + + + sign-artifacts + verify + + sign + + + + + + + + + false + com.mycila.maven-license-plugin + maven-license-plugin + 1.10.b1 + +
${basedir}/doc/license.txt
+ true + true + true + + + + + SLASHSTAR_STYLE + + + src/main/java/**/*.java + + UTF-8 + + + + check-headers + verify + + check + + + + + + org.apache.maven.plugins + maven-jar-plugin + 2.4 + + + + true + + + ${buildNumber} + + + + + + org.codehaus.mojo + buildnumber-maven-plugin + 1.1 + + + validate + + create + + + + + {0,date,yyyy-MM-dd HH:mm:ss} + + timestamp + + false + true + + + + + + + + mc-release + Local Maven repository of releases + http://mc-repo.googlecode.com/svn/maven2/releases + + true + + + false + + + + + + + default-profile + + true + + ${java.home}/../lib/jconsole.jar + + + + ${java.home}/../lib/tools.jar + ${java.home}/../lib/jconsole.jar + + + + + com.alibaba + jconsole + 1.6.0 + system + ${jconsolejar} + true + + + com.alibaba + tools + 1.6.0 + system + ${toolsjar} + true + + + + + mac-profile + + false + + ${java.home}/../Classes/jconsole.jar + + + + + com.alibaba + jconsole + 1.6.0 + system + ${java.home}/../Classes/jconsole.jar + + + + + + + + javax.transaction + jta + 1.1 + provided + true + + + + javax.servlet + servlet-api + 2.5 + provided + true + + + commons-logging + commons-logging + 1.1.1 + provided + true + + + + org.springframework + spring-core + ${spring.version} + provided + true + + + org.springframework + spring-beans + ${spring.version} + provided + true + + + org.springframework + spring-orm + ${spring.version} + provided + true + + + org.springframework + spring-test + ${spring.version} + test + + + + org.springframework + spring-ibatis + 2.0.8 + provided + true + + + org.mybatis + mybatis + 3.1.1 + provided + true + + + org.mybatis + mybatis-spring + 1.1.1 + provided + true + + + + log4j + log4j + 1.2.16 + provided + + + org.slf4j + slf4j-api + 1.6.1 + provided + + + org.slf4j + slf4j-log4j12 + 1.6.1 + provided + + + + mysql + mysql-connector-java + 5.1.24 + provided + + + net.sourceforge.jtds + jtds + 1.3.0 + provided + + + + postgresql + postgresql + 9.1-901-1.jdbc4 + provided + + + + + com.oracle + ojdbc14 + 10.2.0.2 + provided + + + + com.microsoft.sqlserver + sqljdbc4 + 4.0.2206.100 + test + + + + org.nutz + nutz + 1.b.40 + test + + + + junit + junit + ${junit.version} + test + + + org.apache.derby + derby + 10.9.1.0 + test + + + + commons-dbcp + commons-dbcp + 1.4 + test + + + com.jolbox + bonecp + 0.7.1.RELEASE + test + + + com.jolbox + bonecp-spring + 0.7.1.RELEASE + test + + + proxool + proxool + 0.9.1 + test + + + proxool + proxool-cglib + 0.9.1 + test + + + + c3p0 + c3p0 + 0.9.1.2 + test + + + + org.apache.tomcat + tomcat-jdbc + 7.0.34 + test + + + + org.apache.ibatis + ibatis-sqlmap + 2.3.4.726 + provided + + + + com.h2database + h2 + 1.3.170 + provided + + + + org.hibernate + hibernate-core + 4.1.9.Final + provided + + + + commons-dbutils + commons-dbutils + 1.5 + test + + + + org.nutz + nutz + 1.b.47 + test + + + com.taobao.tbdatasource + tbdatasource + 2.0.2 + test + + + From d84bdb55d0f32b9bff3506a2074fd6644cb6a3c2 Mon Sep 17 00:00:00 2001 From: wenshao Date: Fri, 14 Jun 2013 11:29:28 +0800 Subject: [PATCH 3/5] add clearFilters method --- .../druid/pool/DruidAbstractDataSource.java | 3246 +++++++++-------- 1 file changed, 1625 insertions(+), 1621 deletions(-) diff --git a/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java b/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java index 6adb7d53bb..f7d1266512 100644 --- a/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java +++ b/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java @@ -1,1621 +1,1625 @@ -/* - * Copyright 1999-2011 Alibaba Group Holding Ltd. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.alibaba.druid.pool; - -import java.io.PrintWriter; -import java.io.Serializable; -import java.sql.Connection; -import java.sql.Driver; -import java.sql.DriverManager; -import java.sql.ResultSet; -import java.sql.SQLException; -import java.sql.SQLFeatureNotSupportedException; -import java.sql.Statement; -import java.util.ArrayList; -import java.util.Collection; -import java.util.Collections; -import java.util.Date; -import java.util.HashMap; -import java.util.HashSet; -import java.util.IdentityHashMap; -import java.util.Iterator; -import java.util.List; -import java.util.Map; -import java.util.Properties; -import java.util.Set; -import java.util.concurrent.CopyOnWriteArrayList; -import java.util.concurrent.atomic.AtomicLong; -import java.util.concurrent.locks.Condition; -import java.util.concurrent.locks.ReentrantLock; -import java.util.logging.Logger; - -import javax.management.JMException; -import javax.management.ObjectName; -import javax.management.openmbean.CompositeDataSupport; -import javax.security.auth.callback.NameCallback; -import javax.security.auth.callback.PasswordCallback; -import javax.sql.DataSource; - -import com.alibaba.druid.filter.Filter; -import com.alibaba.druid.filter.FilterChainImpl; -import com.alibaba.druid.filter.FilterManager; -import com.alibaba.druid.pool.vendor.NullExceptionSorter; -import com.alibaba.druid.proxy.jdbc.DataSourceProxy; -import com.alibaba.druid.proxy.jdbc.TransactionInfo; -import com.alibaba.druid.stat.JdbcDataSourceStat; -import com.alibaba.druid.stat.JdbcSqlStat; -import com.alibaba.druid.stat.JdbcStatManager; -import com.alibaba.druid.support.logging.Log; -import com.alibaba.druid.support.logging.LogFactory; -import com.alibaba.druid.util.DruidPasswordCallback; -import com.alibaba.druid.util.Histogram; -import com.alibaba.druid.util.IOUtils; -import com.alibaba.druid.util.JdbcUtils; -import com.alibaba.druid.util.StringUtils; - -/** - * @author wenshao - * @author ljw - */ -public abstract class DruidAbstractDataSource extends WrapperAdapter implements DruidAbstractDataSourceMBean, DataSource, DataSourceProxy, Serializable { - - private final static Log LOG = LogFactory.getLog(DruidAbstractDataSource.class); - - private static final long serialVersionUID = 1L; - - public final static int DEFAULT_INITIAL_SIZE = 0; - public final static int DEFAULT_MAX_ACTIVE_SIZE = 8; - public final static int DEFAULT_MAX_IDLE = 8; - public final static int DEFAULT_MIN_IDLE = 0; - public final static int DEFAULT_MAX_WAIT = -1; - public final static String DEFAULT_VALIDATION_QUERY = null; // - public final static boolean DEFAULT_TEST_ON_BORROW = false; - public final static boolean DEFAULT_TEST_ON_RETURN = false; - public final static boolean DEFAULT_WHILE_IDLE = true; - public static final long DEFAULT_TIME_BETWEEN_EVICTION_RUNS_MILLIS = -1L; - public static final long DEFAULT_TIME_BETWEEN_CONNECT_ERROR_MILLIS = 30 * 1000; - public static final int DEFAULT_NUM_TESTS_PER_EVICTION_RUN = 3; - - /** - * The default value for {@link #getMinEvictableIdleTimeMillis}. - * - * @see #getMinEvictableIdleTimeMillis - * @see #setMinEvictableIdleTimeMillis - */ - public static final long DEFAULT_MIN_EVICTABLE_IDLE_TIME_MILLIS = 1000L * 60L * 30L; - - protected volatile boolean defaultAutoCommit = true; - protected volatile Boolean defaultReadOnly; - protected volatile Integer defaultTransactionIsolation; - protected volatile String defaultCatalog = null; - - protected String name; - - protected volatile String username; - protected volatile String password; - protected volatile String jdbcUrl; - protected volatile String driverClass; - protected volatile ClassLoader driverClassLoader; - protected volatile Properties connectProperties = new Properties(); - - protected volatile PasswordCallback passwordCallback; - protected volatile NameCallback userCallback; - - protected volatile int initialSize = DEFAULT_INITIAL_SIZE; - protected volatile int maxActive = DEFAULT_MAX_ACTIVE_SIZE; - protected volatile int minIdle = DEFAULT_MIN_IDLE; - protected volatile int maxIdle = DEFAULT_MAX_IDLE; - protected volatile long maxWait = DEFAULT_MAX_WAIT; - - protected volatile String validationQuery = DEFAULT_VALIDATION_QUERY; - protected volatile int validationQueryTimeout = -1; - private volatile boolean testOnBorrow = DEFAULT_TEST_ON_BORROW; - private volatile boolean testOnReturn = DEFAULT_TEST_ON_RETURN; - private volatile boolean testWhileIdle = DEFAULT_WHILE_IDLE; - protected volatile boolean poolPreparedStatements = false; - protected volatile boolean sharePreparedStatements = false; - protected volatile int maxPoolPreparedStatementPerConnectionSize = 10; - - protected volatile boolean inited = false; - - protected PrintWriter logWriter = new PrintWriter( - System.out); - - protected List filters = new CopyOnWriteArrayList(); - protected volatile ExceptionSorter exceptionSorter = null; - - protected Driver driver; - - protected volatile int queryTimeout; - protected volatile int transactionQueryTimeout; - - protected AtomicLong createErrorCount = new AtomicLong(); - - protected long createTimespan; - - protected volatile int maxWaitThreadCount = -1; - - protected volatile boolean accessToUnderlyingConnectionAllowed = true; - - protected volatile long timeBetweenEvictionRunsMillis = DEFAULT_TIME_BETWEEN_EVICTION_RUNS_MILLIS; - - protected volatile int numTestsPerEvictionRun = DEFAULT_NUM_TESTS_PER_EVICTION_RUN; - - protected volatile long minEvictableIdleTimeMillis = DEFAULT_MIN_EVICTABLE_IDLE_TIME_MILLIS; - - protected volatile boolean removeAbandoned; - - protected volatile long removeAbandonedTimeoutMillis = 300 * 1000; - - protected volatile boolean logAbandoned; - - protected volatile int maxOpenPreparedStatements = -1; - - protected volatile List connectionInitSqls; - - protected volatile String dbType; - - protected volatile long timeBetweenConnectErrorMillis = DEFAULT_TIME_BETWEEN_CONNECT_ERROR_MILLIS; - - protected volatile ValidConnectionChecker validConnectionChecker = null; - - protected final AtomicLong errorCount = new AtomicLong(); - protected final AtomicLong dupCloseCount = new AtomicLong(); - - protected final Map activeConnections = new IdentityHashMap(); - protected final static Object PRESENT = new Object(); - - protected long id; - - protected final Date createdTime = new Date(); - protected Date initedTime; - - protected int connectionErrorRetryAttempts = 30; - - protected boolean breakAfterAcquireFailure = false; - - protected long transactionThresholdMillis = 0L; - - protected final AtomicLong commitCount = new AtomicLong(); - protected final AtomicLong startTransactionCount = new AtomicLong(); - protected final AtomicLong rollbackCount = new AtomicLong(); - protected final AtomicLong cachedPreparedStatementHitCount = new AtomicLong(); - protected final AtomicLong preparedStatementCount = new AtomicLong(); - protected final AtomicLong closedPreparedStatementCount = new AtomicLong(); - protected final AtomicLong cachedPreparedStatementCount = new AtomicLong(); - protected final AtomicLong cachedPreparedStatementDeleteCount = new AtomicLong(); - protected final AtomicLong cachedPreparedStatementMissCount = new AtomicLong(); - - protected final Histogram transactionHistogram = new Histogram( - 10, - 100, - 1000, - 10 * 1000, - 100 * 1000); - - private boolean dupCloseLogEnable = false; - - private ObjectName objectName; - - protected final AtomicLong executeCount = new AtomicLong(); - - protected volatile Throwable createError; - protected volatile Throwable lastError; - protected volatile long lastErrorTimeMillis; - protected volatile Throwable lastCreateError; - protected volatile long lastCreateErrorTimeMillis; - - protected boolean isOracle = false; - - protected boolean useOracleImplicitCache = true; - - protected ReentrantLock lock; - protected Condition notEmpty; - protected Condition empty; - - protected AtomicLong createCount = new AtomicLong(); - protected AtomicLong destroyCount = new AtomicLong(); - - private Boolean useUnfairLock = null; - - private boolean useLocalSessionState = true; - - protected long timeBetweenLogStatsMillis; - protected DruidDataSourceStatLogger statLogger = new DruidDataSourceStatLoggerImpl(); - - public DruidAbstractDataSource(boolean lockFair){ - lock = new ReentrantLock(lockFair); - - notEmpty = lock.newCondition(); - empty = lock.newCondition(); - } - - public boolean isUseLocalSessionState() { - return useLocalSessionState; - } - - public void setUseLocalSessionState(boolean useLocalSessionState) { - this.useLocalSessionState = useLocalSessionState; - } - - public DruidDataSourceStatLogger getStatLogger() { - return statLogger; - } - - public void setStatLoggerClassName(String className) { - Class clazz; - try { - clazz = Class.forName(className); - DruidDataSourceStatLogger statLogger = (DruidDataSourceStatLogger) clazz.newInstance(); - this.setStatLogger(statLogger); - } catch (Exception e) { - throw new IllegalArgumentException(className, e); - } - } - - public void setStatLogger(DruidDataSourceStatLogger statLogger) { - this.statLogger = statLogger; - } - - public long getTimeBetweenLogStatsMillis() { - return timeBetweenLogStatsMillis; - } - - public void setTimeBetweenLogStatsMillis(long timeBetweenLogStatsMillis) { - this.timeBetweenLogStatsMillis = timeBetweenLogStatsMillis; - } - - public boolean isOracle() { - return isOracle; - } - - public void setOracle(boolean isOracle) { - if (inited) { - throw new IllegalStateException(); - } - this.isOracle = isOracle; - } - - public boolean isUseUnfairLock() { - return lock.isFair(); - } - - public void setUseUnfairLock(boolean useUnfairLock) { - if (lock.isFair() == !useUnfairLock) { - return; - } - - if (!this.inited) { - final ReentrantLock lock = this.lock; - lock.lock(); - try { - if (!this.inited) { - this.lock = new ReentrantLock(!useUnfairLock); - this.notEmpty = this.lock.newCondition(); - this.empty = this.lock.newCondition(); - - this.useUnfairLock = useUnfairLock; - } - } finally { - lock.unlock(); - } - } - } - - public boolean isUseOracleImplicitCache() { - return useOracleImplicitCache; - } - - public void setUseOracleImplicitCache(boolean useOracleImplicitCache) { - if (this.useOracleImplicitCache != useOracleImplicitCache) { - this.useOracleImplicitCache = useOracleImplicitCache; - boolean isOracleDriver10 = isOracle() && this.driver != null && this.driver.getMajorVersion() == 10; - - if (isOracleDriver10 && useOracleImplicitCache) { - this.getConnectProperties().setProperty("oracle.jdbc.FreeMemoryOnEnterImplicitCache", "true"); - } else { - this.getConnectProperties().remove("oracle.jdbc.FreeMemoryOnEnterImplicitCache"); - } - } - } - - public Throwable getLastCreateError() { - return lastCreateError; - } - - public Throwable getLastError() { - return this.lastError; - } - - public long getLastErrorTimeMillis() { - return lastErrorTimeMillis; - } - - public Date getLastErrorTime() { - if (lastErrorTimeMillis <= 0) { - return null; - } - - return new Date(lastErrorTimeMillis); - } - - public long getLastCreateErrorTimeMillis() { - return lastCreateErrorTimeMillis; - } - - public Date getLastCreateErrorTime() { - if (lastCreateErrorTimeMillis <= 0) { - return null; - } - - return new Date(lastCreateErrorTimeMillis); - } - - public int getTransactionQueryTimeout() { - if (transactionQueryTimeout <= 0) { - return queryTimeout; - } - - return transactionQueryTimeout; - } - - public void setTransactionQueryTimeout(int transactionQueryTimeout) { - this.transactionQueryTimeout = transactionQueryTimeout; - } - - public long getExecuteCount() { - return executeCount.get(); - } - - public void incrementExecuteCount() { - this.executeCount.incrementAndGet(); - } - - public boolean isDupCloseLogEnable() { - return dupCloseLogEnable; - } - - public void setDupCloseLogEnable(boolean dupCloseLogEnable) { - this.dupCloseLogEnable = dupCloseLogEnable; - } - - public ObjectName getObjectName() { - return objectName; - } - - public void setObjectName(ObjectName objectName) { - this.objectName = objectName; - } - - public Histogram getTransactionHistogram() { - return transactionHistogram; - } - - public void incrementCachedPreparedStatementCount() { - cachedPreparedStatementCount.incrementAndGet(); - } - - public void decrementCachedPreparedStatementCount() { - cachedPreparedStatementCount.decrementAndGet(); - } - - public void incrementCachedPreparedStatementDeleteCount() { - cachedPreparedStatementDeleteCount.incrementAndGet(); - } - - public void incrementCachedPreparedStatementMissCount() { - cachedPreparedStatementMissCount.incrementAndGet(); - } - - public long getCachedPreparedStatementMissCount() { - return cachedPreparedStatementMissCount.get(); - } - - public long getCachedPreparedStatementAccessCount() { - return cachedPreparedStatementMissCount.get() + cachedPreparedStatementHitCount.get(); - } - - public long getCachedPreparedStatementDeleteCount() { - return cachedPreparedStatementDeleteCount.get(); - } - - public long getCachedPreparedStatementCount() { - return cachedPreparedStatementCount.get(); - } - - public void incrementClosedPreparedStatementCount() { - closedPreparedStatementCount.incrementAndGet(); - } - - public long getClosedPreparedStatementCount() { - return closedPreparedStatementCount.get(); - } - - public void incrementPreparedStatementCount() { - preparedStatementCount.incrementAndGet(); - } - - public long getPreparedStatementCount() { - return preparedStatementCount.get(); - } - - public void incrementCachedPreparedStatementHitCount() { - cachedPreparedStatementHitCount.incrementAndGet(); - } - - public long getCachedPreparedStatementHitCount() { - return cachedPreparedStatementHitCount.get(); - } - - public long getTransactionThresholdMillis() { - return transactionThresholdMillis; - } - - public void setTransactionThresholdMillis(long transactionThresholdMillis) { - this.transactionThresholdMillis = transactionThresholdMillis; - } - - public abstract void logTransaction(TransactionInfo info); - - public long[] getTransactionHistogramValues() { - return transactionHistogram.toArray(); - } - - public long[] getTransactionHistogramRanges() { - return transactionHistogram.getRanges(); - } - - public long getCommitCount() { - return commitCount.get(); - } - - public void incrementCommitCount() { - commitCount.incrementAndGet(); - } - - public long getRollbackCount() { - return rollbackCount.get(); - } - - public void incrementRollbackCount() { - rollbackCount.incrementAndGet(); - } - - public long getStartTransactionCount() { - return startTransactionCount.get(); - } - - public void incrementStartTransactionCount() { - startTransactionCount.incrementAndGet(); - } - - public boolean isBreakAfterAcquireFailure() { - return breakAfterAcquireFailure; - } - - public void setBreakAfterAcquireFailure(boolean breakAfterAcquireFailure) { - this.breakAfterAcquireFailure = breakAfterAcquireFailure; - } - - public int getConnectionErrorRetryAttempts() { - return connectionErrorRetryAttempts; - } - - public void setConnectionErrorRetryAttempts(int connectionErrorRetryAttempts) { - this.connectionErrorRetryAttempts = connectionErrorRetryAttempts; - } - - public long getDupCloseCount() { - return dupCloseCount.get(); - } - - public int getMaxPoolPreparedStatementPerConnectionSize() { - return maxPoolPreparedStatementPerConnectionSize; - } - - public void setMaxPoolPreparedStatementPerConnectionSize(int maxPoolPreparedStatementPerConnectionSize) { - if (maxPoolPreparedStatementPerConnectionSize > 0) { - this.poolPreparedStatements = true; - } - - this.maxPoolPreparedStatementPerConnectionSize = maxPoolPreparedStatementPerConnectionSize; - } - - public boolean isSharePreparedStatements() { - return sharePreparedStatements; - } - - public void setSharePreparedStatements(boolean sharePreparedStatements) { - this.sharePreparedStatements = sharePreparedStatements; - } - - public void incrementDupCloseCount() { - dupCloseCount.incrementAndGet(); - } - - public ValidConnectionChecker getValidConnectionChecker() { - return validConnectionChecker; - } - - public void setValidConnectionChecker(ValidConnectionChecker validConnectionChecker) { - this.validConnectionChecker = validConnectionChecker; - } - - public String getValidConnectionCheckerClassName() { - if (validConnectionChecker == null) { - return null; - } - - return validConnectionChecker.getClass().getName(); - } - - public void setValidConnectionCheckerClassName(String validConnectionCheckerClass) throws Exception { - Class clazz = JdbcUtils.loadDriverClass(validConnectionCheckerClass); - ValidConnectionChecker validConnectionChecker = null; - if (clazz != null) { - validConnectionChecker = (ValidConnectionChecker) clazz.newInstance(); - this.validConnectionChecker = validConnectionChecker; - } else { - LOG.error("load validConnectionCheckerClass error : " + validConnectionCheckerClass); - } - } - - public String getDbType() { - return dbType; - } - - public void setDbType(String dbType) { - this.dbType = dbType; - } - - public void addConnectionProperty(String name, String value) { - if (inited) { - throw new UnsupportedOperationException(); - } - - connectProperties.put(name, value); - } - - public Collection getConnectionInitSqls() { - Collection result = connectionInitSqls; - if (result == null) { - return Collections.emptyList(); - } - return result; - } - - public void setConnectionInitSqls(Collection connectionInitSqls) { - if ((connectionInitSqls != null) && (connectionInitSqls.size() > 0)) { - ArrayList newVal = null; - for (Iterator iterator = connectionInitSqls.iterator(); iterator.hasNext();) { - Object o = iterator.next(); - if (o != null) { - String s = o.toString(); - if (s.trim().length() > 0) { - if (newVal == null) { - newVal = new ArrayList(); - } - newVal.add(s); - } - } - } - this.connectionInitSqls = newVal; - } else { - this.connectionInitSqls = null; - } - } - - public long getTimeBetweenConnectErrorMillis() { - return timeBetweenConnectErrorMillis; - } - - public void setTimeBetweenConnectErrorMillis(long timeBetweenConnectErrorMillis) { - this.timeBetweenConnectErrorMillis = timeBetweenConnectErrorMillis; - } - - public int getMaxOpenPreparedStatements() { - return maxPoolPreparedStatementPerConnectionSize; - } - - public void setMaxOpenPreparedStatements(int maxOpenPreparedStatements) { - this.setMaxPoolPreparedStatementPerConnectionSize(maxOpenPreparedStatements); - } - - public boolean isLogAbandoned() { - return logAbandoned; - } - - public void setLogAbandoned(boolean logAbandoned) { - this.logAbandoned = logAbandoned; - } - - public int getRemoveAbandonedTimeout() { - return (int) (removeAbandonedTimeoutMillis / 1000); - } - - public void setRemoveAbandonedTimeout(int removeAbandonedTimeout) { - this.removeAbandonedTimeoutMillis = (long) removeAbandonedTimeout * 1000; - } - - public void setRemoveAbandonedTimeoutMillis(long removeAbandonedTimeoutMillis) { - this.removeAbandonedTimeoutMillis = removeAbandonedTimeoutMillis; - } - - public long getRemoveAbandonedTimeoutMillis() { - return removeAbandonedTimeoutMillis; - } - - public boolean isRemoveAbandoned() { - return removeAbandoned; - } - - public void setRemoveAbandoned(boolean removeAbandoned) { - this.removeAbandoned = removeAbandoned; - } - - public long getMinEvictableIdleTimeMillis() { - return minEvictableIdleTimeMillis; - } - - public void setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis) { - this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis; - } - - public int getNumTestsPerEvictionRun() { - return numTestsPerEvictionRun; - } - - /** - * @param numTestsPerEvictionRun - */ - @Deprecated - public void setNumTestsPerEvictionRun(int numTestsPerEvictionRun) { - this.numTestsPerEvictionRun = numTestsPerEvictionRun; - } - - public long getTimeBetweenEvictionRunsMillis() { - return timeBetweenEvictionRunsMillis; - } - - public void setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis) { - this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis; - } - - public int getMaxWaitThreadCount() { - return maxWaitThreadCount; - } - - public void setMaxWaitThreadCount(int maxWaithThreadCount) { - this.maxWaitThreadCount = maxWaithThreadCount; - } - - public String getValidationQuery() { - return validationQuery; - } - - public void setValidationQuery(String validationQuery) { - this.validationQuery = validationQuery; - } - - public int getValidationQueryTimeout() { - return validationQueryTimeout; - } - - public void setValidationQueryTimeout(int validationQueryTimeout) { - this.validationQueryTimeout = validationQueryTimeout; - } - - public boolean isAccessToUnderlyingConnectionAllowed() { - return accessToUnderlyingConnectionAllowed; - } - - public void setAccessToUnderlyingConnectionAllowed(boolean accessToUnderlyingConnectionAllowed) { - this.accessToUnderlyingConnectionAllowed = accessToUnderlyingConnectionAllowed; - } - - public boolean isTestOnBorrow() { - return testOnBorrow; - } - - public void setTestOnBorrow(boolean testOnBorrow) { - this.testOnBorrow = testOnBorrow; - } - - public boolean isTestOnReturn() { - return testOnReturn; - } - - public void setTestOnReturn(boolean testOnReturn) { - this.testOnReturn = testOnReturn; - } - - public boolean isTestWhileIdle() { - return testWhileIdle; - } - - public void setTestWhileIdle(boolean testWhileIdle) { - this.testWhileIdle = testWhileIdle; - } - - public boolean isDefaultAutoCommit() { - return defaultAutoCommit; - } - - public void setDefaultAutoCommit(boolean defaultAutoCommit) { - this.defaultAutoCommit = defaultAutoCommit; - } - - public Boolean getDefaultReadOnly() { - return defaultReadOnly; - } - - public void setDefaultReadOnly(Boolean defaultReadOnly) { - this.defaultReadOnly = defaultReadOnly; - } - - public Integer getDefaultTransactionIsolation() { - return defaultTransactionIsolation; - } - - public void setDefaultTransactionIsolation(Integer defaultTransactionIsolation) { - this.defaultTransactionIsolation = defaultTransactionIsolation; - } - - public String getDefaultCatalog() { - return defaultCatalog; - } - - public void setDefaultCatalog(String defaultCatalog) { - this.defaultCatalog = defaultCatalog; - } - - public PasswordCallback getPasswordCallback() { - return passwordCallback; - } - - public void setPasswordCallback(PasswordCallback passwordCallback) { - this.passwordCallback = passwordCallback; - } - - public void setPasswordCallbackClassName(String passwordCallbackClassName) throws Exception { - Class clazz = JdbcUtils.loadDriverClass(passwordCallbackClassName); - if (clazz != null) { - this.passwordCallback = (PasswordCallback) clazz.newInstance(); - } else { - LOG.error("load passwordCallback error : " + passwordCallbackClassName); - this.passwordCallback = null; - } - } - - public NameCallback getUserCallback() { - return userCallback; - } - - public void setUserCallback(NameCallback userCallback) { - this.userCallback = userCallback; - } - - /** - * Retrieves the number of seconds the driver will wait for a Statement object to execute. If the limit - * is exceeded, a SQLException is thrown. - * - * @return the current query timeout limit in seconds; zero means there is no limit - * @exception SQLException if a database access error occurs or this method is called on a closed - * Statement - * @see #setQueryTimeout - */ - public int getQueryTimeout() { - return queryTimeout; - } - - /** - * Sets the number of seconds the driver will wait for a Statement object to execute to the given - * number of seconds. If the limit is exceeded, an SQLException is thrown. A JDBC driver must apply - * this limit to the execute, executeQuery and executeUpdate methods. JDBC - * driver implementations may also apply this limit to ResultSet methods (consult your driver vendor - * documentation for details). - * - * @param seconds the new query timeout limit in seconds; zero means there is no limit - * @exception SQLException if a database access error occurs, this method is called on a closed - * Statement or the condition seconds >= 0 is not satisfied - * @see #getQueryTimeout - */ - public void setQueryTimeout(int seconds) { - this.queryTimeout = seconds; - } - - public String getName() { - if (name != null) { - return name; - } - return "DataSource-" + System.identityHashCode(this); - } - - public void setName(String name) { - this.name = name; - } - - public boolean isPoolPreparedStatements() { - return poolPreparedStatements; - } - - public abstract void setPoolPreparedStatements(boolean value); - - public long getMaxWait() { - return maxWait; - } - - public void setMaxWait(long maxWaitMillis) { - if (maxWaitMillis == this.maxWait) { - return; - } - - if (maxWaitMillis > 0 && useUnfairLock == null && !this.inited) { - final ReentrantLock lock = this.lock; - lock.lock(); - try { - if ((!this.inited) && (!lock.isFair())) { - this.lock = new ReentrantLock(true); - this.notEmpty = this.lock.newCondition(); - this.empty = this.lock.newCondition(); - } - } finally { - lock.unlock(); - } - } - - if (inited) { - LOG.error("maxWait changed : " + this.maxWait + " -> " + maxWaitMillis); - } - - this.maxWait = maxWaitMillis; - } - - public int getMinIdle() { - return minIdle; - } - - public void setMinIdle(int value) { - if (value == this.minIdle) { - return; - } - - if (inited) { - if (value > this.maxActive) { - throw new IllegalArgumentException("minIdle greater than maxActive, " + maxActive + " < " - + this.minIdle); - } - - LOG.error("minIdle changed : " + this.minIdle + " -> " + value); - } - - this.minIdle = value; - } - - public int getMaxIdle() { - return maxIdle; - } - - @Deprecated - public void setMaxIdle(int maxIdle) { - LOG.error("maxIdle is deprecated"); - - this.maxIdle = maxIdle; - } - - public int getInitialSize() { - return initialSize; - } - - public void setInitialSize(int initialSize) { - if (this.initialSize == initialSize) { - return; - } - - if (inited) { - throw new UnsupportedOperationException(); - } - - this.initialSize = initialSize; - } - - public long getCreateErrorCount() { - return createErrorCount.get(); - } - - public int getMaxActive() { - return maxActive; - } - - public abstract void setMaxActive(int maxActive); - - public String getUsername() { - return username; - } - - public void setUsername(String username) { - if (inited) { - throw new UnsupportedOperationException(); - } - - this.username = username; - } - - public String getPassword() { - return password; - } - - public void setPassword(String password) { - if (StringUtils.equals(this.password, password)) { - return; - } - - if (inited) { - LOG.info("password changed"); - } - - this.password = password; - } - - public Properties getConnectProperties() { - return connectProperties; - } - - public abstract void setConnectProperties(Properties properties); - - public void setConnectionProperties(String connectionProperties) { - if (connectionProperties == null || connectionProperties.trim().length() == 0) { - setConnectProperties(null); - return; - } - - String[] entries = connectionProperties.split(";"); - Properties properties = new Properties(); - for (int i = 0; i < entries.length; i++) { - String entry = entries[i]; - if (entry.length() > 0) { - int index = entry.indexOf('='); - if (index > 0) { - String name = entry.substring(0, index); - String value = entry.substring(index + 1); - properties.setProperty(name, value); - } else { - // no value is empty string which is how java.util.Properties works - properties.setProperty(entry, ""); - } - } - } - - setConnectProperties(properties); - } - - public String getUrl() { - return jdbcUrl; - } - - public String getRawJdbcUrl() { - return jdbcUrl; - } - - public void setUrl(String jdbcUrl) { - if (inited) { - throw new UnsupportedOperationException(); - } - - if (jdbcUrl != null) { - jdbcUrl = jdbcUrl.trim(); - } - - this.jdbcUrl = jdbcUrl; - - // if (jdbcUrl.startsWith(ConfigFilter.URL_PREFIX)) { - // this.filters.add(new ConfigFilter()); - // } - } - - public String getDriverClassName() { - return driverClass; - } - - public void setDriverClassName(String driverClass) { - if (inited) { - throw new UnsupportedOperationException(); - } - - this.driverClass = driverClass; - } - - public ClassLoader getDriverClassLoader() { - return driverClassLoader; - } - - public void setDriverClassLoader(ClassLoader driverClassLoader) { - this.driverClassLoader = driverClassLoader; - } - - @Override - public PrintWriter getLogWriter() { - return logWriter; - } - - @Override - public void setLogWriter(PrintWriter out) throws SQLException { - this.logWriter = out; - } - - @Override - public void setLoginTimeout(int seconds) { - DriverManager.setLoginTimeout(seconds); - } - - @Override - public int getLoginTimeout() { - return DriverManager.getLoginTimeout(); - } - - public Driver getDriver() { - return driver; - } - - public void setDriver(Driver driver) { - this.driver = driver; - } - - public int getDriverMajorVersion() { - if (this.driver == null) { - return -1; - } - - return this.driver.getMajorVersion(); - } - - public int getDriverMinorVersion() { - if (this.driver == null) { - return -1; - } - - return this.driver.getMinorVersion(); - } - - public ExceptionSorter getExceptionSorter() { - return exceptionSorter; - } - - public String getExceptionSorterClassName() { - if (exceptionSorter == null) { - return null; - } - - return exceptionSorter.getClass().getName(); - } - - public void setExceptionSorter(ExceptionSorter exceptionSoter) { - this.exceptionSorter = exceptionSoter; - } - - // 兼容JBOSS - public void setExceptionSorterClassName(String exceptionSorter) throws Exception { - this.setExceptionSorter(exceptionSorter); - } - - public void setExceptionSorter(String exceptionSorter) throws SQLException { - if (exceptionSorter == null) { - this.exceptionSorter = NullExceptionSorter.getInstance(); - return; - } - - exceptionSorter = exceptionSorter.trim(); - if (exceptionSorter.length() == 0) { - this.exceptionSorter = NullExceptionSorter.getInstance(); - return; - } - - Class clazz = JdbcUtils.loadDriverClass(exceptionSorter); - if (clazz == null) { - LOG.error("load exceptionSorter error : " + exceptionSorter); - } else { - try { - this.exceptionSorter = (ExceptionSorter) clazz.newInstance(); - } catch (Exception ex) { - throw new SQLException("create exceptionSorter error", ex); - } - } - } - - @Override - public List getProxyFilters() { - return filters; - } - - public void setProxyFilters(List filters) { - if (filters != null) { - this.filters.addAll(filters); - } - } - - public String[] getFilterClasses() { - List filterConfigList = getProxyFilters(); - - List classes = new ArrayList(); - for (Filter filter : filterConfigList) { - classes.add(filter.getClass().getName()); - } - - return classes.toArray(new String[classes.size()]); - } - - public void setFilters(String filters) throws SQLException { - if (filters == null || filters.length() == 0) { - return; - } - - String[] filterArray = filters.split("\\,"); - - for (String item : filterArray) { - FilterManager.loadFilter(this.filters, item); - } - } - - public void validateConnection(Connection conn) throws SQLException { - String query = getValidationQuery(); - if (conn.isClosed()) { - throw new SQLException("validateConnection: connection closed"); - } - - if (validConnectionChecker != null) { - if (!validConnectionChecker.isValidConnection(conn, validationQuery, validationQueryTimeout)) { - throw new SQLException("validateConnection false"); - } - return; - } - - if (null != query) { - Statement stmt = null; - ResultSet rs = null; - try { - stmt = conn.createStatement(); - if (getValidationQueryTimeout() > 0) { - stmt.setQueryTimeout(getValidationQueryTimeout()); - } - rs = stmt.executeQuery(query); - if (!rs.next()) { - throw new SQLException("validationQuery didn't return a row"); - } - } finally { - JdbcUtils.close(rs); - JdbcUtils.close(stmt); - } - } - } - - protected boolean testConnectionInternal(Connection conn) { - String sqlFile = JdbcSqlStat.getContextSqlFile(); - String sqlName = JdbcSqlStat.getContextSqlName(); - - if (sqlFile != null) { - JdbcSqlStat.setContextSqlFile(null); - } - if (sqlName != null) { - JdbcSqlStat.setContextSqlName(null); - } - try { - if (validConnectionChecker != null) { - return validConnectionChecker.isValidConnection(conn, validationQuery, validationQueryTimeout); - } - - if (conn.isClosed()) { - return false; - } - - if (null == validationQuery) { - return true; - } - - Statement stmt = null; - ResultSet rset = null; - try { - stmt = conn.createStatement(); - if (getValidationQueryTimeout() > 0) { - stmt.setQueryTimeout(validationQueryTimeout); - } - rset = stmt.executeQuery(validationQuery); - if (!rset.next()) { - return false; - } - } finally { - JdbcUtils.close(rset); - JdbcUtils.close(stmt); - } - - return true; - } catch (Exception ex) { - // skip - return false; - } finally { - if (sqlFile != null) { - JdbcSqlStat.setContextSqlFile(sqlFile); - } - if (sqlName != null) { - JdbcSqlStat.setContextSqlName(sqlName); - } - } - } - - public Set getActiveConnections() { - synchronized (activeConnections) { - return new HashSet(this.activeConnections.keySet()); - } - } - - public List getActiveConnectionStackTrace() { - List list = new ArrayList(); - - for (DruidPooledConnection conn : this.getActiveConnections()) { - list.add(IOUtils.toString(conn.getConnectStackTrace())); - } - - return list; - } - - public long getCreateTimespanNano() { - return createTimespan; - } - - public long getCreateTimespanMillis() { - return createTimespan / (1000 * 1000); - } - - @Override - public Driver getRawDriver() { - return driver; - } - - private final AtomicLong connectionIdSeed = new AtomicLong(10000); - private final AtomicLong statementIdSeed = new AtomicLong(20000); - private final AtomicLong resultSetIdSeed = new AtomicLong(50000); - private final AtomicLong transactionIdSeed = new AtomicLong(50000); - - public long createConnectionId() { - return connectionIdSeed.incrementAndGet(); - } - - public long createStatementId() { - return statementIdSeed.getAndIncrement(); - } - - public long createResultSetId() { - return resultSetIdSeed.getAndIncrement(); - } - - @Override - public long createTransactionId() { - return transactionIdSeed.getAndIncrement(); - } - - void initStatement(DruidPooledConnection conn, Statement stmt) throws SQLException { - boolean transaction = !conn.getConnectionHolder().isUnderlyingAutoCommit(); - - int queryTimeout = transaction ? getTransactionQueryTimeout() : getQueryTimeout(); - - if (queryTimeout > 0) { - stmt.setQueryTimeout(queryTimeout); - } - } - - public abstract void handleConnectionException(DruidPooledConnection pooledConnection, Throwable t) - throws SQLException; - - protected abstract void recycle(DruidPooledConnection pooledConnection) throws SQLException; - - public Connection createPhysicalConnection(String url, Properties info) throws SQLException { - Connection conn; - if (getProxyFilters().size() == 0) { - conn = getDriver().connect(url, info); - } else { - conn = new FilterChainImpl(this).connection_connect(info); - } - - createCount.incrementAndGet(); - - return conn; - } - - public Connection createPhysicalConnection() throws SQLException { - String url = this.getUrl(); - Properties connectProperties = getConnectProperties(); - - String user; - if (getUserCallback() != null) { - user = getUserCallback().getName(); - } else { - user = getUsername(); - } - - String password = getPassword(); - PasswordCallback passwordCallback = getPasswordCallback(); - - if (passwordCallback != null) { - if (passwordCallback instanceof DruidPasswordCallback) { - DruidPasswordCallback druidPasswordCallback = (DruidPasswordCallback) passwordCallback; - - druidPasswordCallback.setUrl(url); - druidPasswordCallback.setProperties(connectProperties); - } - - char[] chars = passwordCallback.getPassword(); - if (chars != null) { - password = new String(chars); - } - } - - Properties physicalConnectProperties = new Properties(); - if (connectProperties != null) { - physicalConnectProperties.putAll(connectProperties); - } - - if (user != null && user.length() != 0) { - physicalConnectProperties.put("user", user); - } - - if (password != null && password.length() != 0) { - physicalConnectProperties.put("password", password); - } - - Connection conn; - - long startNano = System.nanoTime(); - - try { - conn = createPhysicalConnection(url, physicalConnectProperties); - - if (conn == null) { - throw new SQLException("connect error, url " + url + ", driverClass " + this.driverClass); - } - - initPhysicalConnection(conn); - - validateConnection(conn); - createError = null; - } catch (SQLException ex) { - createErrorCount.incrementAndGet(); - createError = ex; - lastCreateError = ex; - lastCreateErrorTimeMillis = System.currentTimeMillis(); - throw ex; - } catch (RuntimeException ex) { - createErrorCount.incrementAndGet(); - createError = ex; - lastCreateError = ex; - lastCreateErrorTimeMillis = System.currentTimeMillis(); - throw ex; - } catch (Error ex) { - createErrorCount.incrementAndGet(); - throw ex; - } finally { - long nano = System.nanoTime() - startNano; - createTimespan += nano; - } - - return conn; - } - - public void initPhysicalConnection(Connection conn) throws SQLException { - if (conn.getAutoCommit() != defaultAutoCommit) { - conn.setAutoCommit(defaultAutoCommit); - } - - if (getDefaultReadOnly() != null) { - if (conn.isReadOnly() != getDefaultReadOnly()) { - conn.setReadOnly(getDefaultReadOnly()); - } - } - - if (getDefaultTransactionIsolation() != null) { - if (conn.getTransactionIsolation() != getDefaultTransactionIsolation().intValue()) { - conn.setTransactionIsolation(getDefaultTransactionIsolation()); - } - } - - if (getDefaultCatalog() != null && getDefaultCatalog().length() != 0) { - conn.setCatalog(getDefaultCatalog()); - } - } - - public abstract int getActivePeak(); - - public CompositeDataSupport getCompositeData() throws JMException { - JdbcDataSourceStat stat = this.getDataSourceStat(); - - Map map = new HashMap(); - - map.put("ID", getID()); - map.put("URL", this.getUrl()); - map.put("Name", this.getName()); - map.put("FilterClasses", getFilterClasses()); - map.put("CreatedTime", getCreatedTime()); - - map.put("RawDriverClassName", getDriverClassName()); - map.put("RawUrl", getUrl()); - map.put("RawDriverMajorVersion", getRawDriverMajorVersion()); - map.put("RawDriverMinorVersion", getRawDriverMinorVersion()); - map.put("Properties", getProperties()); - - // 0 - 4 - map.put("ConnectionActiveCount", (long) getActiveCount()); - map.put("ConnectionActiveCountMax", getActivePeak()); - map.put("ConnectionCloseCount", getCloseCount()); - map.put("ConnectionCommitCount", getCommitCount()); - map.put("ConnectionRollbackCount", getRollbackCount()); - - // 5 - 9 - map.put("ConnectionConnectLastTime", stat.getConnectionStat().getConnectLastTime()); - map.put("ConnectionConnectErrorCount", this.getCreateCount()); - if (createError != null) { - map.put("ConnectionConnectErrorLastTime", getLastCreateErrorTime()); - map.put("ConnectionConnectErrorLastMessage", createError.getMessage()); - map.put("ConnectionConnectErrorLastStackTrace", IOUtils.getStackTrace(createError)); - } else { - map.put("ConnectionConnectErrorLastTime", null); - map.put("ConnectionConnectErrorLastMessage", null); - map.put("ConnectionConnectErrorLastStackTrace", null); - } - - // 10 - 14 - map.put("StatementCreateCount", stat.getStatementStat().getCreateCount()); - map.put("StatementPrepareCount", stat.getStatementStat().getPrepareCount()); - map.put("StatementPreCallCount", stat.getStatementStat().getPrepareCallCount()); - map.put("StatementExecuteCount", stat.getStatementStat().getExecuteCount()); - map.put("StatementRunningCount", stat.getStatementStat().getRunningCount()); - - // 15 - 19 - map.put("StatementConcurrentMax", stat.getStatementStat().getConcurrentMax()); - map.put("StatementCloseCount", stat.getStatementStat().getCloseCount()); - map.put("StatementErrorCount", stat.getStatementStat().getErrorCount()); - map.put("StatementLastErrorTime", null); - map.put("StatementLastErrorMessage", null); - - // 20 - 24 - map.put("StatementLastErrorStackTrace", null); - map.put("StatementExecuteMillisTotal", stat.getStatementStat().getMillisTotal()); - map.put("StatementExecuteLastTime", stat.getStatementStat().getExecuteLastTime()); - map.put("ConnectionConnectingCount", stat.getConnectionStat().getConnectingCount()); - map.put("ResultSetCloseCount", stat.getResultSetStat().getCloseCount()); - - // 25 - 29 - map.put("ResultSetOpenCount", stat.getResultSetStat().getOpenCount()); - map.put("ResultSetOpenningCount", stat.getResultSetStat().getOpenningCount()); - map.put("ResultSetOpenningMax", stat.getResultSetStat().getOpenningMax()); - map.put("ResultSetFetchRowCount", stat.getResultSetStat().getFetchRowCount()); - map.put("ResultSetLastOpenTime", stat.getResultSetStat().getLastOpenTime()); - - // 30 - 34 - map.put("ResultSetErrorCount", stat.getResultSetStat().getErrorCount()); - map.put("ResultSetOpenningMillisTotal", stat.getResultSetStat().getAliveMillisTotal()); - map.put("ResultSetLastErrorTime", stat.getResultSetStat().getLastErrorTime()); - map.put("ResultSetLastErrorMessage", null); - map.put("ResultSetLastErrorStackTrace", null); - - // 35 - 39 - map.put("ConnectionConnectCount", this.getConnectCount()); - if (createError != null) { - map.put("ConnectionErrorLastMessage", createError.getMessage()); - map.put("ConnectionErrorLastStackTrace", IOUtils.getStackTrace(createError)); - } else { - map.put("ConnectionErrorLastMessage", null); - map.put("ConnectionErrorLastStackTrace", null); - } - map.put("ConnectionConnectMillisTotal", stat.getConnectionStat().getConnectMillis()); - map.put("ConnectionConnectingCountMax", stat.getConnectionStat().getConnectingMax()); - - // 40 - 44 - map.put("ConnectionConnectMillisMax", stat.getConnectionStat().getConnectMillisMax()); - map.put("ConnectionErrorLastTime", stat.getConnectionStat().getErrorLastTime()); - map.put("ConnectionAliveMillisMax", stat.getConnectionConnectAliveMillisMax()); - map.put("ConnectionAliveMillisMin", stat.getConnectionConnectAliveMillisMin()); - - map.put("ConnectionHistogram", stat.getConnectionHistogramValues()); - map.put("StatementHistogram", stat.getStatementStat().getHistogramValues()); - - return new CompositeDataSupport(JdbcStatManager.getDataSourceCompositeType(), map); - } - - public long getID() { - return this.id; - } - - public Date getCreatedTime() { - return createdTime; - } - - public abstract int getRawDriverMajorVersion(); - - public abstract int getRawDriverMinorVersion(); - - public abstract String getProperties(); - - public Logger getParentLogger() throws SQLFeatureNotSupportedException { - throw new SQLFeatureNotSupportedException(); - } - - public void closePreapredStatement(PreparedStatementHolder stmtHolder) { - if (stmtHolder == null) { - return; - } - closedPreparedStatementCount.incrementAndGet(); - decrementCachedPreparedStatementCount(); - incrementCachedPreparedStatementDeleteCount(); - - JdbcUtils.close(stmtHolder.getStatement()); - } - - protected void cloneTo(DruidAbstractDataSource to) { - to.defaultAutoCommit = this.defaultAutoCommit; - to.defaultReadOnly = this.defaultReadOnly; - to.defaultTransactionIsolation = this.defaultTransactionIsolation; - to.defaultCatalog = this.defaultCatalog; - to.name = this.name; - to.username = this.username; - to.password = this.password; - to.jdbcUrl = this.jdbcUrl; - to.driverClass = this.driverClass; - to.connectProperties = this.connectProperties; - to.passwordCallback = this.passwordCallback; - to.userCallback = this.userCallback; - to.initialSize = this.initialSize; - to.maxActive = this.maxActive; - to.minIdle = this.minIdle; - to.maxIdle = this.maxIdle; - to.maxWait = this.maxWait; - to.validationQuery = this.validationQuery; - to.validationQueryTimeout = this.validationQueryTimeout; - to.testOnBorrow = this.testOnBorrow; - to.testOnReturn = this.testOnReturn; - to.testWhileIdle = this.testWhileIdle; - to.poolPreparedStatements = this.poolPreparedStatements; - to.sharePreparedStatements = this.sharePreparedStatements; - to.maxPoolPreparedStatementPerConnectionSize = this.maxPoolPreparedStatementPerConnectionSize; - to.logWriter = this.logWriter; - if (this.filters != null) { - to.filters = new ArrayList(this.filters); - } - to.exceptionSorter = this.exceptionSorter; - to.driver = this.driver; - to.queryTimeout = this.queryTimeout; - to.transactionQueryTimeout = this.transactionQueryTimeout; - to.accessToUnderlyingConnectionAllowed = this.accessToUnderlyingConnectionAllowed; - to.timeBetweenEvictionRunsMillis = this.timeBetweenEvictionRunsMillis; - to.numTestsPerEvictionRun = this.numTestsPerEvictionRun; - to.minEvictableIdleTimeMillis = this.minEvictableIdleTimeMillis; - to.removeAbandoned = this.removeAbandoned; - to.removeAbandonedTimeoutMillis = this.removeAbandonedTimeoutMillis; - to.logAbandoned = this.logAbandoned; - to.maxOpenPreparedStatements = this.maxOpenPreparedStatements; - if (connectionInitSqls != null) { - to.connectionInitSqls = new ArrayList(this.connectionInitSqls); - } - to.dbType = this.dbType; - to.timeBetweenConnectErrorMillis = this.timeBetweenConnectErrorMillis; - to.validConnectionChecker = this.validConnectionChecker; - to.connectionErrorRetryAttempts = this.connectionErrorRetryAttempts; - to.breakAfterAcquireFailure = this.breakAfterAcquireFailure; - to.transactionThresholdMillis = this.transactionThresholdMillis; - to.dupCloseLogEnable = this.dupCloseLogEnable; - to.isOracle = this.isOracle; - to.useOracleImplicitCache = this.useOracleImplicitCache; - } - - public abstract void discardConnection(Connection realConnection); -} +/* + * Copyright 1999-2011 Alibaba Group Holding Ltd. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.alibaba.druid.pool; + +import java.io.PrintWriter; +import java.io.Serializable; +import java.sql.Connection; +import java.sql.Driver; +import java.sql.DriverManager; +import java.sql.ResultSet; +import java.sql.SQLException; +import java.sql.SQLFeatureNotSupportedException; +import java.sql.Statement; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.Date; +import java.util.HashMap; +import java.util.HashSet; +import java.util.IdentityHashMap; +import java.util.Iterator; +import java.util.List; +import java.util.Map; +import java.util.Properties; +import java.util.Set; +import java.util.concurrent.CopyOnWriteArrayList; +import java.util.concurrent.atomic.AtomicLong; +import java.util.concurrent.locks.Condition; +import java.util.concurrent.locks.ReentrantLock; +import java.util.logging.Logger; + +import javax.management.JMException; +import javax.management.ObjectName; +import javax.management.openmbean.CompositeDataSupport; +import javax.security.auth.callback.NameCallback; +import javax.security.auth.callback.PasswordCallback; +import javax.sql.DataSource; + +import com.alibaba.druid.filter.Filter; +import com.alibaba.druid.filter.FilterChainImpl; +import com.alibaba.druid.filter.FilterManager; +import com.alibaba.druid.pool.vendor.NullExceptionSorter; +import com.alibaba.druid.proxy.jdbc.DataSourceProxy; +import com.alibaba.druid.proxy.jdbc.TransactionInfo; +import com.alibaba.druid.stat.JdbcDataSourceStat; +import com.alibaba.druid.stat.JdbcSqlStat; +import com.alibaba.druid.stat.JdbcStatManager; +import com.alibaba.druid.support.logging.Log; +import com.alibaba.druid.support.logging.LogFactory; +import com.alibaba.druid.util.DruidPasswordCallback; +import com.alibaba.druid.util.Histogram; +import com.alibaba.druid.util.IOUtils; +import com.alibaba.druid.util.JdbcUtils; +import com.alibaba.druid.util.StringUtils; + +/** + * @author wenshao + * @author ljw + */ +public abstract class DruidAbstractDataSource extends WrapperAdapter implements DruidAbstractDataSourceMBean, DataSource, DataSourceProxy, Serializable { + + private final static Log LOG = LogFactory.getLog(DruidAbstractDataSource.class); + + private static final long serialVersionUID = 1L; + + public final static int DEFAULT_INITIAL_SIZE = 0; + public final static int DEFAULT_MAX_ACTIVE_SIZE = 8; + public final static int DEFAULT_MAX_IDLE = 8; + public final static int DEFAULT_MIN_IDLE = 0; + public final static int DEFAULT_MAX_WAIT = -1; + public final static String DEFAULT_VALIDATION_QUERY = null; // + public final static boolean DEFAULT_TEST_ON_BORROW = false; + public final static boolean DEFAULT_TEST_ON_RETURN = false; + public final static boolean DEFAULT_WHILE_IDLE = true; + public static final long DEFAULT_TIME_BETWEEN_EVICTION_RUNS_MILLIS = -1L; + public static final long DEFAULT_TIME_BETWEEN_CONNECT_ERROR_MILLIS = 30 * 1000; + public static final int DEFAULT_NUM_TESTS_PER_EVICTION_RUN = 3; + + /** + * The default value for {@link #getMinEvictableIdleTimeMillis}. + * + * @see #getMinEvictableIdleTimeMillis + * @see #setMinEvictableIdleTimeMillis + */ + public static final long DEFAULT_MIN_EVICTABLE_IDLE_TIME_MILLIS = 1000L * 60L * 30L; + + protected volatile boolean defaultAutoCommit = true; + protected volatile Boolean defaultReadOnly; + protected volatile Integer defaultTransactionIsolation; + protected volatile String defaultCatalog = null; + + protected String name; + + protected volatile String username; + protected volatile String password; + protected volatile String jdbcUrl; + protected volatile String driverClass; + protected volatile ClassLoader driverClassLoader; + protected volatile Properties connectProperties = new Properties(); + + protected volatile PasswordCallback passwordCallback; + protected volatile NameCallback userCallback; + + protected volatile int initialSize = DEFAULT_INITIAL_SIZE; + protected volatile int maxActive = DEFAULT_MAX_ACTIVE_SIZE; + protected volatile int minIdle = DEFAULT_MIN_IDLE; + protected volatile int maxIdle = DEFAULT_MAX_IDLE; + protected volatile long maxWait = DEFAULT_MAX_WAIT; + + protected volatile String validationQuery = DEFAULT_VALIDATION_QUERY; + protected volatile int validationQueryTimeout = -1; + private volatile boolean testOnBorrow = DEFAULT_TEST_ON_BORROW; + private volatile boolean testOnReturn = DEFAULT_TEST_ON_RETURN; + private volatile boolean testWhileIdle = DEFAULT_WHILE_IDLE; + protected volatile boolean poolPreparedStatements = false; + protected volatile boolean sharePreparedStatements = false; + protected volatile int maxPoolPreparedStatementPerConnectionSize = 10; + + protected volatile boolean inited = false; + + protected PrintWriter logWriter = new PrintWriter( + System.out); + + protected List filters = new CopyOnWriteArrayList(); + protected volatile ExceptionSorter exceptionSorter = null; + + protected Driver driver; + + protected volatile int queryTimeout; + protected volatile int transactionQueryTimeout; + + protected AtomicLong createErrorCount = new AtomicLong(); + + protected long createTimespan; + + protected volatile int maxWaitThreadCount = -1; + + protected volatile boolean accessToUnderlyingConnectionAllowed = true; + + protected volatile long timeBetweenEvictionRunsMillis = DEFAULT_TIME_BETWEEN_EVICTION_RUNS_MILLIS; + + protected volatile int numTestsPerEvictionRun = DEFAULT_NUM_TESTS_PER_EVICTION_RUN; + + protected volatile long minEvictableIdleTimeMillis = DEFAULT_MIN_EVICTABLE_IDLE_TIME_MILLIS; + + protected volatile boolean removeAbandoned; + + protected volatile long removeAbandonedTimeoutMillis = 300 * 1000; + + protected volatile boolean logAbandoned; + + protected volatile int maxOpenPreparedStatements = -1; + + protected volatile List connectionInitSqls; + + protected volatile String dbType; + + protected volatile long timeBetweenConnectErrorMillis = DEFAULT_TIME_BETWEEN_CONNECT_ERROR_MILLIS; + + protected volatile ValidConnectionChecker validConnectionChecker = null; + + protected final AtomicLong errorCount = new AtomicLong(); + protected final AtomicLong dupCloseCount = new AtomicLong(); + + protected final Map activeConnections = new IdentityHashMap(); + protected final static Object PRESENT = new Object(); + + protected long id; + + protected final Date createdTime = new Date(); + protected Date initedTime; + + protected int connectionErrorRetryAttempts = 30; + + protected boolean breakAfterAcquireFailure = false; + + protected long transactionThresholdMillis = 0L; + + protected final AtomicLong commitCount = new AtomicLong(); + protected final AtomicLong startTransactionCount = new AtomicLong(); + protected final AtomicLong rollbackCount = new AtomicLong(); + protected final AtomicLong cachedPreparedStatementHitCount = new AtomicLong(); + protected final AtomicLong preparedStatementCount = new AtomicLong(); + protected final AtomicLong closedPreparedStatementCount = new AtomicLong(); + protected final AtomicLong cachedPreparedStatementCount = new AtomicLong(); + protected final AtomicLong cachedPreparedStatementDeleteCount = new AtomicLong(); + protected final AtomicLong cachedPreparedStatementMissCount = new AtomicLong(); + + protected final Histogram transactionHistogram = new Histogram( + 10, + 100, + 1000, + 10 * 1000, + 100 * 1000); + + private boolean dupCloseLogEnable = false; + + private ObjectName objectName; + + protected final AtomicLong executeCount = new AtomicLong(); + + protected volatile Throwable createError; + protected volatile Throwable lastError; + protected volatile long lastErrorTimeMillis; + protected volatile Throwable lastCreateError; + protected volatile long lastCreateErrorTimeMillis; + + protected boolean isOracle = false; + + protected boolean useOracleImplicitCache = true; + + protected ReentrantLock lock; + protected Condition notEmpty; + protected Condition empty; + + protected AtomicLong createCount = new AtomicLong(); + protected AtomicLong destroyCount = new AtomicLong(); + + private Boolean useUnfairLock = null; + + private boolean useLocalSessionState = true; + + protected long timeBetweenLogStatsMillis; + protected DruidDataSourceStatLogger statLogger = new DruidDataSourceStatLoggerImpl(); + + public DruidAbstractDataSource(boolean lockFair){ + lock = new ReentrantLock(lockFair); + + notEmpty = lock.newCondition(); + empty = lock.newCondition(); + } + + public boolean isUseLocalSessionState() { + return useLocalSessionState; + } + + public void setUseLocalSessionState(boolean useLocalSessionState) { + this.useLocalSessionState = useLocalSessionState; + } + + public DruidDataSourceStatLogger getStatLogger() { + return statLogger; + } + + public void setStatLoggerClassName(String className) { + Class clazz; + try { + clazz = Class.forName(className); + DruidDataSourceStatLogger statLogger = (DruidDataSourceStatLogger) clazz.newInstance(); + this.setStatLogger(statLogger); + } catch (Exception e) { + throw new IllegalArgumentException(className, e); + } + } + + public void setStatLogger(DruidDataSourceStatLogger statLogger) { + this.statLogger = statLogger; + } + + public long getTimeBetweenLogStatsMillis() { + return timeBetweenLogStatsMillis; + } + + public void setTimeBetweenLogStatsMillis(long timeBetweenLogStatsMillis) { + this.timeBetweenLogStatsMillis = timeBetweenLogStatsMillis; + } + + public boolean isOracle() { + return isOracle; + } + + public void setOracle(boolean isOracle) { + if (inited) { + throw new IllegalStateException(); + } + this.isOracle = isOracle; + } + + public boolean isUseUnfairLock() { + return lock.isFair(); + } + + public void setUseUnfairLock(boolean useUnfairLock) { + if (lock.isFair() == !useUnfairLock) { + return; + } + + if (!this.inited) { + final ReentrantLock lock = this.lock; + lock.lock(); + try { + if (!this.inited) { + this.lock = new ReentrantLock(!useUnfairLock); + this.notEmpty = this.lock.newCondition(); + this.empty = this.lock.newCondition(); + + this.useUnfairLock = useUnfairLock; + } + } finally { + lock.unlock(); + } + } + } + + public boolean isUseOracleImplicitCache() { + return useOracleImplicitCache; + } + + public void setUseOracleImplicitCache(boolean useOracleImplicitCache) { + if (this.useOracleImplicitCache != useOracleImplicitCache) { + this.useOracleImplicitCache = useOracleImplicitCache; + boolean isOracleDriver10 = isOracle() && this.driver != null && this.driver.getMajorVersion() == 10; + + if (isOracleDriver10 && useOracleImplicitCache) { + this.getConnectProperties().setProperty("oracle.jdbc.FreeMemoryOnEnterImplicitCache", "true"); + } else { + this.getConnectProperties().remove("oracle.jdbc.FreeMemoryOnEnterImplicitCache"); + } + } + } + + public Throwable getLastCreateError() { + return lastCreateError; + } + + public Throwable getLastError() { + return this.lastError; + } + + public long getLastErrorTimeMillis() { + return lastErrorTimeMillis; + } + + public Date getLastErrorTime() { + if (lastErrorTimeMillis <= 0) { + return null; + } + + return new Date(lastErrorTimeMillis); + } + + public long getLastCreateErrorTimeMillis() { + return lastCreateErrorTimeMillis; + } + + public Date getLastCreateErrorTime() { + if (lastCreateErrorTimeMillis <= 0) { + return null; + } + + return new Date(lastCreateErrorTimeMillis); + } + + public int getTransactionQueryTimeout() { + if (transactionQueryTimeout <= 0) { + return queryTimeout; + } + + return transactionQueryTimeout; + } + + public void setTransactionQueryTimeout(int transactionQueryTimeout) { + this.transactionQueryTimeout = transactionQueryTimeout; + } + + public long getExecuteCount() { + return executeCount.get(); + } + + public void incrementExecuteCount() { + this.executeCount.incrementAndGet(); + } + + public boolean isDupCloseLogEnable() { + return dupCloseLogEnable; + } + + public void setDupCloseLogEnable(boolean dupCloseLogEnable) { + this.dupCloseLogEnable = dupCloseLogEnable; + } + + public ObjectName getObjectName() { + return objectName; + } + + public void setObjectName(ObjectName objectName) { + this.objectName = objectName; + } + + public Histogram getTransactionHistogram() { + return transactionHistogram; + } + + public void incrementCachedPreparedStatementCount() { + cachedPreparedStatementCount.incrementAndGet(); + } + + public void decrementCachedPreparedStatementCount() { + cachedPreparedStatementCount.decrementAndGet(); + } + + public void incrementCachedPreparedStatementDeleteCount() { + cachedPreparedStatementDeleteCount.incrementAndGet(); + } + + public void incrementCachedPreparedStatementMissCount() { + cachedPreparedStatementMissCount.incrementAndGet(); + } + + public long getCachedPreparedStatementMissCount() { + return cachedPreparedStatementMissCount.get(); + } + + public long getCachedPreparedStatementAccessCount() { + return cachedPreparedStatementMissCount.get() + cachedPreparedStatementHitCount.get(); + } + + public long getCachedPreparedStatementDeleteCount() { + return cachedPreparedStatementDeleteCount.get(); + } + + public long getCachedPreparedStatementCount() { + return cachedPreparedStatementCount.get(); + } + + public void incrementClosedPreparedStatementCount() { + closedPreparedStatementCount.incrementAndGet(); + } + + public long getClosedPreparedStatementCount() { + return closedPreparedStatementCount.get(); + } + + public void incrementPreparedStatementCount() { + preparedStatementCount.incrementAndGet(); + } + + public long getPreparedStatementCount() { + return preparedStatementCount.get(); + } + + public void incrementCachedPreparedStatementHitCount() { + cachedPreparedStatementHitCount.incrementAndGet(); + } + + public long getCachedPreparedStatementHitCount() { + return cachedPreparedStatementHitCount.get(); + } + + public long getTransactionThresholdMillis() { + return transactionThresholdMillis; + } + + public void setTransactionThresholdMillis(long transactionThresholdMillis) { + this.transactionThresholdMillis = transactionThresholdMillis; + } + + public abstract void logTransaction(TransactionInfo info); + + public long[] getTransactionHistogramValues() { + return transactionHistogram.toArray(); + } + + public long[] getTransactionHistogramRanges() { + return transactionHistogram.getRanges(); + } + + public long getCommitCount() { + return commitCount.get(); + } + + public void incrementCommitCount() { + commitCount.incrementAndGet(); + } + + public long getRollbackCount() { + return rollbackCount.get(); + } + + public void incrementRollbackCount() { + rollbackCount.incrementAndGet(); + } + + public long getStartTransactionCount() { + return startTransactionCount.get(); + } + + public void incrementStartTransactionCount() { + startTransactionCount.incrementAndGet(); + } + + public boolean isBreakAfterAcquireFailure() { + return breakAfterAcquireFailure; + } + + public void setBreakAfterAcquireFailure(boolean breakAfterAcquireFailure) { + this.breakAfterAcquireFailure = breakAfterAcquireFailure; + } + + public int getConnectionErrorRetryAttempts() { + return connectionErrorRetryAttempts; + } + + public void setConnectionErrorRetryAttempts(int connectionErrorRetryAttempts) { + this.connectionErrorRetryAttempts = connectionErrorRetryAttempts; + } + + public long getDupCloseCount() { + return dupCloseCount.get(); + } + + public int getMaxPoolPreparedStatementPerConnectionSize() { + return maxPoolPreparedStatementPerConnectionSize; + } + + public void setMaxPoolPreparedStatementPerConnectionSize(int maxPoolPreparedStatementPerConnectionSize) { + if (maxPoolPreparedStatementPerConnectionSize > 0) { + this.poolPreparedStatements = true; + } + + this.maxPoolPreparedStatementPerConnectionSize = maxPoolPreparedStatementPerConnectionSize; + } + + public boolean isSharePreparedStatements() { + return sharePreparedStatements; + } + + public void setSharePreparedStatements(boolean sharePreparedStatements) { + this.sharePreparedStatements = sharePreparedStatements; + } + + public void incrementDupCloseCount() { + dupCloseCount.incrementAndGet(); + } + + public ValidConnectionChecker getValidConnectionChecker() { + return validConnectionChecker; + } + + public void setValidConnectionChecker(ValidConnectionChecker validConnectionChecker) { + this.validConnectionChecker = validConnectionChecker; + } + + public String getValidConnectionCheckerClassName() { + if (validConnectionChecker == null) { + return null; + } + + return validConnectionChecker.getClass().getName(); + } + + public void setValidConnectionCheckerClassName(String validConnectionCheckerClass) throws Exception { + Class clazz = JdbcUtils.loadDriverClass(validConnectionCheckerClass); + ValidConnectionChecker validConnectionChecker = null; + if (clazz != null) { + validConnectionChecker = (ValidConnectionChecker) clazz.newInstance(); + this.validConnectionChecker = validConnectionChecker; + } else { + LOG.error("load validConnectionCheckerClass error : " + validConnectionCheckerClass); + } + } + + public String getDbType() { + return dbType; + } + + public void setDbType(String dbType) { + this.dbType = dbType; + } + + public void addConnectionProperty(String name, String value) { + if (inited) { + throw new UnsupportedOperationException(); + } + + connectProperties.put(name, value); + } + + public Collection getConnectionInitSqls() { + Collection result = connectionInitSqls; + if (result == null) { + return Collections.emptyList(); + } + return result; + } + + public void setConnectionInitSqls(Collection connectionInitSqls) { + if ((connectionInitSqls != null) && (connectionInitSqls.size() > 0)) { + ArrayList newVal = null; + for (Iterator iterator = connectionInitSqls.iterator(); iterator.hasNext();) { + Object o = iterator.next(); + if (o != null) { + String s = o.toString(); + if (s.trim().length() > 0) { + if (newVal == null) { + newVal = new ArrayList(); + } + newVal.add(s); + } + } + } + this.connectionInitSqls = newVal; + } else { + this.connectionInitSqls = null; + } + } + + public long getTimeBetweenConnectErrorMillis() { + return timeBetweenConnectErrorMillis; + } + + public void setTimeBetweenConnectErrorMillis(long timeBetweenConnectErrorMillis) { + this.timeBetweenConnectErrorMillis = timeBetweenConnectErrorMillis; + } + + public int getMaxOpenPreparedStatements() { + return maxPoolPreparedStatementPerConnectionSize; + } + + public void setMaxOpenPreparedStatements(int maxOpenPreparedStatements) { + this.setMaxPoolPreparedStatementPerConnectionSize(maxOpenPreparedStatements); + } + + public boolean isLogAbandoned() { + return logAbandoned; + } + + public void setLogAbandoned(boolean logAbandoned) { + this.logAbandoned = logAbandoned; + } + + public int getRemoveAbandonedTimeout() { + return (int) (removeAbandonedTimeoutMillis / 1000); + } + + public void setRemoveAbandonedTimeout(int removeAbandonedTimeout) { + this.removeAbandonedTimeoutMillis = (long) removeAbandonedTimeout * 1000; + } + + public void setRemoveAbandonedTimeoutMillis(long removeAbandonedTimeoutMillis) { + this.removeAbandonedTimeoutMillis = removeAbandonedTimeoutMillis; + } + + public long getRemoveAbandonedTimeoutMillis() { + return removeAbandonedTimeoutMillis; + } + + public boolean isRemoveAbandoned() { + return removeAbandoned; + } + + public void setRemoveAbandoned(boolean removeAbandoned) { + this.removeAbandoned = removeAbandoned; + } + + public long getMinEvictableIdleTimeMillis() { + return minEvictableIdleTimeMillis; + } + + public void setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis) { + this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis; + } + + public int getNumTestsPerEvictionRun() { + return numTestsPerEvictionRun; + } + + /** + * @param numTestsPerEvictionRun + */ + @Deprecated + public void setNumTestsPerEvictionRun(int numTestsPerEvictionRun) { + this.numTestsPerEvictionRun = numTestsPerEvictionRun; + } + + public long getTimeBetweenEvictionRunsMillis() { + return timeBetweenEvictionRunsMillis; + } + + public void setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis) { + this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis; + } + + public int getMaxWaitThreadCount() { + return maxWaitThreadCount; + } + + public void setMaxWaitThreadCount(int maxWaithThreadCount) { + this.maxWaitThreadCount = maxWaithThreadCount; + } + + public String getValidationQuery() { + return validationQuery; + } + + public void setValidationQuery(String validationQuery) { + this.validationQuery = validationQuery; + } + + public int getValidationQueryTimeout() { + return validationQueryTimeout; + } + + public void setValidationQueryTimeout(int validationQueryTimeout) { + this.validationQueryTimeout = validationQueryTimeout; + } + + public boolean isAccessToUnderlyingConnectionAllowed() { + return accessToUnderlyingConnectionAllowed; + } + + public void setAccessToUnderlyingConnectionAllowed(boolean accessToUnderlyingConnectionAllowed) { + this.accessToUnderlyingConnectionAllowed = accessToUnderlyingConnectionAllowed; + } + + public boolean isTestOnBorrow() { + return testOnBorrow; + } + + public void setTestOnBorrow(boolean testOnBorrow) { + this.testOnBorrow = testOnBorrow; + } + + public boolean isTestOnReturn() { + return testOnReturn; + } + + public void setTestOnReturn(boolean testOnReturn) { + this.testOnReturn = testOnReturn; + } + + public boolean isTestWhileIdle() { + return testWhileIdle; + } + + public void setTestWhileIdle(boolean testWhileIdle) { + this.testWhileIdle = testWhileIdle; + } + + public boolean isDefaultAutoCommit() { + return defaultAutoCommit; + } + + public void setDefaultAutoCommit(boolean defaultAutoCommit) { + this.defaultAutoCommit = defaultAutoCommit; + } + + public Boolean getDefaultReadOnly() { + return defaultReadOnly; + } + + public void setDefaultReadOnly(Boolean defaultReadOnly) { + this.defaultReadOnly = defaultReadOnly; + } + + public Integer getDefaultTransactionIsolation() { + return defaultTransactionIsolation; + } + + public void setDefaultTransactionIsolation(Integer defaultTransactionIsolation) { + this.defaultTransactionIsolation = defaultTransactionIsolation; + } + + public String getDefaultCatalog() { + return defaultCatalog; + } + + public void setDefaultCatalog(String defaultCatalog) { + this.defaultCatalog = defaultCatalog; + } + + public PasswordCallback getPasswordCallback() { + return passwordCallback; + } + + public void setPasswordCallback(PasswordCallback passwordCallback) { + this.passwordCallback = passwordCallback; + } + + public void setPasswordCallbackClassName(String passwordCallbackClassName) throws Exception { + Class clazz = JdbcUtils.loadDriverClass(passwordCallbackClassName); + if (clazz != null) { + this.passwordCallback = (PasswordCallback) clazz.newInstance(); + } else { + LOG.error("load passwordCallback error : " + passwordCallbackClassName); + this.passwordCallback = null; + } + } + + public NameCallback getUserCallback() { + return userCallback; + } + + public void setUserCallback(NameCallback userCallback) { + this.userCallback = userCallback; + } + + /** + * Retrieves the number of seconds the driver will wait for a Statement object to execute. If the limit + * is exceeded, a SQLException is thrown. + * + * @return the current query timeout limit in seconds; zero means there is no limit + * @exception SQLException if a database access error occurs or this method is called on a closed + * Statement + * @see #setQueryTimeout + */ + public int getQueryTimeout() { + return queryTimeout; + } + + /** + * Sets the number of seconds the driver will wait for a Statement object to execute to the given + * number of seconds. If the limit is exceeded, an SQLException is thrown. A JDBC driver must apply + * this limit to the execute, executeQuery and executeUpdate methods. JDBC + * driver implementations may also apply this limit to ResultSet methods (consult your driver vendor + * documentation for details). + * + * @param seconds the new query timeout limit in seconds; zero means there is no limit + * @exception SQLException if a database access error occurs, this method is called on a closed + * Statement or the condition seconds >= 0 is not satisfied + * @see #getQueryTimeout + */ + public void setQueryTimeout(int seconds) { + this.queryTimeout = seconds; + } + + public String getName() { + if (name != null) { + return name; + } + return "DataSource-" + System.identityHashCode(this); + } + + public void setName(String name) { + this.name = name; + } + + public boolean isPoolPreparedStatements() { + return poolPreparedStatements; + } + + public abstract void setPoolPreparedStatements(boolean value); + + public long getMaxWait() { + return maxWait; + } + + public void setMaxWait(long maxWaitMillis) { + if (maxWaitMillis == this.maxWait) { + return; + } + + if (maxWaitMillis > 0 && useUnfairLock == null && !this.inited) { + final ReentrantLock lock = this.lock; + lock.lock(); + try { + if ((!this.inited) && (!lock.isFair())) { + this.lock = new ReentrantLock(true); + this.notEmpty = this.lock.newCondition(); + this.empty = this.lock.newCondition(); + } + } finally { + lock.unlock(); + } + } + + if (inited) { + LOG.error("maxWait changed : " + this.maxWait + " -> " + maxWaitMillis); + } + + this.maxWait = maxWaitMillis; + } + + public int getMinIdle() { + return minIdle; + } + + public void setMinIdle(int value) { + if (value == this.minIdle) { + return; + } + + if (inited) { + if (value > this.maxActive) { + throw new IllegalArgumentException("minIdle greater than maxActive, " + maxActive + " < " + + this.minIdle); + } + + LOG.error("minIdle changed : " + this.minIdle + " -> " + value); + } + + this.minIdle = value; + } + + public int getMaxIdle() { + return maxIdle; + } + + @Deprecated + public void setMaxIdle(int maxIdle) { + LOG.error("maxIdle is deprecated"); + + this.maxIdle = maxIdle; + } + + public int getInitialSize() { + return initialSize; + } + + public void setInitialSize(int initialSize) { + if (this.initialSize == initialSize) { + return; + } + + if (inited) { + throw new UnsupportedOperationException(); + } + + this.initialSize = initialSize; + } + + public long getCreateErrorCount() { + return createErrorCount.get(); + } + + public int getMaxActive() { + return maxActive; + } + + public abstract void setMaxActive(int maxActive); + + public String getUsername() { + return username; + } + + public void setUsername(String username) { + if (inited) { + throw new UnsupportedOperationException(); + } + + this.username = username; + } + + public String getPassword() { + return password; + } + + public void setPassword(String password) { + if (StringUtils.equals(this.password, password)) { + return; + } + + if (inited) { + LOG.info("password changed"); + } + + this.password = password; + } + + public Properties getConnectProperties() { + return connectProperties; + } + + public abstract void setConnectProperties(Properties properties); + + public void setConnectionProperties(String connectionProperties) { + if (connectionProperties == null || connectionProperties.trim().length() == 0) { + setConnectProperties(null); + return; + } + + String[] entries = connectionProperties.split(";"); + Properties properties = new Properties(); + for (int i = 0; i < entries.length; i++) { + String entry = entries[i]; + if (entry.length() > 0) { + int index = entry.indexOf('='); + if (index > 0) { + String name = entry.substring(0, index); + String value = entry.substring(index + 1); + properties.setProperty(name, value); + } else { + // no value is empty string which is how java.util.Properties works + properties.setProperty(entry, ""); + } + } + } + + setConnectProperties(properties); + } + + public String getUrl() { + return jdbcUrl; + } + + public String getRawJdbcUrl() { + return jdbcUrl; + } + + public void setUrl(String jdbcUrl) { + if (inited) { + throw new UnsupportedOperationException(); + } + + if (jdbcUrl != null) { + jdbcUrl = jdbcUrl.trim(); + } + + this.jdbcUrl = jdbcUrl; + + // if (jdbcUrl.startsWith(ConfigFilter.URL_PREFIX)) { + // this.filters.add(new ConfigFilter()); + // } + } + + public String getDriverClassName() { + return driverClass; + } + + public void setDriverClassName(String driverClass) { + if (inited) { + throw new UnsupportedOperationException(); + } + + this.driverClass = driverClass; + } + + public ClassLoader getDriverClassLoader() { + return driverClassLoader; + } + + public void setDriverClassLoader(ClassLoader driverClassLoader) { + this.driverClassLoader = driverClassLoader; + } + + @Override + public PrintWriter getLogWriter() { + return logWriter; + } + + @Override + public void setLogWriter(PrintWriter out) throws SQLException { + this.logWriter = out; + } + + @Override + public void setLoginTimeout(int seconds) { + DriverManager.setLoginTimeout(seconds); + } + + @Override + public int getLoginTimeout() { + return DriverManager.getLoginTimeout(); + } + + public Driver getDriver() { + return driver; + } + + public void setDriver(Driver driver) { + this.driver = driver; + } + + public int getDriverMajorVersion() { + if (this.driver == null) { + return -1; + } + + return this.driver.getMajorVersion(); + } + + public int getDriverMinorVersion() { + if (this.driver == null) { + return -1; + } + + return this.driver.getMinorVersion(); + } + + public ExceptionSorter getExceptionSorter() { + return exceptionSorter; + } + + public String getExceptionSorterClassName() { + if (exceptionSorter == null) { + return null; + } + + return exceptionSorter.getClass().getName(); + } + + public void setExceptionSorter(ExceptionSorter exceptionSoter) { + this.exceptionSorter = exceptionSoter; + } + + // 兼容JBOSS + public void setExceptionSorterClassName(String exceptionSorter) throws Exception { + this.setExceptionSorter(exceptionSorter); + } + + public void setExceptionSorter(String exceptionSorter) throws SQLException { + if (exceptionSorter == null) { + this.exceptionSorter = NullExceptionSorter.getInstance(); + return; + } + + exceptionSorter = exceptionSorter.trim(); + if (exceptionSorter.length() == 0) { + this.exceptionSorter = NullExceptionSorter.getInstance(); + return; + } + + Class clazz = JdbcUtils.loadDriverClass(exceptionSorter); + if (clazz == null) { + LOG.error("load exceptionSorter error : " + exceptionSorter); + } else { + try { + this.exceptionSorter = (ExceptionSorter) clazz.newInstance(); + } catch (Exception ex) { + throw new SQLException("create exceptionSorter error", ex); + } + } + } + + @Override + public List getProxyFilters() { + return filters; + } + + public void setProxyFilters(List filters) { + if (filters != null) { + this.filters.addAll(filters); + } + } + + public String[] getFilterClasses() { + List filterConfigList = getProxyFilters(); + + List classes = new ArrayList(); + for (Filter filter : filterConfigList) { + classes.add(filter.getClass().getName()); + } + + return classes.toArray(new String[classes.size()]); + } + + public void setFilters(String filters) throws SQLException { + if (filters == null || filters.length() == 0) { + return; + } + + String[] filterArray = filters.split("\\,"); + + for (String item : filterArray) { + FilterManager.loadFilter(this.filters, item); + } + } + + public void clearFilters() { + this.filters.clear(); + } + + public void validateConnection(Connection conn) throws SQLException { + String query = getValidationQuery(); + if (conn.isClosed()) { + throw new SQLException("validateConnection: connection closed"); + } + + if (validConnectionChecker != null) { + if (!validConnectionChecker.isValidConnection(conn, validationQuery, validationQueryTimeout)) { + throw new SQLException("validateConnection false"); + } + return; + } + + if (null != query) { + Statement stmt = null; + ResultSet rs = null; + try { + stmt = conn.createStatement(); + if (getValidationQueryTimeout() > 0) { + stmt.setQueryTimeout(getValidationQueryTimeout()); + } + rs = stmt.executeQuery(query); + if (!rs.next()) { + throw new SQLException("validationQuery didn't return a row"); + } + } finally { + JdbcUtils.close(rs); + JdbcUtils.close(stmt); + } + } + } + + protected boolean testConnectionInternal(Connection conn) { + String sqlFile = JdbcSqlStat.getContextSqlFile(); + String sqlName = JdbcSqlStat.getContextSqlName(); + + if (sqlFile != null) { + JdbcSqlStat.setContextSqlFile(null); + } + if (sqlName != null) { + JdbcSqlStat.setContextSqlName(null); + } + try { + if (validConnectionChecker != null) { + return validConnectionChecker.isValidConnection(conn, validationQuery, validationQueryTimeout); + } + + if (conn.isClosed()) { + return false; + } + + if (null == validationQuery) { + return true; + } + + Statement stmt = null; + ResultSet rset = null; + try { + stmt = conn.createStatement(); + if (getValidationQueryTimeout() > 0) { + stmt.setQueryTimeout(validationQueryTimeout); + } + rset = stmt.executeQuery(validationQuery); + if (!rset.next()) { + return false; + } + } finally { + JdbcUtils.close(rset); + JdbcUtils.close(stmt); + } + + return true; + } catch (Exception ex) { + // skip + return false; + } finally { + if (sqlFile != null) { + JdbcSqlStat.setContextSqlFile(sqlFile); + } + if (sqlName != null) { + JdbcSqlStat.setContextSqlName(sqlName); + } + } + } + + public Set getActiveConnections() { + synchronized (activeConnections) { + return new HashSet(this.activeConnections.keySet()); + } + } + + public List getActiveConnectionStackTrace() { + List list = new ArrayList(); + + for (DruidPooledConnection conn : this.getActiveConnections()) { + list.add(IOUtils.toString(conn.getConnectStackTrace())); + } + + return list; + } + + public long getCreateTimespanNano() { + return createTimespan; + } + + public long getCreateTimespanMillis() { + return createTimespan / (1000 * 1000); + } + + @Override + public Driver getRawDriver() { + return driver; + } + + private final AtomicLong connectionIdSeed = new AtomicLong(10000); + private final AtomicLong statementIdSeed = new AtomicLong(20000); + private final AtomicLong resultSetIdSeed = new AtomicLong(50000); + private final AtomicLong transactionIdSeed = new AtomicLong(50000); + + public long createConnectionId() { + return connectionIdSeed.incrementAndGet(); + } + + public long createStatementId() { + return statementIdSeed.getAndIncrement(); + } + + public long createResultSetId() { + return resultSetIdSeed.getAndIncrement(); + } + + @Override + public long createTransactionId() { + return transactionIdSeed.getAndIncrement(); + } + + void initStatement(DruidPooledConnection conn, Statement stmt) throws SQLException { + boolean transaction = !conn.getConnectionHolder().isUnderlyingAutoCommit(); + + int queryTimeout = transaction ? getTransactionQueryTimeout() : getQueryTimeout(); + + if (queryTimeout > 0) { + stmt.setQueryTimeout(queryTimeout); + } + } + + public abstract void handleConnectionException(DruidPooledConnection pooledConnection, Throwable t) + throws SQLException; + + protected abstract void recycle(DruidPooledConnection pooledConnection) throws SQLException; + + public Connection createPhysicalConnection(String url, Properties info) throws SQLException { + Connection conn; + if (getProxyFilters().size() == 0) { + conn = getDriver().connect(url, info); + } else { + conn = new FilterChainImpl(this).connection_connect(info); + } + + createCount.incrementAndGet(); + + return conn; + } + + public Connection createPhysicalConnection() throws SQLException { + String url = this.getUrl(); + Properties connectProperties = getConnectProperties(); + + String user; + if (getUserCallback() != null) { + user = getUserCallback().getName(); + } else { + user = getUsername(); + } + + String password = getPassword(); + PasswordCallback passwordCallback = getPasswordCallback(); + + if (passwordCallback != null) { + if (passwordCallback instanceof DruidPasswordCallback) { + DruidPasswordCallback druidPasswordCallback = (DruidPasswordCallback) passwordCallback; + + druidPasswordCallback.setUrl(url); + druidPasswordCallback.setProperties(connectProperties); + } + + char[] chars = passwordCallback.getPassword(); + if (chars != null) { + password = new String(chars); + } + } + + Properties physicalConnectProperties = new Properties(); + if (connectProperties != null) { + physicalConnectProperties.putAll(connectProperties); + } + + if (user != null && user.length() != 0) { + physicalConnectProperties.put("user", user); + } + + if (password != null && password.length() != 0) { + physicalConnectProperties.put("password", password); + } + + Connection conn; + + long startNano = System.nanoTime(); + + try { + conn = createPhysicalConnection(url, physicalConnectProperties); + + if (conn == null) { + throw new SQLException("connect error, url " + url + ", driverClass " + this.driverClass); + } + + initPhysicalConnection(conn); + + validateConnection(conn); + createError = null; + } catch (SQLException ex) { + createErrorCount.incrementAndGet(); + createError = ex; + lastCreateError = ex; + lastCreateErrorTimeMillis = System.currentTimeMillis(); + throw ex; + } catch (RuntimeException ex) { + createErrorCount.incrementAndGet(); + createError = ex; + lastCreateError = ex; + lastCreateErrorTimeMillis = System.currentTimeMillis(); + throw ex; + } catch (Error ex) { + createErrorCount.incrementAndGet(); + throw ex; + } finally { + long nano = System.nanoTime() - startNano; + createTimespan += nano; + } + + return conn; + } + + public void initPhysicalConnection(Connection conn) throws SQLException { + if (conn.getAutoCommit() != defaultAutoCommit) { + conn.setAutoCommit(defaultAutoCommit); + } + + if (getDefaultReadOnly() != null) { + if (conn.isReadOnly() != getDefaultReadOnly()) { + conn.setReadOnly(getDefaultReadOnly()); + } + } + + if (getDefaultTransactionIsolation() != null) { + if (conn.getTransactionIsolation() != getDefaultTransactionIsolation().intValue()) { + conn.setTransactionIsolation(getDefaultTransactionIsolation()); + } + } + + if (getDefaultCatalog() != null && getDefaultCatalog().length() != 0) { + conn.setCatalog(getDefaultCatalog()); + } + } + + public abstract int getActivePeak(); + + public CompositeDataSupport getCompositeData() throws JMException { + JdbcDataSourceStat stat = this.getDataSourceStat(); + + Map map = new HashMap(); + + map.put("ID", getID()); + map.put("URL", this.getUrl()); + map.put("Name", this.getName()); + map.put("FilterClasses", getFilterClasses()); + map.put("CreatedTime", getCreatedTime()); + + map.put("RawDriverClassName", getDriverClassName()); + map.put("RawUrl", getUrl()); + map.put("RawDriverMajorVersion", getRawDriverMajorVersion()); + map.put("RawDriverMinorVersion", getRawDriverMinorVersion()); + map.put("Properties", getProperties()); + + // 0 - 4 + map.put("ConnectionActiveCount", (long) getActiveCount()); + map.put("ConnectionActiveCountMax", getActivePeak()); + map.put("ConnectionCloseCount", getCloseCount()); + map.put("ConnectionCommitCount", getCommitCount()); + map.put("ConnectionRollbackCount", getRollbackCount()); + + // 5 - 9 + map.put("ConnectionConnectLastTime", stat.getConnectionStat().getConnectLastTime()); + map.put("ConnectionConnectErrorCount", this.getCreateCount()); + if (createError != null) { + map.put("ConnectionConnectErrorLastTime", getLastCreateErrorTime()); + map.put("ConnectionConnectErrorLastMessage", createError.getMessage()); + map.put("ConnectionConnectErrorLastStackTrace", IOUtils.getStackTrace(createError)); + } else { + map.put("ConnectionConnectErrorLastTime", null); + map.put("ConnectionConnectErrorLastMessage", null); + map.put("ConnectionConnectErrorLastStackTrace", null); + } + + // 10 - 14 + map.put("StatementCreateCount", stat.getStatementStat().getCreateCount()); + map.put("StatementPrepareCount", stat.getStatementStat().getPrepareCount()); + map.put("StatementPreCallCount", stat.getStatementStat().getPrepareCallCount()); + map.put("StatementExecuteCount", stat.getStatementStat().getExecuteCount()); + map.put("StatementRunningCount", stat.getStatementStat().getRunningCount()); + + // 15 - 19 + map.put("StatementConcurrentMax", stat.getStatementStat().getConcurrentMax()); + map.put("StatementCloseCount", stat.getStatementStat().getCloseCount()); + map.put("StatementErrorCount", stat.getStatementStat().getErrorCount()); + map.put("StatementLastErrorTime", null); + map.put("StatementLastErrorMessage", null); + + // 20 - 24 + map.put("StatementLastErrorStackTrace", null); + map.put("StatementExecuteMillisTotal", stat.getStatementStat().getMillisTotal()); + map.put("StatementExecuteLastTime", stat.getStatementStat().getExecuteLastTime()); + map.put("ConnectionConnectingCount", stat.getConnectionStat().getConnectingCount()); + map.put("ResultSetCloseCount", stat.getResultSetStat().getCloseCount()); + + // 25 - 29 + map.put("ResultSetOpenCount", stat.getResultSetStat().getOpenCount()); + map.put("ResultSetOpenningCount", stat.getResultSetStat().getOpenningCount()); + map.put("ResultSetOpenningMax", stat.getResultSetStat().getOpenningMax()); + map.put("ResultSetFetchRowCount", stat.getResultSetStat().getFetchRowCount()); + map.put("ResultSetLastOpenTime", stat.getResultSetStat().getLastOpenTime()); + + // 30 - 34 + map.put("ResultSetErrorCount", stat.getResultSetStat().getErrorCount()); + map.put("ResultSetOpenningMillisTotal", stat.getResultSetStat().getAliveMillisTotal()); + map.put("ResultSetLastErrorTime", stat.getResultSetStat().getLastErrorTime()); + map.put("ResultSetLastErrorMessage", null); + map.put("ResultSetLastErrorStackTrace", null); + + // 35 - 39 + map.put("ConnectionConnectCount", this.getConnectCount()); + if (createError != null) { + map.put("ConnectionErrorLastMessage", createError.getMessage()); + map.put("ConnectionErrorLastStackTrace", IOUtils.getStackTrace(createError)); + } else { + map.put("ConnectionErrorLastMessage", null); + map.put("ConnectionErrorLastStackTrace", null); + } + map.put("ConnectionConnectMillisTotal", stat.getConnectionStat().getConnectMillis()); + map.put("ConnectionConnectingCountMax", stat.getConnectionStat().getConnectingMax()); + + // 40 - 44 + map.put("ConnectionConnectMillisMax", stat.getConnectionStat().getConnectMillisMax()); + map.put("ConnectionErrorLastTime", stat.getConnectionStat().getErrorLastTime()); + map.put("ConnectionAliveMillisMax", stat.getConnectionConnectAliveMillisMax()); + map.put("ConnectionAliveMillisMin", stat.getConnectionConnectAliveMillisMin()); + + map.put("ConnectionHistogram", stat.getConnectionHistogramValues()); + map.put("StatementHistogram", stat.getStatementStat().getHistogramValues()); + + return new CompositeDataSupport(JdbcStatManager.getDataSourceCompositeType(), map); + } + + public long getID() { + return this.id; + } + + public Date getCreatedTime() { + return createdTime; + } + + public abstract int getRawDriverMajorVersion(); + + public abstract int getRawDriverMinorVersion(); + + public abstract String getProperties(); + + public Logger getParentLogger() throws SQLFeatureNotSupportedException { + throw new SQLFeatureNotSupportedException(); + } + + public void closePreapredStatement(PreparedStatementHolder stmtHolder) { + if (stmtHolder == null) { + return; + } + closedPreparedStatementCount.incrementAndGet(); + decrementCachedPreparedStatementCount(); + incrementCachedPreparedStatementDeleteCount(); + + JdbcUtils.close(stmtHolder.getStatement()); + } + + protected void cloneTo(DruidAbstractDataSource to) { + to.defaultAutoCommit = this.defaultAutoCommit; + to.defaultReadOnly = this.defaultReadOnly; + to.defaultTransactionIsolation = this.defaultTransactionIsolation; + to.defaultCatalog = this.defaultCatalog; + to.name = this.name; + to.username = this.username; + to.password = this.password; + to.jdbcUrl = this.jdbcUrl; + to.driverClass = this.driverClass; + to.connectProperties = this.connectProperties; + to.passwordCallback = this.passwordCallback; + to.userCallback = this.userCallback; + to.initialSize = this.initialSize; + to.maxActive = this.maxActive; + to.minIdle = this.minIdle; + to.maxIdle = this.maxIdle; + to.maxWait = this.maxWait; + to.validationQuery = this.validationQuery; + to.validationQueryTimeout = this.validationQueryTimeout; + to.testOnBorrow = this.testOnBorrow; + to.testOnReturn = this.testOnReturn; + to.testWhileIdle = this.testWhileIdle; + to.poolPreparedStatements = this.poolPreparedStatements; + to.sharePreparedStatements = this.sharePreparedStatements; + to.maxPoolPreparedStatementPerConnectionSize = this.maxPoolPreparedStatementPerConnectionSize; + to.logWriter = this.logWriter; + if (this.filters != null) { + to.filters = new ArrayList(this.filters); + } + to.exceptionSorter = this.exceptionSorter; + to.driver = this.driver; + to.queryTimeout = this.queryTimeout; + to.transactionQueryTimeout = this.transactionQueryTimeout; + to.accessToUnderlyingConnectionAllowed = this.accessToUnderlyingConnectionAllowed; + to.timeBetweenEvictionRunsMillis = this.timeBetweenEvictionRunsMillis; + to.numTestsPerEvictionRun = this.numTestsPerEvictionRun; + to.minEvictableIdleTimeMillis = this.minEvictableIdleTimeMillis; + to.removeAbandoned = this.removeAbandoned; + to.removeAbandonedTimeoutMillis = this.removeAbandonedTimeoutMillis; + to.logAbandoned = this.logAbandoned; + to.maxOpenPreparedStatements = this.maxOpenPreparedStatements; + if (connectionInitSqls != null) { + to.connectionInitSqls = new ArrayList(this.connectionInitSqls); + } + to.dbType = this.dbType; + to.timeBetweenConnectErrorMillis = this.timeBetweenConnectErrorMillis; + to.validConnectionChecker = this.validConnectionChecker; + to.connectionErrorRetryAttempts = this.connectionErrorRetryAttempts; + to.breakAfterAcquireFailure = this.breakAfterAcquireFailure; + to.transactionThresholdMillis = this.transactionThresholdMillis; + to.dupCloseLogEnable = this.dupCloseLogEnable; + to.isOracle = this.isOracle; + to.useOracleImplicitCache = this.useOracleImplicitCache; + } + + public abstract void discardConnection(Connection realConnection); +} From d27e97f126491dca9c4dd35ecf6bf528ab7a840c Mon Sep 17 00:00:00 2001 From: wenshao Date: Fri, 14 Jun 2013 15:52:47 +0800 Subject: [PATCH 4/5] support reset filters --- .../druid/pool/DruidAbstractDataSource.java | 10 +++- .../druid/bvt/filter/ClearFilterTest.java | 22 +++++++ .../java/com/alibaba/druid/pool/MemTest.java | 57 +++++++++++++++++++ 3 files changed, 88 insertions(+), 1 deletion(-) create mode 100644 src/test/java/com/alibaba/druid/bvt/filter/ClearFilterTest.java create mode 100644 src/test/java/com/alibaba/druid/pool/MemTest.java diff --git a/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java b/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java index f7d1266512..847a54f009 100644 --- a/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java +++ b/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java @@ -1158,6 +1158,14 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements } public void setFilters(String filters) throws SQLException { + if (filters != null && filters.startsWith("!")) { + filters = filters.substring(1); + this.clearFilters(); + } + this.addFilters(filters); + } + + public void addFilters(String filters) throws SQLException { if (filters == null || filters.length() == 0) { return; } @@ -1166,7 +1174,7 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements for (String item : filterArray) { FilterManager.loadFilter(this.filters, item); - } + } } public void clearFilters() { diff --git a/src/test/java/com/alibaba/druid/bvt/filter/ClearFilterTest.java b/src/test/java/com/alibaba/druid/bvt/filter/ClearFilterTest.java new file mode 100644 index 0000000000..acfac7d718 --- /dev/null +++ b/src/test/java/com/alibaba/druid/bvt/filter/ClearFilterTest.java @@ -0,0 +1,22 @@ +package com.alibaba.druid.bvt.filter; + +import junit.framework.TestCase; + +import org.junit.Assert; + +import com.alibaba.druid.filter.stat.StatFilter; +import com.alibaba.druid.pool.DruidDataSource; + + +public class ClearFilterTest extends TestCase { + public void test_filters() throws Exception { + DruidDataSource dataSource = new DruidDataSource(); + Assert.assertEquals(0, dataSource.getProxyFilters().size()); + dataSource.setFilters("encoding"); + Assert.assertEquals(1, dataSource.getProxyFilters().size()); + dataSource.setFilters("!stat"); + Assert.assertEquals(1, dataSource.getProxyFilters().size()); + Assert.assertEquals(StatFilter.class.getName(), dataSource.getFilterClassNames().get(0)); + dataSource.close(); + } +} diff --git a/src/test/java/com/alibaba/druid/pool/MemTest.java b/src/test/java/com/alibaba/druid/pool/MemTest.java new file mode 100644 index 0000000000..ee123fb9f7 --- /dev/null +++ b/src/test/java/com/alibaba/druid/pool/MemTest.java @@ -0,0 +1,57 @@ +package com.alibaba.druid.pool; + +import java.sql.Connection; +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.util.List; + +import com.alibaba.druid.sql.ast.SQLStatement; +import com.alibaba.druid.sql.parser.SQLParserUtils; +import com.alibaba.druid.sql.parser.SQLStatementParser; +import com.alibaba.druid.sql.visitor.ParameterizedOutputVisitorUtils; +import com.alibaba.druid.sql.visitor.SQLASTOutputVisitor; + +public class MemTest { + + public static void main(String[] args) throws Exception { +// DruidDataSource dataSource = new DruidDataSource(); +// dataSource.setUrl("jdbc:mock:xxx"); +// dataSource.setInitialSize(1); +// dataSource.setDbType("mysql"); +// dataSource.setFilters("mergeStat"); + // dataSource.setPoolPreparedStatements(true); + // dataSource.setMaxOpenPreparedStatements(50); + + // for (int i = 1000; i < 2000; ++i) { + // String tableName = "t" + i; + // String sql = "select * from " + tableName + " where " + tableName + ".id = " + i; + // Connection conn = dataSource.getConnection(); + // + // PreparedStatement stmt = conn.prepareStatement(sql); + // stmt.execute(); + // stmt.close(); + // + // conn.close(); + // } + + // Connection conn = dataSource.getConnection(); + // + String sql = "SELECT UMID, HWID, MAC, GUID, RID , GMT_CREATE, GMT_MODIFIED FROM umid_rid " + // + "WHERE RID = ? " + // + "LIMIT 10"; + // PreparedStatement stmt = conn.prepareStatement(sql); + // stmt.execute(); + + SQLStatementParser parser = SQLParserUtils.createSQLStatementParser(sql, "mysql"); + List statementList = parser.parseStatementList(); + + SQLStatement stmt = statementList.get(0); + + StringBuilder out = new StringBuilder(); + SQLASTOutputVisitor visitor = ParameterizedOutputVisitorUtils.createParameterizedOutputVisitor(out, "mysql"); + stmt.accept(visitor); + + Thread.sleep(1000 * 1000); +// dataSource.close(); + } +} From b1ea268f43302505ee055a770dda4e7fff26c905 Mon Sep 17 00:00:00 2001 From: wenshao Date: Sat, 15 Jun 2013 00:55:36 +0800 Subject: [PATCH 5/5] improve filter's config --- .../druid/pool/DruidAbstractDataSource.java | 20 ++++++++--- .../alibaba/druid/pool/DruidDataSource.java | 33 +++++++++++++++++-- .../druid/pool/DruidDataSourceMBean.java | 1 + .../druid/stat/JdbcDataSourceStat.java | 23 ++++++++++++- .../druid/bvt/filter/ClearFilterTest.java | 15 +++++++++ .../pool/TimeBetweenLogStatsMillisTest.java | 11 +++++++ 6 files changed, 96 insertions(+), 7 deletions(-) diff --git a/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java b/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java index 847a54f009..6155f1aebe 100644 --- a/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java +++ b/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java @@ -135,6 +135,7 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements System.out); protected List filters = new CopyOnWriteArrayList(); + private boolean clearFiltersEnable = true; protected volatile ExceptionSorter exceptionSorter = null; protected Driver driver; @@ -254,7 +255,7 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements public DruidDataSourceStatLogger getStatLogger() { return statLogger; } - + public void setStatLoggerClassName(String className) { Class clazz; try { @@ -1164,7 +1165,7 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements } this.addFilters(filters); } - + public void addFilters(String filters) throws SQLException { if (filters == null || filters.length() == 0) { return; @@ -1174,10 +1175,13 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements for (String item : filterArray) { FilterManager.loadFilter(this.filters, item); - } + } } - + public void clearFilters() { + if (!isClearFiltersEnable()) { + return; + } this.filters.clear(); } @@ -1295,6 +1299,14 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements return driver; } + public boolean isClearFiltersEnable() { + return clearFiltersEnable; + } + + public void setClearFiltersEnable(boolean clearFiltersEnable) { + this.clearFiltersEnable = clearFiltersEnable; + } + private final AtomicLong connectionIdSeed = new AtomicLong(10000); private final AtomicLong statementIdSeed = new AtomicLong(20000); private final AtomicLong resultSetIdSeed = new AtomicLong(50000); diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java index 424cb19bd0..d4a278b587 100644 --- a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java +++ b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java @@ -128,6 +128,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat private volatile boolean enable = true; private boolean resetStatEnable = true; + private final AtomicLong resetCount = new AtomicLong(); private String initStackTrace; @@ -214,6 +215,22 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat } } } + { + String property = properties.getProperty("druid.clearFiltersEnable"); + if ("true".equals(property)) { + this.setClearFiltersEnable(true); + } else if ("false".equals(property)) { + this.setClearFiltersEnable(false); + } + } + { + String property = properties.getProperty("druid.resetStatEnable"); + if ("true".equals(property)) { + this.setResetStatEnable(true); + } else if ("false".equals(property)) { + this.setResetStatEnable(false); + } + } } public boolean isUseGloalDataSourceStat() { @@ -234,6 +251,9 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat public void setResetStatEnable(boolean resetStatEnable) { this.resetStatEnable = resetStatEnable; + if (dataSourceStat != null) { + dataSourceStat.setResetStatEnable(resetStatEnable); + } } public long getDiscardCount() { @@ -258,7 +278,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat } public void resetStat() { - if (!resetStatEnable) { + if (!isResetStatEnable()) { return; } @@ -298,6 +318,12 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat transactionHistogram.reset(); cachedPreparedStatementDeleteCount.set(0); recycleErrorCount.set(0); + + resetCount.incrementAndGet(); + } + + public long getResetCount() { + return this.resetCount.get(); } public boolean isEnable() { @@ -558,6 +584,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat } else { dataSourceStat = new JdbcDataSourceStat(this.name, this.jdbcUrl, this.dbType, this.connectProperties); } + dataSourceStat.setResetStatEnable(this.resetStatEnable); connections = new DruidConnectionHolder[maxActive]; @@ -616,6 +643,8 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat String threadName = "Druid-ConnectionPool-Log-" + System.identityHashCode(this); logStatsThread = new LogStatsThread(threadName); logStatsThread.start(); + + this.resetStatEnable = false; } private void createAndStartDestroyThread() { @@ -1032,7 +1061,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat this.discardConnection(holder.getConnection()); holder.setDiscard(true); pooledConnection.disable(t); - + LOG.error("discard connection", sqlEx); } diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java b/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java index b2798cc943..3af9d08463 100644 --- a/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java +++ b/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java @@ -24,6 +24,7 @@ import javax.management.ObjectName; * @author wenshao */ public interface DruidDataSourceMBean extends DruidAbstractDataSourceMBean { + long getResetCount(); boolean isEnable(); diff --git a/src/main/java/com/alibaba/druid/stat/JdbcDataSourceStat.java b/src/main/java/com/alibaba/druid/stat/JdbcDataSourceStat.java index f06d26a535..6acedfe834 100644 --- a/src/main/java/com/alibaba/druid/stat/JdbcDataSourceStat.java +++ b/src/main/java/com/alibaba/druid/stat/JdbcDataSourceStat.java @@ -66,12 +66,17 @@ public class JdbcDataSourceStat implements JdbcDataSourceStatMBean { // }); - private final ConcurrentMap connections = new ConcurrentHashMap(16, 0.75f, 1); + private final ConcurrentMap connections = new ConcurrentHashMap( + 16, + 0.75f, + 1); private final AtomicLong clobOpenCount = new AtomicLong(); private final AtomicLong blobOpenCount = new AtomicLong(); + private boolean resetStatEnable = true; + private static JdbcDataSourceStat global; static { @@ -92,6 +97,18 @@ public class JdbcDataSourceStat implements JdbcDataSourceStatMBean { public static void setGlobal(JdbcDataSourceStat value) { global = value; } + + public void configFromProperties(Properties properties) { + + } + + public boolean isResetStatEnable() { + return resetStatEnable; + } + + public void setResetStatEnable(boolean resetStatEnable) { + this.resetStatEnable = resetStatEnable; + } public JdbcDataSourceStat(String name, String url){ this(name, url, null); @@ -187,6 +204,10 @@ public class JdbcDataSourceStat implements JdbcDataSourceStatMBean { } public void reset() { + if (!isResetStatEnable()) { + return; + } + blobOpenCount.set(0); clobOpenCount.set(0); diff --git a/src/test/java/com/alibaba/druid/bvt/filter/ClearFilterTest.java b/src/test/java/com/alibaba/druid/bvt/filter/ClearFilterTest.java index acfac7d718..a70688a985 100644 --- a/src/test/java/com/alibaba/druid/bvt/filter/ClearFilterTest.java +++ b/src/test/java/com/alibaba/druid/bvt/filter/ClearFilterTest.java @@ -4,6 +4,7 @@ import junit.framework.TestCase; import org.junit.Assert; +import com.alibaba.druid.filter.encoding.EncodingConvertFilter; import com.alibaba.druid.filter.stat.StatFilter; import com.alibaba.druid.pool.DruidDataSource; @@ -17,6 +18,20 @@ public class ClearFilterTest extends TestCase { dataSource.setFilters("!stat"); Assert.assertEquals(1, dataSource.getProxyFilters().size()); Assert.assertEquals(StatFilter.class.getName(), dataSource.getFilterClassNames().get(0)); + dataSource.setClearFiltersEnable(false); + dataSource.setFilters("!encoding"); + Assert.assertEquals(StatFilter.class.getName(), dataSource.getFilterClassNames().get(0)); + Assert.assertEquals(EncodingConvertFilter.class.getName(), dataSource.getFilterClassNames().get(1)); + + dataSource.setConnectionProperties("druid.clearFiltersEnable=false"); + Assert.assertFalse(dataSource.isClearFiltersEnable()); + + dataSource.setConnectionProperties("druid.clearFiltersEnable=true"); + Assert.assertTrue(dataSource.isClearFiltersEnable()); + + dataSource.setConnectionProperties("druid.clearFiltersEnable=xx"); // no change + Assert.assertTrue(dataSource.isClearFiltersEnable()); + dataSource.close(); } } diff --git a/src/test/java/com/alibaba/druid/bvt/pool/TimeBetweenLogStatsMillisTest.java b/src/test/java/com/alibaba/druid/bvt/pool/TimeBetweenLogStatsMillisTest.java index 7179724e94..c3d0e25dbd 100644 --- a/src/test/java/com/alibaba/druid/bvt/pool/TimeBetweenLogStatsMillisTest.java +++ b/src/test/java/com/alibaba/druid/bvt/pool/TimeBetweenLogStatsMillisTest.java @@ -24,7 +24,18 @@ public class TimeBetweenLogStatsMillisTest extends TestCase { } public void test_0() throws Exception { + Assert.assertEquals(true, dataSource.isResetStatEnable()); dataSource.init(); Assert.assertEquals(1000, dataSource.getTimeBetweenLogStatsMillis()); + Assert.assertEquals(false, dataSource.isResetStatEnable()); + dataSource.resetStat(); + Assert.assertEquals(0, dataSource.getResetCount()); + dataSource.setConnectionProperties("druid.resetStatEnable=true"); + Assert.assertEquals(true, dataSource.isResetStatEnable()); + + dataSource.setConnectionProperties("druid.resetStatEnable=false"); + Assert.assertEquals(false, dataSource.isResetStatEnable()); + + dataSource.setConnectionProperties("druid.resetStatEnable=xxx"); } }