程序包 com.alibaba.druid.pool

类 DruidDataSource

java.lang.Object

com.alibaba.druid.pool.WrapperAdapter

com.alibaba.druid.pool.DruidAbstractDataSource

com.alibaba.druid.pool.DruidDataSource

所有已实现的接口:

DruidAbstractDataSourceMBean, DruidDataSourceMBean, ManagedDataSource, DataSourceProxy, DataSourceMonitorable, Closeable, Serializable, AutoCloseable, Cloneable, Wrapper, MBeanRegistration, Referenceable, CommonDataSource, ConnectionPoolDataSource, DataSource

直接已知子类:

DruidQuartzConnectionProvider, DruidXADataSource

public class DruidDataSource
extends DruidAbstractDataSource
implements DruidDataSourceMBean, ManagedDataSource, Referenceable, Closeable, Cloneable, ConnectionPoolDataSource, MBeanRegistration

作者:

ljw [ljw2083@alibaba-inc.com], wenshao [szujobs@hotmail.com]

另请参阅:

• 序列化表格

嵌套类概要

嵌套类

修饰符和类型	类	说明
class	DruidDataSource.CreateConnectionTask
class	DruidDataSource.CreateConnectionThread
class	DruidDataSource.DestroyConnectionThread
class	DruidDataSource.DestroyTask
class	DruidDataSource.LogStatsThread

从类继承的嵌套类/接口 com.alibaba.druid.pool.DruidAbstractDataSource

DruidAbstractDataSource.PhysicalConnectionInfo

字段概要

字段

修饰符和类型	字段	说明
protected boolean	checkExecuteTime
protected static final AtomicLongFieldUpdater<DruidDataSource>	connectErrorCountUpdater
protected static final AtomicIntegerFieldUpdater<DruidDataSource>	createDirectCountUpdater
protected static final AtomicLongFieldUpdater<DruidDataSource>	createTaskIdSeedUpdater
protected JdbcDataSourceStat	dataSourceStat
protected static final AtomicLongFieldUpdater<DruidDataSource>	discardErrorCountUpdater
protected String	instanceKey	Instance key
protected static final AtomicIntegerFieldUpdater<DruidDataSource>	keepAliveCheckErrorCountUpdater
protected boolean	killWhenSocketReadTimeout
protected static final AtomicLongFieldUpdater<DruidDataSource>	recycleErrorCountUpdater
protected static final AtomicLongFieldUpdater<DruidDataSource>	resetCountUpdater

从类继承的字段 com.alibaba.druid.pool.DruidAbstractDataSource

accessToUnderlyingConnectionAllowed, activeConnectionLock, activeConnections, asyncCloseConnectionEnable, breakAfterAcquireFailure, cachedPreparedStatementCount, cachedPreparedStatementDeleteCount, cachedPreparedStatementHitCount, cachedPreparedStatementMissCount, closedPreparedStatementCount, commitCount, connectionErrorRetryAttempts, connectionIdSeed, connectionInitSqls, connectProperties, connectTimeout, createCount, createdTime, createError, createErrorCount, createScheduler, createStartNanos, createTimespan, creatingCount, dbTypeName, DEFAULT_INITIAL_SIZE, DEFAULT_MAX_ACTIVE_SIZE, DEFAULT_MAX_EVICTABLE_IDLE_TIME_MILLIS, DEFAULT_MAX_IDLE, DEFAULT_MAX_WAIT, DEFAULT_MIN_EVICTABLE_IDLE_TIME_MILLIS, DEFAULT_MIN_IDLE, DEFAULT_NUM_TESTS_PER_EVICTION_RUN, DEFAULT_PHY_TIMEOUT_MILLIS, DEFAULT_TEST_ON_BORROW, DEFAULT_TEST_ON_RETURN, DEFAULT_TIME_BETWEEN_CONNECT_ERROR_MILLIS, DEFAULT_TIME_BETWEEN_EVICTION_RUNS_MILLIS, DEFAULT_TIME_CONNECT_TIMEOUT_MILLIS, DEFAULT_TIME_SOCKET_TIMEOUT_MILLIS, DEFAULT_VALIDATION_QUERY, DEFAULT_WHILE_IDLE, defaultAutoCommit, defaultCatalog, defaultReadOnly, defaultTransactionIsolation, destroyCount, destroyScheduler, directCreateCount, driver, driverClass, driverClassLoader, dupCloseCount, empty, errorCount, exceptionSorter, executeBatchCount, executeCount, executeQueryCount, executeUpdateCount, failContinuous, failContinuousTimeMillis, failFast, fatalErrorCount, fatalErrorCountLastShrink, filterChainUpdater, filters, id, inited, initedTime, initExceptionThrow, initGlobalVariants, initialSize, initVariants, isMySql, isOracle, jdbcUrl, keepAliveBetweenTimeMillis, keepAliveError, lastCreateError, lastCreateErrorTimeMillis, lastCreateStartTimeMillis, lastError, lastErrorTimeMillis, lastFatalError, lastFatalErrorSql, lastFatalErrorTimeMillis, lock, logAbandoned, logWriter, maxActive, maxCreateTaskCount, maxEvictableIdleTimeMillis, maxIdle, maxOpenPreparedStatements, maxPoolPreparedStatementPerConnectionSize, maxWait, maxWaitThreadCount, metaDataIdSeed, minEvictableIdleTimeMillis, minIdle, name, netTimeoutError, netTimeoutExecutor, notEmpty, notFullTimeoutRetryCount, numTestsPerEvictionRun, onFatalError, onFatalErrorMaxActive, password, passwordCallback, phyMaxUseCount, phyTimeoutMillis, poolPreparedStatements, preparedStatementCount, PRESENT, queryTimeout, removeAbandoned, removeAbandonedTimeoutMillis, resultSetIdSeed, rollbackCount, sharePreparedStatements, socketTimeout, startTransactionCount, statementIdSeed, statLogger, testOnBorrow, testOnReturn, testWhileIdle, timeBetweenConnectErrorMillis, timeBetweenEvictionRunsMillis, timeBetweenLogStatsMillis, transactionHistogram, transactionIdSeed, transactionQueryTimeout, transactionThresholdMillis, useOracleImplicitCache, usePingMethod, userCallback, username, validationQuery, validationQueryTimeout, validConnectionChecker

构造器概要

构造器

构造器	说明
DruidDataSource()
DruidDataSource(boolean fairLock)

方法概要

修饰符和类型	方法	说明
void	clearStatementCache()
Object	clone()
DruidDataSource	cloneDruidDataSource()
void	close()	close datasource
void	configFromPropeties(Properties properties)
void	configFromPropety(Properties properties)	已过时。
protected void	createAndStartCreatorThread()
protected void	createAndStartDestroyThread()
boolean	discardConnection(DruidConnectionHolder holder)
boolean	discardConnection(Connection conn)	已过时。
String	dump()
int	fill()
int	fill(int toCount)
void	forEach(Connection conn)
int	getActiveCount()
int	getActivePeak()
Date	getActivePeakTime()
long	getCloseCount()
long	getConnectCount()
long	getConnectErrorCount()
DruidPooledConnection	getConnection()
DruidPooledConnection	getConnection(long maxWaitMillis)
Connection	getConnection(String username, String password)
DruidPooledConnection	getConnectionDirect(long maxWaitMillis)
long	getCreateCount()
JdbcDataSourceStat	getDataSourceStat()
long	getDestroyCount()
long	getDiscardCount()
long	getErrorCount()
List<String>	getFilterClassNames()
String	getInitStackTrace()
Lock	getLock()
int	getLockQueueLength()
long	getNotEmptySignalCount()
long	getNotEmptyWaitCount()
long	getNotEmptyWaitMillis()
long	getNotEmptyWaitNanos()
int	getNotEmptyWaitThreadCount()
int	getNotEmptyWaitThreadPeak()
PooledConnection	getPooledConnection()
PooledConnection	getPooledConnection(String user, String password)
List<Map<String,Object>>	getPoolingConnectionInfo()
int	getPoolingCount()
int	getPoolingPeak()
Date	getPoolingPeakTime()
String	getProperties()
int	getRawDriverMajorVersion()
int	getRawDriverMinorVersion()
long	getRecycleCount()
long	getRecycleErrorCount()
Reference	getReference()
long	getRemoveAbandonedCount()
long	getResetCount()
JdbcSqlStat	getSqlStat(int sqlId)
JdbcSqlStat	getSqlStat(long sqlId)
Map<String,JdbcSqlStat>	getSqlStatMap()
Map<String,Object>	getStatData()
Map<String,Object>	getStatDataForMBean()
DruidDataSourceStatValue	getStatValueAndReset()
String	getVersion()
int	getWaitThreadCount()
Map<String,Object>	getWallStatMap()
WallProviderStatValue	getWallStatValue(boolean reset)
void	handleConnectionException(DruidPooledConnection pooledConnection, Throwable t, String sql)
protected final void	handleFatalError(DruidPooledConnection conn, SQLException error, String sql)
void	init()
protected void	initCheck()
boolean	isAsyncInit()
boolean	isCheckExecuteTime()
boolean	isClosed()
boolean	isEnable()
boolean	isFull()
boolean	isKeepAlive()
boolean	isKillWhenSocketReadTimeout()
boolean	isLogDifferentThread()
boolean	isMbeanRegistered()
boolean	isResetStatEnable()
boolean	isUseGlobalDataSourceStat()
boolean	isWrapperFor(Class<?> iface)
void	logStats()
void	logTransaction(TransactionInfo info)
void	postDeregister()
void	postRegister(Boolean registrationDone)
void	preDeregister()
ObjectName	preRegister(MBeanServer server, ObjectName name)
protected boolean	put(DruidAbstractDataSource.PhysicalConnectionInfo physicalConnectionInfo)
protected void	recycle(DruidPooledConnection pooledConnection)	回收连接
void	registerMbean()
int	removeAbandoned()
void	resetStat()
protected void	resolveDriver()
void	restart()
void	restart(Properties properties)
void	setAsyncInit(boolean asyncInit)
void	setCheckExecuteTime(boolean checkExecuteTime)
void	setConnectProperties(Properties properties)
void	setEnable(boolean enable)
void	setKeepAlive(boolean keepAlive)
void	setKillWhenSocketReadTimeout(boolean killWhenSocketTimeOut)
void	setLogDifferentThread(boolean logDifferentThread)
void	setMaxActive(int maxActive)
void	setPoolPreparedStatements(boolean value)
void	setResetStatEnable(boolean resetStatEnable)
void	setUseGlobalDataSourceStat(boolean useGlobalDataSourceStat)
void	shrink()
void	shrink(boolean checkTime)
void	shrink(boolean checkTime, boolean keepAlive)
String	toString()
DruidPooledConnection	tryGetConnection()
void	unregisterMbean()
<T> T	unwrap(Class<T> iface)

从类继承的方法 com.alibaba.druid.pool.DruidAbstractDataSource

addConnectionProperty, addFilters, clearFilters, cloneTo, closePreapredStatement, createChain, createConnectionId, createMetaDataId, createPhysicalConnection, createPhysicalConnection, createResultSetId, createStatementId, createTransactionId, decrementCachedPreparedStatementCount, fillStatDataToMap, getActiveConnections, getActiveConnectionStackTrace, getAndResetExecuteCount, getCachedPreparedStatementAccessCount, getCachedPreparedStatementCount, getCachedPreparedStatementDeleteCount, getCachedPreparedStatementHitCount, getCachedPreparedStatementMissCount, getClosedPreparedStatementCount, getCommitCount, getCompositeData, getConnectionErrorRetryAttempts, getConnectionInitSqls, getConnectProperties, getConnectTimeout, getCreatedTime, getCreateErrorCount, getCreateScheduler, getCreateTimespanMillis, getCreateTimespanNano, getDataSourceId, getDbType, getDefaultCatalog, getDefaultReadOnly, getDefaultTransactionIsolation, getDestroyScheduler, getDriver, getDriverClassLoader, getDriverClassName, getDriverMajorVersion, getDriverMinorVersion, getDupCloseCount, getExceptionSorter, getExceptionSorterClassName, getExecuteBatchCount, getExecuteCount, getExecuteCount2, getExecuteQueryCount, getExecuteUpdateCount, getFilterClasses, getID, getInitialSize, getKeepAliveBetweenTimeMillis, getLastCreateError, getLastCreateErrorTime, getLastCreateErrorTimeMillis, getLastError, getLastErrorTime, getLastErrorTimeMillis, getLoginTimeout, getLogWriter, getMaxActive, getMaxCreateTaskCount, getMaxEvictableIdleTimeMillis, getMaxIdle, getMaxOpenPreparedStatements, getMaxPoolPreparedStatementPerConnectionSize, getMaxWait, getMaxWaitThreadCount, getMinEvictableIdleTimeMillis, getMinIdle, getName, getNotFullTimeoutRetryCount, getNumTestsPerEvictionRun, getObjectName, getOnFatalErrorMaxActive, getParentLogger, getPassword, getPasswordCallback, getPhyMaxUseCount, getPhyTimeoutMillis, getPreparedStatementCount, getProxyFilters, getQueryTimeout, getRawDriver, getRawJdbcUrl, getRemoveAbandonedTimeout, getRemoveAbandonedTimeoutMillis, getRollbackCount, getSocketTimeout, getStartTransactionCount, getStatLogger, getTimeBetweenConnectErrorMillis, getTimeBetweenEvictionRunsMillis, getTimeBetweenLogStatsMillis, getTransactionHistogram, getTransactionHistogramRanges, getTransactionHistogramValues, getTransactionQueryTimeout, getTransactionThresholdMillis, getUrl, getUserCallback, getUsername, getValidationQuery, getValidationQueryTimeout, getValidConnectionChecker, getValidConnectionCheckerClassName, handleConnectionException, incrementCachedPreparedStatementCount, incrementCachedPreparedStatementDeleteCount, incrementCachedPreparedStatementHitCount, incrementCachedPreparedStatementMissCount, incrementClosedPreparedStatementCount, incrementCommitCount, incrementDupCloseCount, incrementExecuteBatchCount, incrementExecuteCount, incrementExecuteQueryCount, incrementExecuteUpdateCount, incrementPreparedStatementCount, incrementRollbackCount, incrementStartTransactionCount, initPhysicalConnection, initPhysicalConnection, isAccessToUnderlyingConnectionAllowed, isAsyncCloseConnectionEnable, isBreakAfterAcquireFailure, isClearFiltersEnable, isDefaultAutoCommit, isDupCloseLogEnable, isFailContinuous, isFailFast, isInited, isInitExceptionThrow, isInitGlobalVariants, isInitVariants, isKeepConnectionUnderlyingTransactionIsolation, isLogAbandoned, isOnFatalError, isOracle, isPoolPreparedStatements, isRemoveAbandoned, isSharePreparedStatements, isTestOnBorrow, isTestOnReturn, isTestWhileIdle, isUseLocalSessionState, isUseOracleImplicitCache, isUsePingMethod, isUseUnfairLock, recycleFilterChain, setAccessToUnderlyingConnectionAllowed, setAsyncCloseConnectionEnable, setBreakAfterAcquireFailure, setClearFiltersEnable, setConnectionErrorRetryAttempts, setConnectionInitSqls, setConnectionProperties, setConnectTimeout, setConnectTimeout, setCreateError, setCreateScheduler, setDbType, setDbType, setDefaultAutoCommit, setDefaultCatalog, setDefaultReadOnly, setDefaultTransactionIsolation, setDestroyScheduler, setDriver, setDriverClassLoader, setDriverClassName, setDupCloseLogEnable, setExceptionSorter, setExceptionSorter, setExceptionSorterClassName, setFailContinuous, setFailFast, setFilters, setInitExceptionThrow, setInitGlobalVariants, setInitialSize, setInitVariants, setKeepAliveBetweenTimeMillis, setKeepConnectionUnderlyingTransactionIsolation, setLogAbandoned, setLoginTimeout, setLogWriter, setMaxCreateTaskCount, setMaxEvictableIdleTimeMillis, setMaxIdle, setMaxOpenPreparedStatements, setMaxPoolPreparedStatementPerConnectionSize, setMaxWait, setMaxWaitThreadCount, setMinEvictableIdleTimeMillis, setMinIdle, setName, setNotFullTimeoutRetryCount, setNumTestsPerEvictionRun, setObjectName, setOnFatalErrorMaxActive, setOracle, setPassword, setPasswordCallback, setPasswordCallbackClassName, setPhyMaxUseCount, setPhyTimeoutMillis, setProxyFilters, setQueryTimeout, setRemoveAbandoned, setRemoveAbandonedTimeout, setRemoveAbandonedTimeoutMillis, setSharePreparedStatements, setSocketTimeout, setSocketTimeout, setStatLogger, setStatLoggerClassName, setTestOnBorrow, setTestOnReturn, setTestWhileIdle, setTimeBetweenConnectErrorMillis, setTimeBetweenEvictionRunsMillis, setTimeBetweenLogStatsMillis, setTransactionQueryTimeout, setTransactionThresholdMillis, setUrl, setUseLocalSessionState, setUseOracleImplicitCache, setUsePingMethod, setUserCallback, setUsername, setUseUnfairLock, setValidationQuery, setValidationQueryTimeout, setValidConnectionChecker, setValidConnectionCheckerClassName, testConnectionInternal, testConnectionInternal, validateConnection

从类继承的方法 java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

从接口继承的方法 javax.sql.CommonDataSource

createShardingKeyBuilder, getParentLogger

从接口继承的方法 javax.sql.ConnectionPoolDataSource

createPooledConnectionBuilder, getLoginTimeout, getLogWriter, setLoginTimeout, setLogWriter

从接口继承的方法 javax.sql.DataSource

createConnectionBuilder, getLoginTimeout, getLogWriter, setLoginTimeout, setLogWriter

从接口继承的方法 com.alibaba.druid.pool.DruidAbstractDataSourceMBean

getActiveConnectionStackTrace, getCachedPreparedStatementAccessCount, getCachedPreparedStatementCount, getCachedPreparedStatementDeleteCount, getCachedPreparedStatementHitCount, getCachedPreparedStatementMissCount, getClosedPreparedStatementCount, getCommitCount, getConnectionErrorRetryAttempts, getCreatedTime, getCreateErrorCount, getCreateTimespanMillis, getDbType, getDefaultCatalog, getDefaultReadOnly, getDefaultTransactionIsolation, getDriverClassName, getDriverMajorVersion, getDriverMinorVersion, getDupCloseCount, getExceptionSorterClassName, getInitialSize, getLoginTimeout, getMaxActive, getMaxIdle, getMaxOpenPreparedStatements, getMaxPoolPreparedStatementPerConnectionSize, getMaxWait, getMaxWaitThreadCount, getMinEvictableIdleTimeMillis, getMinIdle, getName, getPreparedStatementCount, getQueryTimeout, getRemoveAbandonedTimeoutMillis, getRollbackCount, getStartTransactionCount, getTimeBetweenConnectErrorMillis, getTimeBetweenEvictionRunsMillis, getTransactionHistogramValues, getTransactionQueryTimeout, getTransactionThresholdMillis, getUsername, getValidationQuery, getValidationQueryTimeout, getValidConnectionCheckerClassName, isBreakAfterAcquireFailure, isDefaultAutoCommit, isLogAbandoned, isPoolPreparedStatements, isRemoveAbandoned, isSharePreparedStatements, isTestOnBorrow, isTestOnReturn, isTestWhileIdle, isUseOracleImplicitCache, setLogAbandoned, setMaxPoolPreparedStatementPerConnectionSize, setTestOnBorrow, setTestWhileIdle, setTransactionThresholdMillis, setUseOracleImplicitCache

从接口继承的方法 com.alibaba.druid.pool.DruidDataSourceMBean

getObjectName, getTimeBetweenLogStatsMillis, getUrl, setConnectionProperties, setStatLoggerClassName, setTimeBetweenLogStatsMillis

从接口继承的方法 com.alibaba.druid.pool.ManagedDataSource

getObjectName, setObjectName

字段详细资料

dataSourceStat

protected JdbcDataSourceStat dataSourceStat

killWhenSocketReadTimeout

protected boolean killWhenSocketReadTimeout

checkExecuteTime

protected boolean checkExecuteTime

recycleErrorCountUpdater

protected static final AtomicLongFieldUpdater<DruidDataSource> recycleErrorCountUpdater

connectErrorCountUpdater

protected static final AtomicLongFieldUpdater<DruidDataSource> connectErrorCountUpdater

resetCountUpdater

protected static final AtomicLongFieldUpdater<DruidDataSource> resetCountUpdater

createTaskIdSeedUpdater

protected static final AtomicLongFieldUpdater<DruidDataSource> createTaskIdSeedUpdater

discardErrorCountUpdater

protected static final AtomicLongFieldUpdater<DruidDataSource> discardErrorCountUpdater

keepAliveCheckErrorCountUpdater

protected static final AtomicIntegerFieldUpdater<DruidDataSource> keepAliveCheckErrorCountUpdater

createDirectCountUpdater

protected static final AtomicIntegerFieldUpdater<DruidDataSource> createDirectCountUpdater

instanceKey

protected String instanceKey

Instance key

构造器详细资料

DruidDataSource

public DruidDataSource()

DruidDataSource

public DruidDataSource(boolean fairLock)

方法详细资料

isAsyncInit

public boolean isAsyncInit()

setAsyncInit

public void setAsyncInit(boolean asyncInit)

configFromPropety

@Deprecated
public void configFromPropety(Properties properties)

已过时。

configFromPropeties

public void configFromPropeties(Properties properties)

isKillWhenSocketReadTimeout

public boolean isKillWhenSocketReadTimeout()

setKillWhenSocketReadTimeout

public void setKillWhenSocketReadTimeout(boolean killWhenSocketTimeOut)

isUseGlobalDataSourceStat

public boolean isUseGlobalDataSourceStat()

指定者:

isUseGlobalDataSourceStat 在接口中 DruidDataSourceMBean

setUseGlobalDataSourceStat

public void setUseGlobalDataSourceStat(boolean useGlobalDataSourceStat)

isKeepAlive

public boolean isKeepAlive()

setKeepAlive

public void setKeepAlive(boolean keepAlive)

getInitStackTrace

public String getInitStackTrace()

指定者:

getInitStackTrace 在接口中 DataSourceMonitorable

isResetStatEnable

public boolean isResetStatEnable()

指定者:

isResetStatEnable 在接口中 DruidDataSourceMBean

setResetStatEnable

public void setResetStatEnable(boolean resetStatEnable)

指定者:

setResetStatEnable 在接口中 DruidDataSourceMBean

getDiscardCount

public long getDiscardCount()

指定者:

getDiscardCount 在接口中 DruidDataSourceMBean

restart

public void restart()
             throws SQLException

抛出:

SQLException

restart

public void restart(Properties properties)
             throws SQLException

抛出:

SQLException

resetStat

public void resetStat()

指定者:

resetStat 在接口中 DataSourceMonitorable

指定者:

resetStat 在接口中 DruidDataSourceMBean

getResetCount

public long getResetCount()

指定者:

getResetCount 在接口中 DruidDataSourceMBean

isEnable

public boolean isEnable()

指定者:

isEnable 在接口中 DruidDataSourceMBean

指定者:

isEnable 在接口中 ManagedDataSource

setEnable

public void setEnable(boolean enable)

指定者:

setEnable 在接口中 ManagedDataSource

setPoolPreparedStatements

public void setPoolPreparedStatements(boolean value)

指定者:

setPoolPreparedStatements 在接口中 DruidDataSourceMBean

指定者:

setPoolPreparedStatements 在类中 DruidAbstractDataSource

setMaxActive

public void setMaxActive(int maxActive)

指定者:

setMaxActive 在接口中 DruidAbstractDataSourceMBean

指定者:

setMaxActive 在类中 DruidAbstractDataSource

setConnectProperties

public void setConnectProperties(Properties properties)

指定者:

setConnectProperties 在类中 DruidAbstractDataSource

init

public void init()
          throws SQLException

抛出:

SQLException

createAndStartDestroyThread

protected void createAndStartDestroyThread()

createAndStartCreatorThread

protected void createAndStartCreatorThread()

resolveDriver

protected void resolveDriver()
                      throws SQLException

抛出:

SQLException

initCheck

protected void initCheck()
                  throws SQLException

抛出:

SQLException

getConnection

public DruidPooledConnection getConnection()
                                    throws SQLException

指定者:

getConnection 在接口中 DataSource

抛出:

SQLException

getConnection

public DruidPooledConnection getConnection(long maxWaitMillis)
                                    throws SQLException

抛出:

SQLException

getPooledConnection

public PooledConnection getPooledConnection()
                                     throws SQLException

指定者:

getPooledConnection 在接口中 ConnectionPoolDataSource

抛出:

SQLException

getPooledConnection

public PooledConnection getPooledConnection(String user,
 String password)
                                     throws SQLException

指定者:

getPooledConnection 在接口中 ConnectionPoolDataSource

抛出:

SQLException

getConnectionDirect

public DruidPooledConnection getConnectionDirect(long maxWaitMillis)
                                          throws SQLException

抛出:

SQLException

discardConnection

public boolean discardConnection(Connection conn)

已过时。

抛弃连接，不进行回收，而是抛弃

指定者:

discardConnection 在类中 DruidAbstractDataSource

参数:

conn - the connection to be discarded

返回:

a boolean indicating whether the empty signal was called

discardConnection

public boolean discardConnection(DruidConnectionHolder holder)

覆盖:

discardConnection 在类中 DruidAbstractDataSource

handleConnectionException

public void handleConnectionException(DruidPooledConnection pooledConnection,
 Throwable t,
 String sql)
                               throws SQLException

指定者:

handleConnectionException 在类中 DruidAbstractDataSource

抛出:

SQLException

handleFatalError

protected final void handleFatalError(DruidPooledConnection conn,
 SQLException error,
 String sql)
                               throws SQLException

抛出:

SQLException

recycle

protected void recycle(DruidPooledConnection pooledConnection)
                throws SQLException

回收连接

指定者:

recycle 在类中 DruidAbstractDataSource

抛出:

SQLException

getRecycleErrorCount

public long getRecycleErrorCount()

clearStatementCache

public void clearStatementCache()
                         throws SQLException

指定者:

clearStatementCache 在接口中 DruidDataSourceMBean

抛出:

SQLException

close

public void close()

close datasource

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 Closeable

registerMbean

public void registerMbean()

unregisterMbean

public void unregisterMbean()

isMbeanRegistered

public boolean isMbeanRegistered()

getConnection

public Connection getConnection(String username,
 String password)
                         throws SQLException

指定者:

getConnection 在接口中 DataSource

抛出:

SQLException

getCreateCount

public long getCreateCount()

指定者:

getCreateCount 在接口中 DruidAbstractDataSourceMBean

getDestroyCount

public long getDestroyCount()

指定者:

getDestroyCount 在接口中 DruidAbstractDataSourceMBean

getConnectCount

public long getConnectCount()

指定者:

getConnectCount 在接口中 DruidAbstractDataSourceMBean

getCloseCount

public long getCloseCount()

指定者:

getCloseCount 在接口中 DruidAbstractDataSourceMBean

getConnectErrorCount

public long getConnectErrorCount()

指定者:

getConnectErrorCount 在接口中 DruidAbstractDataSourceMBean

getPoolingCount

public int getPoolingCount()

指定者:

getPoolingCount 在接口中 DruidAbstractDataSourceMBean

getPoolingPeak

public int getPoolingPeak()

指定者:

getPoolingPeak 在接口中 DruidDataSourceMBean

getPoolingPeakTime

public Date getPoolingPeakTime()

指定者:

getPoolingPeakTime 在接口中 DruidDataSourceMBean

getRecycleCount

public long getRecycleCount()

指定者:

getRecycleCount 在接口中 DruidAbstractDataSourceMBean

getActiveCount

public int getActiveCount()

指定者:

getActiveCount 在接口中 DruidAbstractDataSourceMBean

logStats

public void logStats()

getStatValueAndReset

public DruidDataSourceStatValue getStatValueAndReset()

getRemoveAbandonedCount

public long getRemoveAbandonedCount()

指定者:

getRemoveAbandonedCount 在接口中 DruidAbstractDataSourceMBean

put

protected boolean put(DruidAbstractDataSource.PhysicalConnectionInfo physicalConnectionInfo)

removeAbandoned

public int removeAbandoned()

指定者:

removeAbandoned 在接口中 DruidDataSourceMBean

getReference

public Reference getReference()
                       throws NamingException

指定者:

getReference 在接口中 Referenceable

抛出:

NamingException

getFilterClassNames

public List<String> getFilterClassNames()

指定者:

getFilterClassNames 在接口中 DruidAbstractDataSourceMBean

getRawDriverMajorVersion

public int getRawDriverMajorVersion()

指定者:

getRawDriverMajorVersion 在接口中 DruidAbstractDataSourceMBean

指定者:

getRawDriverMajorVersion 在类中 DruidAbstractDataSource

getRawDriverMinorVersion

public int getRawDriverMinorVersion()

指定者:

getRawDriverMinorVersion 在接口中 DruidAbstractDataSourceMBean

指定者:

getRawDriverMinorVersion 在类中 DruidAbstractDataSource

getProperties

public String getProperties()

指定者:

getProperties 在接口中 DruidAbstractDataSourceMBean

指定者:

getProperties 在类中 DruidAbstractDataSource

shrink

public void shrink()

指定者:

shrink 在接口中 DruidDataSourceMBean

shrink

public void shrink(boolean checkTime)

shrink

public void shrink(boolean checkTime,
 boolean keepAlive)

getWaitThreadCount

public int getWaitThreadCount()

指定者:

getWaitThreadCount 在接口中 DruidDataSourceMBean

getNotEmptyWaitCount

public long getNotEmptyWaitCount()

指定者:

getNotEmptyWaitCount 在接口中 DruidDataSourceMBean

getNotEmptyWaitThreadCount

public int getNotEmptyWaitThreadCount()

指定者:

getNotEmptyWaitThreadCount 在接口中 DruidDataSourceMBean

getNotEmptyWaitThreadPeak

public int getNotEmptyWaitThreadPeak()

getNotEmptySignalCount

public long getNotEmptySignalCount()

指定者:

getNotEmptySignalCount 在接口中 DruidDataSourceMBean

getNotEmptyWaitMillis

public long getNotEmptyWaitMillis()

指定者:

getNotEmptyWaitMillis 在接口中 DruidDataSourceMBean

getNotEmptyWaitNanos

public long getNotEmptyWaitNanos()

指定者:

getNotEmptyWaitNanos 在接口中 DruidDataSourceMBean

getLockQueueLength

public int getLockQueueLength()

指定者:

getLockQueueLength 在接口中 DruidDataSourceMBean

getActivePeak

public int getActivePeak()

指定者:

getActivePeak 在接口中 DruidDataSourceMBean

指定者:

getActivePeak 在类中 DruidAbstractDataSource

getActivePeakTime

public Date getActivePeakTime()

指定者:

getActivePeakTime 在接口中 DruidDataSourceMBean

dump

public String dump()

指定者:

dump 在接口中 DruidDataSourceMBean

getErrorCount

public long getErrorCount()

指定者:

getErrorCount 在接口中 DruidDataSourceMBean

toString

public String toString()

覆盖:

toString 在类中 Object

getPoolingConnectionInfo

public List<Map<String,Object>> getPoolingConnectionInfo()

指定者:

getPoolingConnectionInfo 在接口中 DataSourceMonitorable

logTransaction

public void logTransaction(TransactionInfo info)

指定者:

logTransaction 在类中 DruidAbstractDataSource

getVersion

public String getVersion()

指定者:

getVersion 在接口中 DruidDataSourceMBean

getDataSourceStat

public JdbcDataSourceStat getDataSourceStat()

指定者:

getDataSourceStat 在接口中 DataSourceProxy

clone

public Object clone()

覆盖:

clone 在类中 Object

cloneDruidDataSource

public DruidDataSource cloneDruidDataSource()

getStatDataForMBean

public Map<String,Object> getStatDataForMBean()

getStatData

public Map<String,Object> getStatData()

getSqlStat

public JdbcSqlStat getSqlStat(int sqlId)

getSqlStat

public JdbcSqlStat getSqlStat(long sqlId)

getSqlStatMap

public Map<String,JdbcSqlStat> getSqlStatMap()

getWallStatMap

public Map<String,Object> getWallStatMap()

getWallStatValue

public WallProviderStatValue getWallStatValue(boolean reset)

getLock

public Lock getLock()

isWrapperFor

public boolean isWrapperFor(Class<?> iface)

指定者:

isWrapperFor 在接口中 Wrapper

覆盖:

isWrapperFor 在类中 WrapperAdapter

unwrap

public <T> T unwrap(Class<T> iface)

指定者:

unwrap 在接口中 Wrapper

覆盖:

unwrap 在类中 WrapperAdapter

isLogDifferentThread

public boolean isLogDifferentThread()

setLogDifferentThread

public void setLogDifferentThread(boolean logDifferentThread)

tryGetConnection

public DruidPooledConnection tryGetConnection()
                                       throws SQLException

抛出:

SQLException

fill

public int fill()
         throws SQLException

指定者:

fill 在接口中 DruidDataSourceMBean

抛出:

SQLException

fill

public int fill(int toCount)
         throws SQLException

指定者:

fill 在接口中 DruidDataSourceMBean

抛出:

SQLException

isFull

public boolean isFull()

preRegister

public ObjectName preRegister(MBeanServer server,
 ObjectName name)
                       throws Exception

指定者:

preRegister 在接口中 MBeanRegistration

抛出:

Exception

postRegister

public void postRegister(Boolean registrationDone)

指定者:

postRegister 在接口中 MBeanRegistration

preDeregister

public void preDeregister()
                   throws Exception

指定者:

preDeregister 在接口中 MBeanRegistration

抛出:

Exception

postDeregister

public void postDeregister()

指定者:

postDeregister 在接口中 MBeanRegistration

isClosed

public boolean isClosed()

isCheckExecuteTime

public boolean isCheckExecuteTime()

setCheckExecuteTime

public void setCheckExecuteTime(boolean checkExecuteTime)

forEach

public void forEach(Connection conn)