hoj-master.zip

// // Source code recreated from a .class file by IntelliJ IDEA // (powered by Fernflower decompiler) // package com.alibaba.druid.pool; import com.alibaba.druid.DruidRuntimeException; 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.JdbcUtils; import com.alibaba.druid.util.MySqlUtils; import com.alibaba.druid.util.StringUtils; import com.alibaba.druid.util.Utils; 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.ScheduledExecutorService; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; import java.util.concurrent.atomic.AtomicLongFieldUpdater; 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; public abstract class DruidAbstractDataSource extends WrapperAdapter implements DruidAbstractDataSourceMBean, DataSource, DataSourceProxy, Serializable { private static final long serialVersionUID = 1L; private static final Log LOG = LogFactory.getLog(DruidAbstractDataSource.class); public static final int DEFAULT_INITIAL_SIZE = 0; public static final int DEFAULT_MAX_ACTIVE_SIZE = 8; public static final int DEFAULT_MAX_IDLE = 8; public static final int DEFAULT_MIN_IDLE = 0; public static final int DEFAULT_MAX_WAIT = -1; public static final String DEFAULT_VALIDATION_QUERY = null; public static final boolean DEFAULT_TEST_ON_BORROW = false; public static final boolean DEFAULT_TEST_ON_RETURN = false; public static final boolean DEFAULT_WHILE_IDLE = true; public static final long DEFAULT_TIME_BETWEEN_EVICTION_RUNS_MILLIS = 60000L; public static final long DEFAULT_TIME_BETWEEN_CONNECT_ERROR_MILLIS = 500L; public static final int DEFAULT_NUM_TESTS_PER_EVICTION_RUN = 3; public static final long DEFAULT_MIN_EVICTABLE_IDLE_TIME_MILLIS = 1800000L; public static final long DEFAULT_MAX_EVICTABLE_IDLE_TIME_MILLIS = 25200000L; public static final long DEFAULT_PHY_TIMEOUT_MILLIS = -1L; 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 = 0; protected volatile int maxActive = 8; protected volatile int minIdle = 0; protected volatile int maxIdle = 8; protected volatile long maxWait = -1L; protected int notFullTimeoutRetryCount = 0; protected volatile String validationQuery; protected volatile int validationQueryTimeout; protected volatile boolean testOnBorrow; protected volatile boolean testOnReturn; protected volatile boolean testWhileIdle; protected volatile boolean poolPreparedStatements; protected volatile boolean sharePreparedStatements; protected volatile int maxPoolPreparedStatementPerConnectionSize; protected volatile boolean inited; protected volatile boolean initExceptionThrow; protected PrintWriter logWriter; protected List<Filter> filters; private boolean clearFiltersEnable; protected volatile ExceptionSorter exceptionSorter; protected Driver driver; protected volatile int queryTimeout; protected volatile int transactionQueryTimeout; protected long createTimespan; protected volatile int maxWaitThreadCount; protected volatile boolean accessToUnderlyingConnectionAllowed; protected volatile long timeBetweenEvictionRunsMillis; protected volatile int numTestsPerEvictionRun; protected volatile long minEvictableIdleTimeMillis; protected volatile long maxEvictableIdleTimeMillis; protected volatile long keepAliveBetweenTimeMillis; protected volatile long phyTimeoutMillis; protected volatile long phyMaxUseCount; protected volatile boolean removeAbandoned; protected volatile long removeAbandonedTimeoutMillis; protected volatile boolean logAbandoned; protected volatile int maxOpenPreparedStatements; protected volatile List<String> connectionInitSqls; protected volatile String dbType; protected volatile long timeBetweenConnectErrorMillis; protected volatile ValidConnectionChecker validConnectionChecker; protected final Map<DruidPooledConnection, Object> activeConnections; protected static final Object PRESENT = new Object(); protected long id; protected int connectionErrorRetryAttempts; protected boolean breakAfterAcquireFailure; protected long transactionThresholdMillis; protected final Date createdTime; protected Date initedTime; protected volatile long errorCount; protected volatile long dupCloseCount; protected volatile long startTransactionCount; protected volatile long commitCount; protected volatile long rollbackCount; protected volatile long cachedPreparedStatementHitCount; protected volatile long preparedStatementCount; protected volatile long closedPreparedStatementCount; protected volatile long cachedPreparedStatementCount; protected volatile long cachedPreparedStatementDeleteCount; protected volatile long cachedPreparedStatementMissCount; static final AtomicLongFieldUpdater<DruidAbstractDataSource> errorCountUpdater = AtomicLongFieldUpdater.newUpdater(DruidAbstractDataSource.class, "errorCount"); static final AtomicLongFieldUpdater<DruidAbstractDataSource> dupCloseCountUpdater = AtomicLongFieldUpdater.newUpdater(DruidAbstractDataSource.class, "dupCloseCount"); static final AtomicLongFieldUpdater<DruidAbstractDataSource> startTransactionCountUpdater = AtomicLongFieldUpdater.newUpdater(DruidAbstractDataSource.class, "startTransactionCount"); static final AtomicLongFieldUpdater<DruidAbstractDataSource> commitCountUpdater = AtomicLongFieldUpdater.newUpdater(DruidAbstractDataSource.class, "commitCount"); static final AtomicLongFieldUpdater<DruidAbstractDataSource> rollbackCountUpdater = AtomicLongFieldUpdater.newUpdater(DruidAbstractDataSource.class, "rollbackCount"); static final AtomicLongFieldUpdater<DruidAbstractDataSource> cachedPreparedStatementHitCountUpdater = AtomicL