c3p0 0.10.1 · com.mchange.v2.c3p0.impl.C3P0PooledConnectionPoolManager

Field Summary

Modifier and Type	Field and Description
pack-priv Map<K, V>	authsToPools
private static final CoalesceChecker	COALESCE_CHECKER
pack-priv static final Coalescer	COALESCER
pack-priv final ConnectionPoolDataSource	cpds
private static final TaskRunnerFactory	DEFAULT_TASK_RUNNER_FACTORY
pack-priv final DbAuth	defaultAuth
pack-priv ThreadPoolReportingAsynchronousRunner	deferredStatementDestroyer
pack-priv static final int	DFLT_NUM_TASK_THREADS_PER_DATA_SOURCE
pack-priv final Map<K, V>	flatPropertyOverrides
private static final MLogger	logger
pack-priv int	num_task_threads
pack-priv final String	parentDataSourceIdentityToken
pack-priv final String	parentDataSourceName
private static final boolean	POOL_EVENT_SUPPORT
pack-priv final Map<K, V>	propNamesToReadMethods
pack-priv ResourcePoolFactory	rpfact
pack-priv ThreadPoolReportingAsynchronousRunner	taskRunner
pack-priv Timer	timer
pack-priv final Map<K, V>	userOverrides

Constructor Summary

Access	Constructor and Description
public	C3P0PooledConnectionPoolManager(ConnectionPoolDataSource cpds, Map<K, V> flatPropertyOverrides, Map<K, V> forceUserOverrides, int num_task_threads, String parentDataSourceIdentityToken, String parentDataSourceName)

Method Summary

Modifier and Type	Method and Description
private boolean	checkAutomaticTestTable(String automaticTestTable)
public void	close()
public synchronized void	close(boolean close_outstanding_connections)
private C3P0PooledConnectionPool	createPooledConnectionPool(DbAuth auth)
private ThreadPoolReportingAsynchronousRunner	createTaskRunner(int num_threads_if_supported, int max_administrative_task_time_if_supported, String contextClassLoaderSourceIfSupported, boolean privilege_spawned_threads_if_supported, String threadLabelIfSupported, ConnectionPoolDataSource cpds, Timer timer)
private void	ensureFirstConnectionAcquisition(DbAuth auth)
protected synchronized void	finalize() Overrides java.lang.Object.finalize. Called by the garbage collector on an object when garbage collection determines that there are no more references to the object.
private int	getAcquireIncrement(String userName)
private int	getAcquireRetryAttempts(String userName)
private int	getAcquireRetryDelay(String userName)
private boolean	getAttemptResurrectOnCheckin(String userName)
public String	getAutomaticTestTable(String userName)
private boolean	getBoolean(String propName, String userName)
private boolean	getBreakAfterAcquireFailure(String userName)
private int	getCheckoutTimeout(String userName)
private ConnectionCustomizer	getConnectionCustomizer(String userName)
private String	getConnectionCustomizerClassName(String userName)
private int	getConnectionIsValidTimeout(String userName)
private ConnectionTester	getConnectionTester(String userName)
private String	getConnectionTesterClassName(String userName)
private String	getContextClassLoaderSource()
private boolean	getDebugUnreturnedConnectionStackTraces(String userName)
private boolean	getForceSynchronousCheckins(String userName)
private int	getIdleConnectionTestPeriod(String userName)
private int	getInitialPoolSize(String userName)
private int	getInt(String propName, String userName)
public synchronized Set<E>	getManagedAuths()
private String	getMarkSessionBoundaries(String userName)
private int	getMaxAdministrativeTaskTime()
private int	getMaxConnectionAge(String userName)
private int	getMaxIdleTime(String userName)
private int	getMaxIdleTimeExcessConnections(String userName)
private int	getMaxPoolSize(String userName)
private int	getMaxStatements(String userName)
private int	getMaxStatementsPerConnection(String userName)
public int	getMinPoolSize(String userName)
public synchronized int	getNumBusyConnectionsAllAuths()
public synchronized int	getNumConnectionsAllAuths()
public synchronized int	getNumIdleConnectionsAllAuths()
public synchronized int	getNumManagedAuths()
public synchronized int	getNumUnclosedOrphanedConnectionsAllAuths()
private Object	getObject(String propName, String userName)
public synchronized C3P0PooledConnectionPool	getPool(String username, String password, boolean create)
public C3P0PooledConnectionPool	getPool(String username, String password)
public synchronized C3P0PooledConnectionPool	getPool(DbAuth auth)
public C3P0PooledConnectionPool	getPool()
public String	getPreferredTestQuery(String userName)
private boolean	getPrivilegeSpawnedThreads()
private int	getPropertyCycle(String userName)
public synchronized int	getStatementCacheNumCheckedOutStatementsAllUsers()
public synchronized int	getStatementCacheNumConnectionsWithCachedStatementsAllUsers()
private int	getStatementCacheNumDeferredCloseThreads()
public synchronized int	getStatementCacheNumStatementsAllUsers()
public int	getStatementDestroyerNumActiveThreads()
public synchronized int	getStatementDestroyerNumConnectionsInUseAllUsers()
public synchronized int	getStatementDestroyerNumConnectionsWithDeferredDestroyStatementsAllUsers()
public synchronized int	getStatementDestroyerNumDeferredDestroyStatementsAllUsers()
public int	getStatementDestroyerNumIdleThreads()
public int	getStatementDestroyerNumTasksPending()
public int	getStatementDestroyerNumThreads()
public String	getStatementDestroyerStackTraces()
public String	getStatementDestroyerStatus()
private String	getString(String propName, String userName)
private TaskRunnerFactory	getTaskRunnerFactory(String userName)
private String	getTaskRunnerFactoryClassName(String userName)
private boolean	getTestConnectionOnCheckin(String userName)
private boolean	getTestConnectionOnCheckout(String userName)
public int	getThreadPoolNumActiveThreads()
public int	getThreadPoolNumIdleThreads()
public int	getThreadPoolNumTasksPending()
public int	getThreadPoolSize()
public String	getThreadPoolStackTraces()
public String	getThreadPoolStatus()
private int	getUnreturnedConnectionTimeout(String userName)
private String	idString()
private String	initializeAutomaticTestTable(String automaticTestTable, DbAuth auth)
private void	poolsDestroy()
private synchronized void	poolsDestroy(boolean close_outstanding_connections)
private void	poolsInit()
public synchronized void	softResetAllAuths()

Inherited from java.lang.Object:: clone equals getClass hashCode notify notifyAll toString wait wait wait

Field Detail

authsToPools	back to summary
pack-priv Map<K, V> authsToPools

COALESCE_CHECKER	back to summary
private static final CoalesceChecker COALESCE_CHECKER

COALESCER	back to summary
pack-priv static final Coalescer COALESCER

cpds	back to summary
pack-priv final ConnectionPoolDataSource cpds

DEFAULT_TASK_RUNNER_FACTORY	back to summary
private static final TaskRunnerFactory DEFAULT_TASK_RUNNER_FACTORY

defaultAuth	back to summary
pack-priv final DbAuth defaultAuth

deferredStatementDestroyer	back to summary
pack-priv ThreadPoolReportingAsynchronousRunner deferredStatementDestroyer

DFLT_NUM_TASK_THREADS_PER_DATA_SOURCE	back to summary
pack-priv static final int DFLT_NUM_TASK_THREADS_PER_DATA_SOURCE

flatPropertyOverrides	back to summary
pack-priv final Map<K, V> flatPropertyOverrides

logger	back to summary
private static final MLogger logger

num_task_threads	back to summary
pack-priv int num_task_threads

parentDataSourceIdentityToken	back to summary
pack-priv final String parentDataSourceIdentityToken

parentDataSourceName	back to summary
pack-priv final String parentDataSourceName

POOL_EVENT_SUPPORT	back to summary
private static final boolean POOL_EVENT_SUPPORT

propNamesToReadMethods	back to summary
pack-priv final Map<K, V> propNamesToReadMethods

rpfact	back to summary
pack-priv ResourcePoolFactory rpfact

taskRunner	back to summary
pack-priv ThreadPoolReportingAsynchronousRunner taskRunner

timer	back to summary
pack-priv Timer timer

userOverrides	back to summary
pack-priv final Map<K, V> userOverrides

Constructor Detail

C3P0PooledConnectionPoolManager	back to summary
public C3P0PooledConnectionPoolManager(ConnectionPoolDataSource cpds, Map<K, V> flatPropertyOverrides, Map<K, V> forceUserOverrides, int num_task_threads, String parentDataSourceIdentityToken, String parentDataSourceName) throws SQLException

Method Detail

checkAutomaticTestTable	back to summary
private boolean checkAutomaticTestTable(String automaticTestTable)

close	back to summary
public void close()

close	back to summary
public synchronized void close(boolean close_outstanding_connections)

createPooledConnectionPool	back to summary
private C3P0PooledConnectionPool createPooledConnectionPool(DbAuth auth) throws SQLException

createTaskRunner	back to summary
private ThreadPoolReportingAsynchronousRunner createTaskRunner(int num_threads_if_supported, int max_administrative_task_time_if_supported, String contextClassLoaderSourceIfSupported, boolean privilege_spawned_threads_if_supported, String threadLabelIfSupported, ConnectionPoolDataSource cpds, Timer timer)

ensureFirstConnectionAcquisition	back to summary
private void ensureFirstConnectionAcquisition(DbAuth auth) throws SQLException

finalize back to summary

finalize	back to summary
protected synchronized void finalize() Overrides java.lang.Object.finalize. Doc from java.lang.Object.finalize. Called by the garbage collector on an object when garbage collection determines that there are no more references to the object. A subclass overrides the `finalize` method to dispose of system resources or to perform other cleanup. When running in a Java virtual machine in which finalization has been disabled or removed, the garbage collector will never call `finalize()`. In a Java virtual machine in which finalization is enabled, the garbage collector might call `finalize` only after an indefinite delay. The general contract of `finalize` is that it is invoked if and when the Java virtual machine has determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, except as a result of an action taken by the finalization of some other object or class which is ready to be finalized. The `finalize` method may take any action, including making this object available again to other threads; the usual purpose of `finalize`, however, is to perform cleanup actions before the object is irrevocably discarded. For example, the finalize method for an object that represents an input/output connection might perform explicit I/O transactions to break the connection before the object is permanently discarded. The `finalize` method of class `Object` performs no special action; it simply returns normally. Subclasses of `Object` may override this definition. The Java programming language does not guarantee which thread will invoke the `finalize` method for any given object. It is guaranteed, however, that the thread that invokes finalize will not be holding any user-visible synchronization locks when finalize is invoked. If an uncaught exception is thrown by the finalize method, the exception is ignored and finalization of that object terminates. After the `finalize` method has been invoked for an object, no further action is taken until the Java virtual machine has again determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, including possible actions by other objects or classes which are ready to be finalized, at which point the object may be discarded. The `finalize` method is never invoked more than once by a Java virtual machine for any given object. Any exception thrown by the `finalize` method causes the finalization of this object to be halted, but is otherwise ignored.

protected synchronized void finalize()

Overrides java.lang.Object.finalize.

Doc from java.lang.Object.finalize.

Called by the garbage collector on an object when garbage collection determines that there are no more references to the object. A subclass overrides the finalize method to dispose of system resources or to perform other cleanup.

When running in a Java virtual machine in which finalization has been disabled or removed, the garbage collector will never call finalize(). In a Java virtual machine in which finalization is enabled, the garbage collector might call finalize only after an indefinite delay.

The general contract of finalize is that it is invoked if and when the Java virtual machine has determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, except as a result of an action taken by the finalization of some other object or class which is ready to be finalized. The finalize method may take any action, including making this object available again to other threads; the usual purpose of finalize, however, is to perform cleanup actions before the object is irrevocably discarded. For example, the finalize method for an object that represents an input/output connection might perform explicit I/O transactions to break the connection before the object is permanently discarded.

The finalize method of class Object performs no special action; it simply returns normally. Subclasses of Object may override this definition.

The Java programming language does not guarantee which thread will invoke the finalize method for any given object. It is guaranteed, however, that the thread that invokes finalize will not be holding any user-visible synchronization locks when finalize is invoked. If an uncaught exception is thrown by the finalize method, the exception is ignored and finalization of that object terminates.

After the finalize method has been invoked for an object, no further action is taken until the Java virtual machine has again determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, including possible actions by other objects or classes which are ready to be finalized, at which point the object may be discarded.

The finalize method is never invoked more than once by a Java virtual machine for any given object.

Any exception thrown by the finalize method causes the finalization of this object to be halted, but is otherwise ignored.

getAcquireIncrement	back to summary
private int getAcquireIncrement(String userName)

getAcquireRetryAttempts	back to summary
private int getAcquireRetryAttempts(String userName)

getAcquireRetryDelay	back to summary
private int getAcquireRetryDelay(String userName)

getAttemptResurrectOnCheckin	back to summary
private boolean getAttemptResurrectOnCheckin(String userName)

getAutomaticTestTable	back to summary
public String getAutomaticTestTable(String userName)

getBoolean	back to summary
private boolean getBoolean(String propName, String userName) throws Exception

getBreakAfterAcquireFailure	back to summary
private boolean getBreakAfterAcquireFailure(String userName)

getCheckoutTimeout	back to summary
private int getCheckoutTimeout(String userName)

getConnectionCustomizer	back to summary
private ConnectionCustomizer getConnectionCustomizer(String userName) throws SQLException

getConnectionCustomizerClassName	back to summary
private String getConnectionCustomizerClassName(String userName)

getConnectionIsValidTimeout	back to summary
private int getConnectionIsValidTimeout(String userName)

getConnectionTester	back to summary
private ConnectionTester getConnectionTester(String userName)

getConnectionTesterClassName	back to summary
private String getConnectionTesterClassName(String userName)

getContextClassLoaderSource	back to summary
private String getContextClassLoaderSource()

getDebugUnreturnedConnectionStackTraces	back to summary
private boolean getDebugUnreturnedConnectionStackTraces(String userName)

getForceSynchronousCheckins	back to summary
private boolean getForceSynchronousCheckins(String userName)

getIdleConnectionTestPeriod	back to summary
private int getIdleConnectionTestPeriod(String userName)

getInitialPoolSize	back to summary
private int getInitialPoolSize(String userName)

getInt	back to summary
private int getInt(String propName, String userName) throws Exception

getManagedAuths	back to summary
public synchronized Set<E> getManagedAuths()

getMarkSessionBoundaries	back to summary
private String getMarkSessionBoundaries(String userName)

getMaxAdministrativeTaskTime	back to summary
private int getMaxAdministrativeTaskTime()

getMaxConnectionAge	back to summary
private int getMaxConnectionAge(String userName)

getMaxIdleTime	back to summary
private int getMaxIdleTime(String userName)

getMaxIdleTimeExcessConnections	back to summary
private int getMaxIdleTimeExcessConnections(String userName)

getMaxPoolSize	back to summary
private int getMaxPoolSize(String userName)

getMaxStatements	back to summary
private int getMaxStatements(String userName)

getMaxStatementsPerConnection	back to summary
private int getMaxStatementsPerConnection(String userName)

getMinPoolSize	back to summary
public int getMinPoolSize(String userName)

getNumBusyConnectionsAllAuths	back to summary
public synchronized int getNumBusyConnectionsAllAuths() throws SQLException

getNumConnectionsAllAuths	back to summary
public synchronized int getNumConnectionsAllAuths() throws SQLException

getNumIdleConnectionsAllAuths	back to summary
public synchronized int getNumIdleConnectionsAllAuths() throws SQLException

getNumManagedAuths	back to summary
public synchronized int getNumManagedAuths()

getNumUnclosedOrphanedConnectionsAllAuths	back to summary
public synchronized int getNumUnclosedOrphanedConnectionsAllAuths() throws SQLException

getObject	back to summary
private Object getObject(String propName, String userName)

getPool	back to summary
public synchronized C3P0PooledConnectionPool getPool(String username, String password, boolean create) throws SQLException

getPool	back to summary
public C3P0PooledConnectionPool getPool(String username, String password) throws SQLException

getPool	back to summary
public synchronized C3P0PooledConnectionPool getPool(DbAuth auth) throws SQLException

getPool	back to summary
public C3P0PooledConnectionPool getPool() throws SQLException

getPreferredTestQuery	back to summary
public String getPreferredTestQuery(String userName)

getPrivilegeSpawnedThreads	back to summary
private boolean getPrivilegeSpawnedThreads()

getPropertyCycle	back to summary
private int getPropertyCycle(String userName)

getStatementCacheNumCheckedOutStatementsAllUsers	back to summary
public synchronized int getStatementCacheNumCheckedOutStatementsAllUsers() throws SQLException

getStatementCacheNumConnectionsWithCachedStatementsAllUsers	back to summary
public synchronized int getStatementCacheNumConnectionsWithCachedStatementsAllUsers() throws SQLException

getStatementCacheNumDeferredCloseThreads	back to summary
private int getStatementCacheNumDeferredCloseThreads()

getStatementCacheNumStatementsAllUsers	back to summary
public synchronized int getStatementCacheNumStatementsAllUsers() throws SQLException

getStatementDestroyerNumActiveThreads	back to summary
public int getStatementDestroyerNumActiveThreads()

getStatementDestroyerNumConnectionsInUseAllUsers	back to summary
public synchronized int getStatementDestroyerNumConnectionsInUseAllUsers() throws SQLException

getStatementDestroyerNumConnectionsWithDeferredDestroyStatementsAllUsers	back to summary
public synchronized int getStatementDestroyerNumConnectionsWithDeferredDestroyStatementsAllUsers() throws SQLException

getStatementDestroyerNumDeferredDestroyStatementsAllUsers	back to summary
public synchronized int getStatementDestroyerNumDeferredDestroyStatementsAllUsers() throws SQLException

getStatementDestroyerNumIdleThreads	back to summary
public int getStatementDestroyerNumIdleThreads()

getStatementDestroyerNumTasksPending	back to summary
public int getStatementDestroyerNumTasksPending()

getStatementDestroyerNumThreads	back to summary
public int getStatementDestroyerNumThreads()

getStatementDestroyerStackTraces	back to summary
public String getStatementDestroyerStackTraces()

getStatementDestroyerStatus	back to summary
public String getStatementDestroyerStatus()

getString	back to summary
private String getString(String propName, String userName)

getTaskRunnerFactory	back to summary
private TaskRunnerFactory getTaskRunnerFactory(String userName)

getTaskRunnerFactoryClassName	back to summary
private String getTaskRunnerFactoryClassName(String userName)

getTestConnectionOnCheckin	back to summary
private boolean getTestConnectionOnCheckin(String userName)

getTestConnectionOnCheckout	back to summary
private boolean getTestConnectionOnCheckout(String userName)

getThreadPoolNumActiveThreads	back to summary
public int getThreadPoolNumActiveThreads()

getThreadPoolNumIdleThreads	back to summary
public int getThreadPoolNumIdleThreads()

getThreadPoolNumTasksPending	back to summary
public int getThreadPoolNumTasksPending()

getThreadPoolSize	back to summary
public int getThreadPoolSize()

getThreadPoolStackTraces	back to summary
public String getThreadPoolStackTraces()

getThreadPoolStatus	back to summary
public String getThreadPoolStatus()

getUnreturnedConnectionTimeout	back to summary
private int getUnreturnedConnectionTimeout(String userName)

idString	back to summary
private String idString()

initializeAutomaticTestTable	back to summary
private String initializeAutomaticTestTable(String automaticTestTable, DbAuth auth) throws SQLException

poolsDestroy	back to summary
private void poolsDestroy()

poolsDestroy	back to summary
private synchronized void poolsDestroy(boolean close_outstanding_connections)

poolsInit	back to summary
private void poolsInit()