Class DataSource

java.lang.Object

org.apache.tomcat.jdbc.pool.DataSourceProxy

org.apache.tomcat.jdbc.pool.DataSource

All Implemented Interfaces:

Wrapper, MBeanRegistration, CommonDataSource, ConnectionPoolDataSource, DataSource, ConnectionPoolMBean, PoolConfiguration

Direct Known Subclasses:

XADataSource

public class DataSource
extends DataSourceProxy
implements DataSource, MBeanRegistration, ConnectionPoolMBean, ConnectionPoolDataSource

A DataSource that can be instantiated through IoC and implements the DataSource interface since the DataSourceProxy is used as a generic proxy. The DataSource simply wraps a ConnectionPool in order to provide a standard interface to the user.

Field Summary

Fields

Modifier and Type	Field	Description
protected ObjectName	oname	The JMX ObjectName for the connection pool MBean.

Fields inherited from class DataSourceProxy

pool, poolProperties

Modifier and Type	Field	Description
protected ConnectionPool	pool	The underlying connection pool.
protected PoolConfiguration	poolProperties	The pool configuration properties.

Fields inherited from interface ConnectionPoolMBean

FAILED_QUERY_NOTIFICATION, NOTIFY_ABANDON, NOTIFY_CONNECT, NOTIFY_INIT, POOL_EMPTY, SLOW_QUERY_NOTIFICATION, SUSPECT_ABANDONED_NOTIFICATION, SUSPECT_RETURNED_NOTIFICATION

Modifier and Type	Field	Description
static final String	FAILED_QUERY_NOTIFICATION	Notification type sent when the SlowQueryReportJmx interceptor reports a query that failed.
static final String	NOTIFY_ABANDON	Notification type sent when a connection that has been checked out longer than the remove-abandoned timeout is abandoned and removed from the pool.
static final String	NOTIFY_CONNECT	Notification type sent when the pool cannot establish a physical connection to the database.
static final String	NOTIFY_INIT	Notification type sent when the initialization of the pool fails, because an interceptor could not be started or because an initial connection of the pool could not be created and the failure is not ignored through ignoreExceptionOnPreLoad.
static final String	POOL_EMPTY	Notification type sent when a borrow from the pool fails because the pool is empty: the borrower was not willing to wait for a connection or its wait timed out.
static final String	SLOW_QUERY_NOTIFICATION	Notification type sent when the SlowQueryReportJmx interceptor reports a query that took longer than its configured threshold.
static final String	SUSPECT_ABANDONED_NOTIFICATION	Notification type sent when the pool marks a connection as suspect because it has been checked out longer than the suspect timeout and is therefore suspected of having been abandoned.
static final String	SUSPECT_RETURNED_NOTIFICATION	Notification type sent when a connection that the pool had marked as suspect is returned to the pool.

Fields inherited from interface PoolConfiguration

PKG_PREFIX

Modifier and Type	Field	Description
static final String	PKG_PREFIX	JMX prefix for interceptors that register themselves with JMX

Constructor Summary

Constructors

Constructor	Description
DataSource()	Constructor for reflection only.
DataSource(PoolConfiguration poolProperties)	Constructs a DataSource object wrapping a connection

Method Summary

Modifier and Type	Method	Description
void	close(boolean all)	Unregisters the connection pool MBean before closing the pool, so a dead pool does not keep reporting stale statistics under a live object name (and does not pin the closed pool, its credentials and its JDBC driver class loader in the MBean server). Close the connection pool.
ObjectName	createObjectName(ObjectName original)	Creates the ObjectName for the ConnectionPoolMBean object to be registered
void	postDeregister()	Unregisters the underlying connection pool mbean.
void	postRegister(Boolean registrationDone)	Releases the pool MBean that preRegister(MBeanServer, ObjectName) published when the MBean server did not complete this DataSource's own registration.
void	preDeregister()	no-op
ObjectName	preRegister(MBeanServer server, ObjectName name)	If the connection pool MBean exists, it will be registered during this operation.
protected void	registerJmx()	Registers the ConnectionPoolMBean under a unique name based on the ObjectName for the DataSource.
protected void	unregisterJmx(ObjectName name)	Unregisters the ConnectionPoolMBean published under the given name.

Methods inherited from class DataSourceProxy

checkAbandoned, checkIdle, close, createPool, getAbandonWhenPercentageFull, getActive, getBorrowedCount, getCommitOnReturn, getConnection, getConnection, getConnectionAsync, getConnectionProperties, getCreatedCount, getDataSource, getDataSourceJNDI, getDbProperties, getDefaultAutoCommit, getDefaultCatalog, getDefaultReadOnly, getDefaultTransactionIsolation, getDriverClassName, getIdle, getInitialSize, getInitSQL, getJdbcInterceptors, getJdbcInterceptorsAsArray, getLoginTimeout, getLogValidationErrors, getLogWriter, getMaxActive, getMaxAge, getMaxIdle, getMaxWait, getMinEvictableIdleTimeMillis, getMinIdle, getName, getNumActive, getNumIdle, getNumTestsPerEvictionRun, getParentLogger, getPassword, getPool, getPooledConnection, getPooledConnection, getPoolName, getPoolProperties, getPoolSize, getPropagateInterruptState, getReconnectedCount, getReleasedCount, getReleasedIdleCount, getRemoveAbandonedCount, getRemoveAbandonedTimeout, getReturnedCount, getRollbackOnReturn, getSize, getSuspectTimeout, getTimeBetweenEvictionRunsMillis, getUrl, getUseDisposableConnectionFacade, getUseLock, getUsername, getUseStatementFacade, getValidationInterval, getValidationQuery, getValidationQueryTimeout, getValidator, getValidatorClassName, getWaitCount, getXAConnection, getXAConnection, isAccessToUnderlyingConnectionAllowed, isAlternateUsernameAllowed, isDefaultAutoCommit, isDefaultReadOnly, isFairQueue, isIgnoreExceptionOnPreLoad, isJmxEnabled, isLogAbandoned, isPoolSweeperEnabled, isRemoveAbandoned, isTestOnBorrow, isTestOnConnect, isTestOnReturn, isTestWhileIdle, isUseEquals, isWrapperFor, purge, purgeOnReturn, resetStats, setAbandonWhenPercentageFull, setAccessToUnderlyingConnectionAllowed, setAlternateUsernameAllowed, setCommitOnReturn, setConnectionProperties, setDataSource, setDataSourceJNDI, setDbProperties, setDefaultAutoCommit, setDefaultCatalog, setDefaultReadOnly, setDefaultTransactionIsolation, setDriverClassName, setFairQueue, setIgnoreExceptionOnPreLoad, setInitialSize, setInitSQL, setJdbcInterceptors, setJmxEnabled, setLogAbandoned, setLoginTimeout, setLogValidationErrors, setLogWriter, setMaxActive, setMaxAge, setMaxIdle, setMaxWait, setMinEvictableIdleTimeMillis, setMinIdle, setName, setNumTestsPerEvictionRun, setPassword, setPoolProperties, setPropagateInterruptState, setRemoveAbandoned, setRemoveAbandonedTimeout, setRollbackOnReturn, setSuspectTimeout, setTestOnBorrow, setTestOnConnect, setTestOnReturn, setTestWhileIdle, setTimeBetweenEvictionRunsMillis, setUrl, setUseDisposableConnectionFacade, setUseEquals, setUseLock, setUsername, setUseStatementFacade, setValidationInterval, setValidationQuery, setValidationQueryTimeout, setValidator, setValidatorClassName, testIdle, toString, unwrap

Modifier and Type	Method	Description
void	checkAbandoned()	Forces an abandon check on the connection pool.
void	checkIdle()	Forces a check for resizing of the idle connections
void	close()	Close the connection pool, returning connections to the database.
ConnectionPool	createPool()	Sets up the connection pool, by creating a pooling driver.
int	getAbandonWhenPercentageFull()	Connections that have been abandoned (timed out) wont get closed and reported up unless the number of connections in use are above the percentage defined by abandonWhenPercentageFull.
int	getActive()	Returns the number of connections currently in use by the application.
long	getBorrowedCount()	The total number of connections borrowed from this pool.
boolean	getCommitOnReturn()	Returns whether the pool commits any pending transaction when a connection is returned.
Connection	getConnection()	Get a database connection.
Connection	getConnection(String username, String password)	Get a database connection.
Future<Connection>	getConnectionAsync()	Invokes an sync operation to retrieve the connection.
String	getConnectionProperties()	The connection properties that will be sent to the JDBC driver when establishing new connections.
long	getCreatedCount()	The total number of connections created by this pool.
Object	getDataSource()	Returns a datasource, if one exists that is being used to create connections.
String	getDataSourceJNDI()	Returns the JNDI string configured for data source usage.
Properties	getDbProperties()	Returns a copy of the database properties with the password removed.
Boolean	getDefaultAutoCommit()	The default auto-commit state of connections created by this pool.
String	getDefaultCatalog()	If non null, during connection creation the method Connection.setCatalog(String) will be called with the set value.
Boolean	getDefaultReadOnly()	If non null, during connection creation the method Connection.setReadOnly(boolean) will be called with the set value.
int	getDefaultTransactionIsolation()	Returns the default transaction isolation level.
String	getDriverClassName()	The fully qualified Java class name of the JDBC driver to be used.
int	getIdle()	If the pool has not been created, it will be created during this call.
int	getInitialSize()	Returns the number of connections that will be established when the connection pool is started.
String	getInitSQL()	A custom query to be run when a connection is first created.
String	getJdbcInterceptors()	A semicolon separated list of classnames extending JdbcInterceptor class.
PoolProperties.InterceptorDefinition[]	getJdbcInterceptorsAsArray()	Returns the PoolConfiguration.getJdbcInterceptors() as an array of objects with properties and the classes.
int	getLoginTimeout()	no-op CommonDataSource.getLoginTimeout()
boolean	getLogValidationErrors()	Returns true if errors that happen during validation will be logged
PrintWriter	getLogWriter()	no-op CommonDataSource.getLogWriter()
int	getMaxActive()	The maximum number of active connections that can be allocated from this pool at the same time.
long	getMaxAge()	Time in milliseconds to keep this connection before reconnecting.
int	getMaxIdle()	The maximum number of connections that should be kept in the idle pool if PoolConfiguration.isPoolSweeperEnabled() returns false.
int	getMaxWait()	The maximum number of milliseconds that the pool will wait (when there are no available connections and the PoolConfiguration.getMaxActive() has been reached) for a connection to be returned before throwing an exception.
int	getMinEvictableIdleTimeMillis()	The minimum amount of time an object must sit idle in the pool before it is eligible for eviction.
int	getMinIdle()	The minimum number of established connections that should be kept in the pool at all times.
String	getName()	Returns the name of the connection pool.
int	getNumActive()	Returns the number of connections currently in use by the application.
int	getNumIdle()	DataSourceProxy.getIdle()
int	getNumTestsPerEvictionRun()	Property not used
Logger	getParentLogger()	no-op CommonDataSource.getParentLogger()
String	getPassword()	Returns the password used when establishing connections to the database.
ConnectionPool	getPool()	Return the underlying connection pool, creating it if necessary.
PooledConnection	getPooledConnection()	Get a database connection.
PooledConnection	getPooledConnection(String username, String password)	Get a database connection.
String	getPoolName()	Returns the name of the connection pool.
PoolConfiguration	getPoolProperties()	Return the pool configuration properties.
int	getPoolSize()	Return the current number of connections in the pool.
boolean	getPropagateInterruptState()	Returns true if the pool is configured to propagate interrupt state of a thread.
long	getReconnectedCount()	The total number of connections reconnected by this pool.
long	getReleasedCount()	The total number of connections released from this pool.
long	getReleasedIdleCount()	The total number of connections released by eviction.
long	getRemoveAbandonedCount()	The total number of connections released by remove abandoned.
int	getRemoveAbandonedTimeout()	The time in seconds before a connection can be considered abandoned.
long	getReturnedCount()	The total number of connections returned to this pool.
boolean	getRollbackOnReturn()	Returns whether the pool rolls back any pending transaction when a connection is returned.
int	getSize()	Returns the current total number of connections in the pool.
int	getSuspectTimeout()	Returns the time in seconds to pass before a connection is marked an abandoned suspect.
int	getTimeBetweenEvictionRunsMillis()	The number of milliseconds to sleep between runs of the idle connection validation, abandoned cleaner and idle pool resizing.
String	getUrl()	The URL used to connect to the database
boolean	getUseDisposableConnectionFacade()	Deprecated. The disposable connection facade is always used, so this property no longer has any effect.
boolean	getUseLock()	Return true if a lock should be used when operations are performed on the connection object.
String	getUsername()	Returns the username used to establish the connection with
boolean	getUseStatementFacade()	Deprecated. The statement facade is always used, so this property no longer has any effect.
long	getValidationInterval()	avoid excess validation, only run validation at most at this frequency - time in milliseconds.
String	getValidationQuery()	The SQL query that will be used to validate connections from this pool before returning them to the caller or pool.
int	getValidationQueryTimeout()	The timeout in seconds before a connection validation queries fail.
Validator	getValidator()	Returns the validator object used for connection validation.
String	getValidatorClassName()	Return the name of the optional validator class - may be null.
int	getWaitCount()	Returns the number of threads currently waiting for a connection from the pool.
XAConnection	getXAConnection()	Get a database connection.
XAConnection	getXAConnection(String username, String password)	Get a database connection.
boolean	isAccessToUnderlyingConnectionAllowed()	Property not used.
boolean	isAlternateUsernameAllowed()	Returns true if the call getConnection(username,password) is allowed.
Boolean	isDefaultAutoCommit()	The default auto-commit state of connections created by this pool.
Boolean	isDefaultReadOnly()	If non null, during connection creation the method Connection.setReadOnly(boolean) will be called with the set value.
boolean	isFairQueue()	Returns true if a fair queue is being used by the connection pool
boolean	isIgnoreExceptionOnPreLoad()	Returns whether exceptions during connection creation at pool initialization should be ignored.
boolean	isJmxEnabled()	If set to true, the connection pool creates a ConnectionPoolMBean object that can be registered with JMX to receive notifications and state about the pool.
boolean	isLogAbandoned()	boolean flag to set if stack traces should be logged for application code which abandoned a Connection.
boolean	isPoolSweeperEnabled()	Returns true if the pool sweeper is enabled for the connection pool.
boolean	isRemoveAbandoned()	boolean flag to remove abandoned connections if they exceed the removeAbandonedTimeout.
boolean	isTestOnBorrow()	The indication of whether objects will be validated before being borrowed from the pool.
boolean	isTestOnConnect()	Returns true if we should run the validation query when connecting to the database for the first time on a connection.
boolean	isTestOnReturn()	The indication of whether objects will be validated after being returned to the pool.
boolean	isTestWhileIdle()	Set to true if query validation should take place while the connection is idle.
boolean	isUseEquals()	Set to true if you wish the ProxyConnection class to use String.equals instead of == when comparing method names.
boolean	isWrapperFor(Class<?> iface)	Check if this proxy implements, or wraps an instance of, the given interface.
void	purge()	Purge all connections from the pool.
void	purgeOnReturn()	Enable purging of connections on return to the pool.
void	resetStats()	reset the statistics of this pool.
void	setAbandonWhenPercentageFull(int percentage)	Connections that have been abandoned (timed out) wont get closed and reported up unless the number of connections in use are above the percentage defined by abandonWhenPercentageFull.
void	setAccessToUnderlyingConnectionAllowed(boolean accessToUnderlyingConnectionAllowed)	No-op
void	setAlternateUsernameAllowed(boolean alternateUsernameAllowed)	Set to true if the call getConnection(username,password) is allowed and honored..
void	setCommitOnReturn(boolean commitOnReturn)	Set to true if you want the connection pool to commit any pending transaction when a connection is returned.
void	setConnectionProperties(String properties)	The properties that will be passed into Driver.connect(String, Properties) method.
void	setDataSource(Object ds)	Injects a datasource that will be used to retrieve/create connections.
void	setDataSourceJNDI(String jndiDS)	Configure the connection pool to use a DataSource according to PoolConfiguration.setDataSource(Object) But instead of injecting the object, specify the JNDI location.
void	setDbProperties(Properties dbProperties)	Overrides the database properties passed into the Driver.connect(String, Properties) method.
void	setDefaultAutoCommit(Boolean autocommit)	The default auto-commit state of connections created by this pool.
void	setDefaultCatalog(String catalog)	If non null, during connection creation the method Connection.setCatalog(String) will be called with the set value.
void	setDefaultReadOnly(Boolean defaultReadOnly)	If non null, during connection creation the method Connection.setReadOnly(boolean) will be called with the set value.
void	setDefaultTransactionIsolation(int defaultTransactionIsolation)	If set to DataSourceFactory.UNKNOWN_TRANSACTIONISOLATION the method Connection.setTransactionIsolation(int) will not be called during connection creation.
void	setDriverClassName(String driverClassName)	The fully qualified Java class name of the JDBC driver to be used.
void	setFairQueue(boolean fairQueue)	Set to true if you wish that calls to getConnection should be treated fairly in a true FIFO fashion.
void	setIgnoreExceptionOnPreLoad(boolean ignoreExceptionOnPreLoad)	Set to true if you want to ignore error of connection creation while initializing the pool.
void	setInitialSize(int initialSize)	Set the number of connections that will be established when the connection pool is started.
void	setInitSQL(String initSQL)	A custom query to be run when a connection is first created.
void	setJdbcInterceptors(String interceptors)	A semicolon separated list of classnames extending JdbcInterceptor class.
void	setJmxEnabled(boolean enabled)	If set to true, the connection pool creates a ConnectionPoolMBean object that can be registered with JMX to receive notifications and state about the pool.
void	setLogAbandoned(boolean logAbandoned)	boolean flag to set if stack traces should be logged for application code which abandoned a Connection.
void	setLoginTimeout(int i)	CommonDataSource.setLoginTimeout(int)
void	setLogValidationErrors(boolean logValidationErrors)	Set to true if you wish that errors from validation should be logged as error messages.
void	setLogWriter(PrintWriter out)	no-op CommonDataSource.setLogWriter(PrintWriter)
void	setMaxActive(int maxActive)	The maximum number of active connections that can be allocated from this pool at the same time.
void	setMaxAge(long maxAge)	Time in milliseconds to keep this connection before reconnecting.
void	setMaxIdle(int maxIdle)	The maximum number of connections that should be kept in the idle pool if PoolConfiguration.isPoolSweeperEnabled() returns false.
void	setMaxWait(int maxWait)	The maximum number of milliseconds that the pool will wait (when there are no available connections and the PoolConfiguration.getMaxActive() has been reached) for a connection to be returned before throwing an exception.
void	setMinEvictableIdleTimeMillis(int minEvictableIdleTimeMillis)	The minimum amount of time an object must sit idle in the pool before it is eligible for eviction.
void	setMinIdle(int minIdle)	The minimum number of established connections that should be kept in the pool at all times.
void	setName(String name)	Sets the name of the connection pool
void	setNumTestsPerEvictionRun(int numTestsPerEvictionRun)	Property not used
void	setPassword(String password)	Sets the password used to establish connections with, and mirrors it into the password database property.
void	setPoolProperties(PoolConfiguration poolProperties)	Set the pool configuration properties directly.
void	setPropagateInterruptState(boolean propagateInterruptState)	Configure the pool to propagate interrupt state for interrupted threads waiting for a connection A thread waiting for a connection, can have its wait interrupted, and by default will clear the interrupt flag and throw a PoolExhaustedException If set to true, this behavior will change, while the PoolExhaustedException is still thrown, the threads interrupted state is still set.
void	setRemoveAbandoned(boolean removeAbandoned)	boolean flag to remove abandoned connections if they exceed the removeAbandonedTimeout.
void	setRemoveAbandonedTimeout(int removeAbandonedTimeout)	The time in seconds before a connection can be considered abandoned.
void	setRollbackOnReturn(boolean rollbackOnReturn)	Set to true if you want the connection pool to rollback any pending transaction when a connection is returned.
void	setSuspectTimeout(int seconds)	Similar to PoolConfiguration.setRemoveAbandonedTimeout(int) but instead of treating the connection as abandoned, and potentially closing the connection, this simply logs the warning if PoolConfiguration.isLogAbandoned() returns true.
void	setTestOnBorrow(boolean testOnBorrow)	The indication of whether objects will be validated before being borrowed from the pool.
void	setTestOnConnect(boolean testOnConnect)	Set to true if we should run the validation query when connecting to the database for the first time on a connection.
void	setTestOnReturn(boolean testOnReturn)	The indication of whether objects will be validated after being returned to the pool.
void	setTestWhileIdle(boolean testWhileIdle)	Set to true if query validation should take place while the connection is idle.
void	setTimeBetweenEvictionRunsMillis(int timeBetweenEvictionRunsMillis)	The number of milliseconds to sleep between runs of the idle connection validation, abandoned cleaner and idle pool resizing.
void	setUrl(String url)	Sets the URL used to connect to the database
void	setUseDisposableConnectionFacade(boolean useDisposableConnectionFacade)	Deprecated. The disposable connection facade is always used, so this property no longer has any effect.
void	setUseEquals(boolean useEquals)	Set to true if you wish the ProxyConnection class to use String.equals instead of == when comparing method names.
void	setUseLock(boolean useLock)	Set to true if a lock should be used when operations are performed on the connection object.
void	setUsername(String username)	Sets the user name used to establish connections with, and mirrors it into the user database property.
void	setUseStatementFacade(boolean useStatementFacade)	Deprecated. The statement facade is always used, so this property no longer has any effect.
void	setValidationInterval(long validationInterval)	avoid excess validation, only run validation at most at this frequency - time in milliseconds.
void	setValidationQuery(String validationQuery)	The SQL query that will be used to validate connections from this pool before returning them to the caller or pool.
void	setValidationQueryTimeout(int validationQueryTimeout)	The timeout in seconds before a connection validation queries fail.
void	setValidator(Validator validator)	Sets the validator object If this is a non null object, it will be used as a validator instead of the validationQuery If this is null, remove the usage of the validator.
void	setValidatorClassName(String className)	Set the name for an optional validator class which will be used in place of test queries.
void	testIdle()	Performs a validation on idle connections.
String	toString()
<T> T	unwrap(Class<T> iface)	Unwrap the proxy to the given interface.

Methods inherited from class Object

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

Methods inherited from interface CommonDataSource

getLoginTimeout, getLogWriter, getParentLogger, setLoginTimeout, setLogWriter

Methods inherited from interface ConnectionPoolDataSource

getPooledConnection, getPooledConnection

Methods inherited from interface ConnectionPoolMBean

checkAbandoned, checkIdle, getActive, getBorrowedCount, getCreatedCount, getIdle, getNumActive, getNumIdle, getReconnectedCount, getReleasedCount, getReleasedIdleCount, getRemoveAbandonedCount, getReturnedCount, getSize, getWaitCount, purge, purgeOnReturn, resetStats, testIdle

Modifier and Type	Method	Description
void	checkAbandoned()	Checks for and removes abandoned connections from the pool.
void	checkIdle()	Checks and cleans up idle connections in the pool.
int	getActive()	Returns the number of active (in-use) connections.
long	getBorrowedCount()	Returns the total number of connections borrowed since pool creation.
long	getCreatedCount()	Returns the total number of connections created since pool creation.
int	getIdle()	Returns the number of idle connections in the pool.
int	getNumActive()	Returns the number of active (in-use) connections.
int	getNumIdle()	Returns the number of idle connections in the pool.
long	getReconnectedCount()	Returns the total number of reconnections since pool creation.
long	getReleasedCount()	Returns the total number of connections released since pool creation.
long	getReleasedIdleCount()	Returns the total number of idle connections released by the pool cleaner.
long	getRemoveAbandonedCount()	Returns the total number of connections removed due to abandonment.
long	getReturnedCount()	Returns the total number of connections returned since pool creation.
int	getSize()	Returns the total number of connections in the pool.
int	getWaitCount()	Returns the number of threads waiting for a connection.
void	purge()	Purges all connections in the pool.
void	purgeOnReturn()	Purges connections when they are returned from the pool.
void	resetStats()	reset the statistics of this pool.
void	testIdle()	Validates all idle connections in the pool.

Methods inherited from interface DataSource

getConnection, getConnection

Methods inherited from interface Wrapper

isWrapperFor, unwrap

Field Details

oname

protected volatile ObjectName oname

The JMX ObjectName for the connection pool MBean. The handle is checked, cleared and released only under this data source's monitor.

Constructor Details

DataSource

public DataSource()

Constructor for reflection only. A default set of pool properties will be created.

DataSource

public DataSource(PoolConfiguration poolProperties)

Constructs a DataSource object wrapping a connection

Parameters:

poolProperties - The pool properties

Method Details

close

public void close(boolean all)

Unregisters the connection pool MBean before closing the pool, so a dead pool does not keep reporting stale statistics under a live object name (and does not pin the closed pool, its credentials and its JDBC driver class loader in the MBean server).
Close the connection pool. If a pool creation is in flight, this method does not wait for it - the driver connects of the creation's initial pre-load can block for an unbounded, uninterruptible time against a hung database - it marks this data source closed and returns: the creation observes the closure at its publication step and closes the pool it built instead of publishing it.

Overrides:

close in class DataSourceProxy

Parameters:

all - if true close all connections, otherwise only idle ones

postDeregister

public void postDeregister()

Unregisters the underlying connection pool mbean.

Specified by:

postDeregister in interface MBeanRegistration

postRegister

public void postRegister(Boolean registrationDone)

Releases the pool MBean that preRegister(MBeanServer, ObjectName) published when the MBean server did not complete this DataSource's own registration. Per the MBeanRegistration contract a false registrationDone means that the registration phase failed, and after a failed registration the server does not call postDeregister(): this callback is the only chance to undo that side effect. Leaving the pool MBean registered would keep a pool nobody manages reporting statistics and notifications, and would pin the pool - with its properties, its credentials and its JDBC driver class loader - in the MBean server.

Specified by:

postRegister in interface MBeanRegistration

preDeregister

public void preDeregister()
                   throws Exception

no-op

Specified by:

preDeregister in interface MBeanRegistration

Throws:

Exception

preRegister

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

If the connection pool MBean exists, it will be registered during this operation.

Specified by:

preRegister in interface MBeanRegistration

Throws:

Exception

createObjectName

public ObjectName createObjectName(ObjectName original)
                            throws MalformedObjectNameException

Creates the ObjectName for the ConnectionPoolMBean object to be registered

Parameters:

original - the ObjectName for the DataSource

Returns:

the ObjectName for the ConnectionPoolMBean

Throws:

MalformedObjectNameException - Invalid object name

registerJmx

protected void registerJmx()

Registers the ConnectionPoolMBean under a unique name based on the ObjectName for the DataSource. A pool that has not been created yet (or was already closed) has no MBean to publish; the registration is then skipped rather than failing, since the caller of preRegister(MBeanServer, ObjectName) must not see an exception over pool-side lifecycle state. A publish the MBean server refused - because the name is already in use by another MBean, for instance - is likewise not this pool's registration.

unregisterJmx

protected void unregisterJmx(ObjectName name)

Unregisters the ConnectionPoolMBean published under the given name. The name is the registration handle captured by the caller, which holds this data source's monitor: the handle is checked, cleared and released as one step there, so it never reaches this method twice and a name this data source never published is never released.

Parameters:

name - the ObjectName the pool MBean was published under, or null to release nothing