Class BasicDataSource
- java.lang.Object
-
- org.apache.commons.dbcp2.BasicDataSource
-
- All Implemented Interfaces:
- AutoCloseable, Wrapper, MBeanRegistration, CommonDataSource, DataSource, BasicDataSourceMXBean
- Direct Known Subclasses:
- BasicManagedDataSource
public class BasicDataSource extends Object implements DataSource, BasicDataSourceMXBean, MBeanRegistration, AutoCloseable
Basic implementation of
javax.sql.DataSource
that is configured via JavaBeans properties. This is not the only way to combine the commons-dbcp2 and commons-pool2 packages, but provides a "one stop shopping" solution for basic requirements.- Since:
- 2.0
-
-
Constructor Summary
Constructors Constructor and Description BasicDataSource()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method and Description void
addConnectionProperty(String name, String value)
Adds a custom connection property to the set that will be passed to our JDBC driver.void
close()
Closes and releases all idle connections that are currently stored in the connection pool associated with this data source.protected ConnectionFactory
createConnectionFactory()
Creates a JDBC connection factory for this datasource.protected void
createConnectionPool(PoolableConnectionFactory factory)
Creates a connection pool for this datasource.protected DataSource
createDataSource()
Creates (if necessary) and return the internal data source we are using to manage our connections.protected DataSource
createDataSourceInstance()
Creates the actual data source instance.protected GenericObjectPool<PoolableConnection>
createObjectPool(PoolableConnectionFactory factory, GenericObjectPoolConfig poolConfig, AbandonedConfig abandonedConfig)
Creates an object pool used to provide pooling support forJDBC connections
.protected PoolableConnectionFactory
createPoolableConnectionFactory(ConnectionFactory driverConnectionFactory)
Creates the PoolableConnectionFactory and attaches it to the connection pool.PrintWriter
getAbandonedLogWriter()
Gets the print writer used by this configuration to log information on abandoned objects.boolean
getAbandonedUsageTracking()
If the connection pool implementsUsageTracking
, should the connection pool record a stack trace every time a method is called on a pooled connection and retain the most recent stack trace to aid debugging of abandoned connections?boolean
getCacheState()
Returns the state caching flag.Connection
getConnection()
Creates (if necessary) and return a connection to the database.Connection
getConnection(String user, String pass)
BasicDataSource does NOT support this method.List<String>
getConnectionInitSqls()
Returns the list of SQL statements executed when a physical connection is first created.String[]
getConnectionInitSqlsAsArray()
Provides the same data asgetConnectionInitSqls()
but in an array so it is accessible via JMX.protected GenericObjectPool<PoolableConnection>
getConnectionPool()
Boolean
getDefaultAutoCommit()
Returns the default auto-commit property.String
getDefaultCatalog()
Returns the default catalog.Integer
getDefaultQueryTimeout()
Gets the default query timeout that will be used forStatement
s created from this connection.Boolean
getDefaultReadOnly()
Returns the default readOnly property.int
getDefaultTransactionIsolation()
Returns the default transaction isolation state of returned connections.Set<String>
getDisconnectionSqlCodes()
Returns the set of SQL_STATE codes considered to signal fatal conditions.String[]
getDisconnectionSqlCodesAsArray()
Provides the same data asgetDisconnectionSqlCodes()
but in an array so it is accessible via JMX.Driver
getDriver()
Returns the JDBC Driver that has been configured for use by this pool.ClassLoader
getDriverClassLoader()
Returns the class loader specified for loading the JDBC driver.String
getDriverClassName()
Returns the JDBC driver class name.boolean
getEnableAutoCommitOnReturn()
Returns the value of the flag that controls whether or not connections being returned to the pool will be checked and configured withConnection.setAutoCommit(true)
if the auto commit setting isfalse
when the connection is returned.String
getEvictionPolicyClassName()
Gets the EvictionPolicy implementation in use with this connection pool.boolean
getFastFailValidation()
True means that validation will fail immediately for connections that have previously thrown SQLExceptions with SQL_STATE indicating fatal disconnection errors.int
getInitialSize()
Returns the initial size of the connection pool.String
getJmxName()
Returns the JMX name that has been requested for this DataSource.boolean
getLifo()
Returns the LIFO property.boolean
getLogAbandoned()
Flag to log stack traces for application code which abandoned a Statement or Connection.boolean
getLogExpiredConnections()
WhengetMaxConnLifetimeMillis()
is set to limit connection lifetime, this property determines whether or not log messages are generated when the pool closes connections due to maximum lifetime exceeded.int
getLoginTimeout()
BasicDataSource does NOT support this method.PrintWriter
getLogWriter()
Returns the log writer being used by this data source.long
getMaxConnLifetimeMillis()
Returns the maximum permitted lifetime of a connection in milliseconds.int
getMaxIdle()
Returns the maximum number of connections that can remain idle in the pool.int
getMaxOpenPreparedStatements()
Gets the value of themaxOpenPreparedStatements
property.int
getMaxTotal()
Returns the maximum number of active connections that can be allocated at the same time.long
getMaxWaitMillis()
Returns the maximum number of milliseconds that the pool will wait for a connection to be returned before throwing an exception.long
getMinEvictableIdleTimeMillis()
Returns theminEvictableIdleTimeMillis
property.int
getMinIdle()
Returns the minimum number of idle connections in the pool.int
getNumActive()
[Read Only] The current number of active connections that have been allocated from this data source.int
getNumIdle()
[Read Only] The current number of idle connections that are waiting to be allocated from this data source.int
getNumTestsPerEvictionRun()
Returns the value of thenumTestsPerEvictionRun
property.Logger
getParentLogger()
String
getPassword()
Returns the password passed to the JDBC driver to establish connections.protected ObjectName
getRegisteredJmxName()
boolean
getRemoveAbandonedOnBorrow()
Flag to remove abandoned connections if they exceed the removeAbandonedTimeout when borrowObject is invoked.boolean
getRemoveAbandonedOnMaintenance()
Flag to remove abandoned connections if they exceed the removeAbandonedTimeout during pool maintenance.int
getRemoveAbandonedTimeout()
Timeout in seconds before an abandoned connection can be removed.boolean
getRollbackOnReturn()
Gets the current value of the flag that controls whether a connection will be rolled back when it is returned to the pool if auto commit is not enabled and the connection is not read only.long
getSoftMinEvictableIdleTimeMillis()
Returns the minimum amount of time a connection may sit idle in the pool before it is eligible for eviction by the idle object evictor, with the extra condition that at least "minIdle" connections remain in the pool.boolean
getTestOnBorrow()
Returns thetestOnBorrow
property.boolean
getTestOnCreate()
Returns thetestOnCreate
property.boolean
getTestOnReturn()
Returns the value of thetestOnReturn
property.boolean
getTestWhileIdle()
Returns the value of thetestWhileIdle
property.long
getTimeBetweenEvictionRunsMillis()
Returns the value of thetimeBetweenEvictionRunsMillis
property.String
getUrl()
Returns the JDBC connectionurl
property.String
getUsername()
Returns the JDBC connectionuserName
property.String
getValidationQuery()
Returns the validation query used to validate connections before returning them.int
getValidationQueryTimeout()
Returns the validation query timeout.void
invalidateConnection(Connection connection)
Manually invalidates a connection, effectively requesting the pool to try to close it, remove it from the pool and reclaim pool capacity.boolean
isAccessToUnderlyingConnectionAllowed()
Returns the value of the accessToUnderlyingConnectionAllowed property.boolean
isClosed()
If true, this data source is closed and no more connections can be retrieved from this datasource.boolean
isPoolPreparedStatements()
Returns true if we are pooling statements.boolean
isWrapperFor(Class<?> iface)
protected void
log(String message)
void
postDeregister()
void
postRegister(Boolean registrationDone)
void
preDeregister()
ObjectName
preRegister(MBeanServer server, ObjectName objectName)
void
removeConnectionProperty(String name)
Removes a custom connection property.void
setAbandonedLogWriter(PrintWriter logWriter)
Sets the print writer to be used by this configuration to log information on abandoned objects.void
setAbandonedUsageTracking(boolean usageTracking)
If the connection pool implementsUsageTracking
, configure whether the connection pool should record a stack trace every time a method is called on a pooled connection and retain the most recent stack trace to aid debugging of abandoned connections.void
setAccessToUnderlyingConnectionAllowed(boolean allow)
Sets the value of the accessToUnderlyingConnectionAllowed property.void
setCacheState(boolean cacheState)
Sets the state caching flag.void
setConnectionInitSqls(Collection<String> connectionInitSqls)
Sets the list of SQL statements to be executed when a physical connection is first created.void
setConnectionProperties(String connectionProperties)
Sets the connection properties passed to driver.connect(...).void
setDefaultAutoCommit(Boolean defaultAutoCommit)
Sets default auto-commit state of connections returned by this datasource.void
setDefaultCatalog(String defaultCatalog)
Sets the default catalog.void
setDefaultQueryTimeout(Integer defaultQueryTimeoutSeconds)
Sets the default query timeout that will be used forStatement
s created from this connection.void
setDefaultReadOnly(Boolean defaultReadOnly)
Sets defaultReadonly property.void
setDefaultTransactionIsolation(int defaultTransactionIsolation)
Sets the default transaction isolation state for returned connections.void
setDisconnectionSqlCodes(Collection<String> disconnectionSqlCodes)
Sets the SQL_STATE codes considered to signal fatal conditions.void
setDriver(Driver driver)
Sets the JDBC Driver instance to use for this pool.void
setDriverClassLoader(ClassLoader driverClassLoader)
Sets the class loader to be used to load the JDBC driver.void
setDriverClassName(String driverClassName)
Sets the JDBC driver class name.void
setEnableAutoCommitOnReturn(boolean enableAutoCommitOnReturn)
Sets the value of the flag that controls whether or not connections being returned to the pool will be checked and configured withConnection.setAutoCommit(true)
if the auto commit setting isfalse
when the connection is returned.void
setEvictionPolicyClassName(String evictionPolicyClassName)
Sets the EvictionPolicy implementation to use with this connection pool.void
setFastFailValidation(boolean fastFailValidation)
void
setInitialSize(int initialSize)
Sets the initial size of the connection pool.void
setJmxName(String jmxName)
Sets the JMX name that has been requested for this DataSource.void
setLifo(boolean lifo)
Sets the LIFO property.void
setLogAbandoned(boolean logAbandoned)
void
setLogExpiredConnections(boolean logExpiredConnections)
WhengetMaxConnLifetimeMillis()
is set to limit connection lifetime, this property determines whether or not log messages are generated when the pool closes connections due to maximum lifetime exceeded.void
setLoginTimeout(int loginTimeout)
BasicDataSource does NOT support this method.void
setLogWriter(PrintWriter logWriter)
Sets the log writer being used by this data source.void
setMaxConnLifetimeMillis(long maxConnLifetimeMillis)
Sets the maximum permitted lifetime of a connection in milliseconds.void
setMaxIdle(int maxIdle)
Sets the maximum number of connections that can remain idle in the pool.void
setMaxOpenPreparedStatements(int maxOpenStatements)
Sets the value of themaxOpenPreparedStatements
property.void
setMaxTotal(int maxTotal)
Sets the maximum total number of idle and borrows connections that can be active at the same time.void
setMaxWaitMillis(long maxWaitMillis)
Sets the MaxWaitMillis property.void
setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis)
Sets theminEvictableIdleTimeMillis
property.void
setMinIdle(int minIdle)
Sets the minimum number of idle connections in the pool.void
setNumTestsPerEvictionRun(int numTestsPerEvictionRun)
Sets the value of thenumTestsPerEvictionRun
property.void
setPassword(String password)
Sets thepassword
.void
setPoolPreparedStatements(boolean poolingStatements)
Sets whether to pool statements or not.void
setRemoveAbandonedOnBorrow(boolean removeAbandonedOnBorrow)
void
setRemoveAbandonedOnMaintenance(boolean removeAbandonedOnMaintenance)
void
setRemoveAbandonedTimeout(int removeAbandonedTimeout)
Sets the timeout in seconds before an abandoned connection can be removed.void
setRollbackOnReturn(boolean rollbackOnReturn)
Sets the flag that controls if a connection will be rolled back when it is returned to the pool if auto commit is not enabled and the connection is not read only.void
setSoftMinEvictableIdleTimeMillis(long softMinEvictableIdleTimeMillis)
Sets the minimum amount of time a connection may sit idle in the pool before it is eligible for eviction by the idle object evictor, with the extra condition that at least "minIdle" connections remain in the pool.void
setTestOnBorrow(boolean testOnBorrow)
Sets thetestOnBorrow
property.void
setTestOnCreate(boolean testOnCreate)
Sets thetestOnCreate
property.void
setTestOnReturn(boolean testOnReturn)
Sets thetestOnReturn
property.void
setTestWhileIdle(boolean testWhileIdle)
Sets thetestWhileIdle
property.void
setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis)
Sets thetimeBetweenEvictionRunsMillis
property.void
setUrl(String url)
Sets theurl
.void
setUsername(String userName)
Sets theuserName
.void
setValidationQuery(String validationQuery)
Sets thevalidationQuery
.void
setValidationQueryTimeout(int validationQueryTimeoutSeconds)
Sets the validation query timeout, the amount of time, in seconds, that connection validation will wait for a response from the database when executing a validation query.protected void
startPoolMaintenance()
Starts the connection pool maintenance task, if configured.<T> T
unwrap(Class<T> iface)
protected static void
validateConnectionFactory(PoolableConnectionFactory connectionFactory)
-
-
-
Constructor Detail
-
BasicDataSource
public BasicDataSource()
-
-
Method Detail
-
getDefaultAutoCommit
public Boolean getDefaultAutoCommit()
Returns the default auto-commit property.- Specified by:
getDefaultAutoCommit
in interfaceBasicDataSourceMXBean
- Returns:
- true if default auto-commit is enabled
-
setDefaultAutoCommit
public void setDefaultAutoCommit(Boolean defaultAutoCommit)
Sets default auto-commit state of connections returned by this datasource.
Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
defaultAutoCommit
- default auto-commit value
-
getDefaultReadOnly
public Boolean getDefaultReadOnly()
Returns the default readOnly property.- Specified by:
getDefaultReadOnly
in interfaceBasicDataSourceMXBean
- Returns:
- true if connections are readOnly by default
-
setDefaultReadOnly
public void setDefaultReadOnly(Boolean defaultReadOnly)
Sets defaultReadonly property.
Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
defaultReadOnly
- default read-only value
-
getDefaultTransactionIsolation
public int getDefaultTransactionIsolation()
Returns the default transaction isolation state of returned connections.- Specified by:
getDefaultTransactionIsolation
in interfaceBasicDataSourceMXBean
- Returns:
- the default value for transaction isolation state
- See Also:
Connection.getTransactionIsolation()
-
setDefaultTransactionIsolation
public void setDefaultTransactionIsolation(int defaultTransactionIsolation)
Sets the default transaction isolation state for returned connections.
Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
defaultTransactionIsolation
- the default transaction isolation state- See Also:
Connection.getTransactionIsolation()
-
getDefaultQueryTimeout
public Integer getDefaultQueryTimeout()
Gets the default query timeout that will be used forStatement
s created from this connection.null
means that the driver default will be used.- Returns:
- The default query timeout in seconds.
-
setDefaultQueryTimeout
public void setDefaultQueryTimeout(Integer defaultQueryTimeoutSeconds)
Sets the default query timeout that will be used forStatement
s created from this connection.null
means that the driver default will be used.- Parameters:
defaultQueryTimeoutSeconds
- The default query timeout in seconds.
-
getDefaultCatalog
public String getDefaultCatalog()
Returns the default catalog.- Specified by:
getDefaultCatalog
in interfaceBasicDataSourceMXBean
- Returns:
- the default catalog
-
setDefaultCatalog
public void setDefaultCatalog(String defaultCatalog)
Sets the default catalog.
Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
defaultCatalog
- the default catalog
-
getCacheState
public boolean getCacheState()
Returns the state caching flag.- Specified by:
getCacheState
in interfaceBasicDataSourceMXBean
- Returns:
- the state caching flag
-
setCacheState
public void setCacheState(boolean cacheState)
Sets the state caching flag.- Parameters:
cacheState
- The new value for the state caching flag
-
getDriver
public Driver getDriver()
Returns the JDBC Driver that has been configured for use by this pool.Note: This getter only returns the last value set by a call to
setDriver(Driver)
. It does not return any driver instance that may have been created from the value set viasetDriverClassName(String)
.- Returns:
- the JDBC Driver that has been configured for use by this pool
-
setDriver
public void setDriver(Driver driver)
Sets the JDBC Driver instance to use for this pool.Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
driver
- The JDBC Driver instance to use for this pool.
-
getDriverClassName
public String getDriverClassName()
Returns the JDBC driver class name.Note: This getter only returns the last value set by a call to
setDriverClassName(String)
. It does not return the class name of any driver that may have been set viasetDriver(Driver)
.- Specified by:
getDriverClassName
in interfaceBasicDataSourceMXBean
- Returns:
- the JDBC driver class name
-
setDriverClassName
public void setDriverClassName(String driverClassName)
Sets the JDBC driver class name.
Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
driverClassName
- the class name of the JDBC driver
-
getDriverClassLoader
public ClassLoader getDriverClassLoader()
Returns the class loader specified for loading the JDBC driver. Returnsnull
if no class loader has been explicitly specified.Note: This getter only returns the last value set by a call to
setDriverClassLoader(ClassLoader)
. It does not return the class loader of any driver that may have been set viasetDriver(Driver)
.- Returns:
- The class loader specified for loading the JDBC driver.
-
setDriverClassLoader
public void setDriverClassLoader(ClassLoader driverClassLoader)
Sets the class loader to be used to load the JDBC driver.
Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
driverClassLoader
- the class loader with which to load the JDBC driver
-
getLifo
public boolean getLifo()
Returns the LIFO property.- Specified by:
getLifo
in interfaceBasicDataSourceMXBean
- Returns:
- true if connection pool behaves as a LIFO queue.
-
setLifo
public void setLifo(boolean lifo)
Sets the LIFO property. True means the pool behaves as a LIFO queue; false means FIFO.- Parameters:
lifo
- the new value for the LIFO property
-
getMaxTotal
public int getMaxTotal()
Returns the maximum number of active connections that can be allocated at the same time.
A negative number means that there is no limit.
- Specified by:
getMaxTotal
in interfaceBasicDataSourceMXBean
- Returns:
- the maximum number of active connections
-
setMaxTotal
public void setMaxTotal(int maxTotal)
Sets the maximum total number of idle and borrows connections that can be active at the same time. Use a negative value for no limit.- Parameters:
maxTotal
- the new value for maxTotal- See Also:
getMaxTotal()
-
getMaxIdle
public int getMaxIdle()
Returns the maximum number of connections that can remain idle in the pool. Excess idle connections are destroyed on return to the pool.
A negative value indicates that there is no limit
- Specified by:
getMaxIdle
in interfaceBasicDataSourceMXBean
- Returns:
- the maximum number of idle connections
-
setMaxIdle
public void setMaxIdle(int maxIdle)
Sets the maximum number of connections that can remain idle in the pool. Excess idle connections are destroyed on return to the pool.- Parameters:
maxIdle
- the new value for maxIdle- See Also:
getMaxIdle()
-
getMinIdle
public int getMinIdle()
Returns the minimum number of idle connections in the pool. The pool attempts to ensure that minIdle connections are available when the idle object evictor runs. The value of this property has no effect unlesstimeBetweenEvictionRunsMillis
has a positive value.- Specified by:
getMinIdle
in interfaceBasicDataSourceMXBean
- Returns:
- the minimum number of idle connections
- See Also:
GenericObjectPool.getMinIdle()
-
setMinIdle
public void setMinIdle(int minIdle)
Sets the minimum number of idle connections in the pool. The pool attempts to ensure that minIdle connections are available when the idle object evictor runs. The value of this property has no effect unlesstimeBetweenEvictionRunsMillis
has a positive value.- Parameters:
minIdle
- the new value for minIdle- See Also:
GenericObjectPool.setMinIdle(int)
-
getInitialSize
public int getInitialSize()
Returns the initial size of the connection pool.- Specified by:
getInitialSize
in interfaceBasicDataSourceMXBean
- Returns:
- the number of connections created when the pool is initialized
-
setInitialSize
public void setInitialSize(int initialSize)
Sets the initial size of the connection pool.
Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
initialSize
- the number of connections created when the pool is initialized
-
getMaxWaitMillis
public long getMaxWaitMillis()
Returns the maximum number of milliseconds that the pool will wait for a connection to be returned before throwing an exception. A value less than or equal to zero means the pool is set to wait indefinitely.- Specified by:
getMaxWaitMillis
in interfaceBasicDataSourceMXBean
- Returns:
- the maxWaitMillis property value
-
setMaxWaitMillis
public void setMaxWaitMillis(long maxWaitMillis)
Sets the MaxWaitMillis property. Use -1 to make the pool wait indefinitely.- Parameters:
maxWaitMillis
- the new value for MaxWaitMillis- See Also:
getMaxWaitMillis()
-
isPoolPreparedStatements
public boolean isPoolPreparedStatements()
Returns true if we are pooling statements.- Specified by:
isPoolPreparedStatements
in interfaceBasicDataSourceMXBean
- Returns:
- true if prepared and callable statements are pooled
-
setPoolPreparedStatements
public void setPoolPreparedStatements(boolean poolingStatements)
Sets whether to pool statements or not.
Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
poolingStatements
- pooling on or off
-
getMaxOpenPreparedStatements
public int getMaxOpenPreparedStatements()
Gets the value of themaxOpenPreparedStatements
property.- Specified by:
getMaxOpenPreparedStatements
in interfaceBasicDataSourceMXBean
- Returns:
- the maximum number of open statements
-
setMaxOpenPreparedStatements
public void setMaxOpenPreparedStatements(int maxOpenStatements)
Sets the value of the
maxOpenPreparedStatements
property.Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
maxOpenStatements
- the new maximum number of prepared statements
-
getTestOnCreate
public boolean getTestOnCreate()
Returns thetestOnCreate
property.- Specified by:
getTestOnCreate
in interfaceBasicDataSourceMXBean
- Returns:
- true if objects are validated immediately after they are created by the pool
- See Also:
testOnCreate
-
setTestOnCreate
public void setTestOnCreate(boolean testOnCreate)
Sets thetestOnCreate
property. This property determines whether or not the pool will validate objects immediately after they are created by the pool- Parameters:
testOnCreate
- new value for testOnCreate property
-
getTestOnBorrow
public boolean getTestOnBorrow()
Returns thetestOnBorrow
property.- Specified by:
getTestOnBorrow
in interfaceBasicDataSourceMXBean
- Returns:
- true if objects are validated before being borrowed from the pool
- See Also:
testOnBorrow
-
setTestOnBorrow
public void setTestOnBorrow(boolean testOnBorrow)
Sets thetestOnBorrow
property. This property determines whether or not the pool will validate objects before they are borrowed from the pool.- Parameters:
testOnBorrow
- new value for testOnBorrow property
-
getTestOnReturn
public boolean getTestOnReturn()
Returns the value of thetestOnReturn
property.- Returns:
- true if objects are validated before being returned to the pool
- See Also:
testOnReturn
-
setTestOnReturn
public void setTestOnReturn(boolean testOnReturn)
Sets thetestOnReturn
property. This property determines whether or not the pool will validate objects before they are returned to the pool.- Parameters:
testOnReturn
- new value for testOnReturn property
-
getTimeBetweenEvictionRunsMillis
public long getTimeBetweenEvictionRunsMillis()
Returns the value of thetimeBetweenEvictionRunsMillis
property.- Specified by:
getTimeBetweenEvictionRunsMillis
in interfaceBasicDataSourceMXBean
- Returns:
- the time (in milliseconds) between evictor runs
- See Also:
timeBetweenEvictionRunsMillis
-
setTimeBetweenEvictionRunsMillis
public void setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis)
Sets thetimeBetweenEvictionRunsMillis
property.- Parameters:
timeBetweenEvictionRunsMillis
- the new time between evictor runs- See Also:
timeBetweenEvictionRunsMillis
-
getNumTestsPerEvictionRun
public int getNumTestsPerEvictionRun()
Returns the value of thenumTestsPerEvictionRun
property.- Specified by:
getNumTestsPerEvictionRun
in interfaceBasicDataSourceMXBean
- Returns:
- the number of objects to examine during idle object evictor runs
- See Also:
numTestsPerEvictionRun
-
setNumTestsPerEvictionRun
public void setNumTestsPerEvictionRun(int numTestsPerEvictionRun)
Sets the value of thenumTestsPerEvictionRun
property.- Parameters:
numTestsPerEvictionRun
- the newnumTestsPerEvictionRun
value- See Also:
numTestsPerEvictionRun
-
getMinEvictableIdleTimeMillis
public long getMinEvictableIdleTimeMillis()
Returns theminEvictableIdleTimeMillis
property.- Specified by:
getMinEvictableIdleTimeMillis
in interfaceBasicDataSourceMXBean
- Returns:
- the value of the
minEvictableIdleTimeMillis
property - See Also:
minEvictableIdleTimeMillis
-
setMinEvictableIdleTimeMillis
public void setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis)
Sets theminEvictableIdleTimeMillis
property.- Parameters:
minEvictableIdleTimeMillis
- the minimum amount of time an object may sit idle in the pool- See Also:
minEvictableIdleTimeMillis
-
setSoftMinEvictableIdleTimeMillis
public void setSoftMinEvictableIdleTimeMillis(long softMinEvictableIdleTimeMillis)
Sets the minimum amount of time a connection may sit idle in the pool before it is eligible for eviction by the idle object evictor, with the extra condition that at least "minIdle" connections remain in the pool.- Parameters:
softMinEvictableIdleTimeMillis
- minimum amount of time a connection may sit idle in the pool before it is eligible for eviction, assuming there are minIdle idle connections in the pool.- See Also:
getSoftMinEvictableIdleTimeMillis()
-
getSoftMinEvictableIdleTimeMillis
public long getSoftMinEvictableIdleTimeMillis()
Returns the minimum amount of time a connection may sit idle in the pool before it is eligible for eviction by the idle object evictor, with the extra condition that at least "minIdle" connections remain in the pool.
When
minEvictableIdleTimeMillis
is set to a positive value, minEvictableIdleTimeMillis is examined first by the idle connection evictor - i.e. when idle connections are visited by the evictor, idle time is first compared againstminEvictableIdleTimeMillis
(without considering the number of idle connections in the pool) and then againstsoftMinEvictableIdleTimeMillis
, including theminIdle
, constraint.- Specified by:
getSoftMinEvictableIdleTimeMillis
in interfaceBasicDataSourceMXBean
- Returns:
- minimum amount of time a connection may sit idle in the pool before it is eligible for eviction, assuming there are minIdle idle connections in the pool
-
getEvictionPolicyClassName
public String getEvictionPolicyClassName()
Gets the EvictionPolicy implementation in use with this connection pool.- Returns:
- The EvictionPolicy implementation in use with this connection pool.
-
setEvictionPolicyClassName
public void setEvictionPolicyClassName(String evictionPolicyClassName)
Sets the EvictionPolicy implementation to use with this connection pool.- Parameters:
evictionPolicyClassName
- The fully qualified class name of the EvictionPolicy implementation
-
getTestWhileIdle
public boolean getTestWhileIdle()
Returns the value of thetestWhileIdle
property.- Specified by:
getTestWhileIdle
in interfaceBasicDataSourceMXBean
- Returns:
- true if objects examined by the idle object evictor are validated
- See Also:
testWhileIdle
-
setTestWhileIdle
public void setTestWhileIdle(boolean testWhileIdle)
Sets thetestWhileIdle
property. This property determines whether or not the idle object evictor will validate connections.- Parameters:
testWhileIdle
- new value for testWhileIdle property
-
getNumActive
public int getNumActive()
[Read Only] The current number of active connections that have been allocated from this data source.- Specified by:
getNumActive
in interfaceBasicDataSourceMXBean
- Returns:
- the current number of active connections
-
getNumIdle
public int getNumIdle()
[Read Only] The current number of idle connections that are waiting to be allocated from this data source.- Specified by:
getNumIdle
in interfaceBasicDataSourceMXBean
- Returns:
- the current number of idle connections
-
getPassword
public String getPassword()
Returns the password passed to the JDBC driver to establish connections.- Specified by:
getPassword
in interfaceBasicDataSourceMXBean
- Returns:
- the connection password
-
setPassword
public void setPassword(String password)
Sets the
password
.Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
password
- new value for the password
-
getUrl
public String getUrl()
Returns the JDBC connectionurl
property.- Specified by:
getUrl
in interfaceBasicDataSourceMXBean
- Returns:
- the
url
passed to the JDBC driver to establish connections
-
setUrl
public void setUrl(String url)
Sets the
url
.Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
url
- the new value for the JDBC connection url
-
getUsername
public String getUsername()
Returns the JDBC connectionuserName
property.- Specified by:
getUsername
in interfaceBasicDataSourceMXBean
- Returns:
- the
userName
passed to the JDBC driver to establish connections
-
setUsername
public void setUsername(String userName)
Sets the
userName
.Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
userName
- the new value for the JDBC connection user name
-
getValidationQuery
public String getValidationQuery()
Returns the validation query used to validate connections before returning them.- Specified by:
getValidationQuery
in interfaceBasicDataSourceMXBean
- Returns:
- the SQL validation query
- See Also:
validationQuery
-
setValidationQuery
public void setValidationQuery(String validationQuery)
Sets the
validationQuery
.Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
validationQuery
- the new value for the validation query
-
getValidationQueryTimeout
public int getValidationQueryTimeout()
Returns the validation query timeout.- Specified by:
getValidationQueryTimeout
in interfaceBasicDataSourceMXBean
- Returns:
- the timeout in seconds before connection validation queries fail.
-
setValidationQueryTimeout
public void setValidationQueryTimeout(int validationQueryTimeoutSeconds)
Sets the validation query timeout, the amount of time, in seconds, that connection validation will wait for a response from the database when executing a validation query. Use a value less than or equal to 0 for no timeout.Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
validationQueryTimeoutSeconds
- new validation query timeout value in seconds
-
getConnectionInitSqls
public List<String> getConnectionInitSqls()
Returns the list of SQL statements executed when a physical connection is first created. Returns an empty list if there are no initialization statements configured.- Returns:
- initialization SQL statements
-
getConnectionInitSqlsAsArray
public String[] getConnectionInitSqlsAsArray()
Provides the same data asgetConnectionInitSqls()
but in an array so it is accessible via JMX.- Specified by:
getConnectionInitSqlsAsArray
in interfaceBasicDataSourceMXBean
- Returns:
getConnectionInitSqlsAsArray()
-
setConnectionInitSqls
public void setConnectionInitSqls(Collection<String> connectionInitSqls)
Sets the list of SQL statements to be executed when a physical connection is first created.Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
connectionInitSqls
- Collection of SQL statements to execute on connection creation
-
isAccessToUnderlyingConnectionAllowed
public boolean isAccessToUnderlyingConnectionAllowed()
Returns the value of the accessToUnderlyingConnectionAllowed property.- Specified by:
isAccessToUnderlyingConnectionAllowed
in interfaceBasicDataSourceMXBean
- Returns:
- true if access to the underlying connection is allowed, false otherwise.
-
setAccessToUnderlyingConnectionAllowed
public void setAccessToUnderlyingConnectionAllowed(boolean allow)
Sets the value of the accessToUnderlyingConnectionAllowed property. It controls if the PoolGuard allows access to the underlying connection. (Default: false)
Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
allow
- Access to the underlying connection is granted when true.
-
getMaxConnLifetimeMillis
public long getMaxConnLifetimeMillis()
Returns the maximum permitted lifetime of a connection in milliseconds. A value of zero or less indicates an infinite lifetime.- Specified by:
getMaxConnLifetimeMillis
in interfaceBasicDataSourceMXBean
- Returns:
getMaxConnLifetimeMillis()
-
getLogExpiredConnections
public boolean getLogExpiredConnections()
WhengetMaxConnLifetimeMillis()
is set to limit connection lifetime, this property determines whether or not log messages are generated when the pool closes connections due to maximum lifetime exceeded.- Specified by:
getLogExpiredConnections
in interfaceBasicDataSourceMXBean
- Returns:
getLogExpiredConnections()
- Since:
- 2.1
-
setMaxConnLifetimeMillis
public void setMaxConnLifetimeMillis(long maxConnLifetimeMillis)
Sets the maximum permitted lifetime of a connection in milliseconds. A value of zero or less indicates an infinite lifetime.
Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter.
- Parameters:
maxConnLifetimeMillis
- The maximum permitted lifetime of a connection in milliseconds.
-
setLogExpiredConnections
public void setLogExpiredConnections(boolean logExpiredConnections)
WhengetMaxConnLifetimeMillis()
is set to limit connection lifetime, this property determines whether or not log messages are generated when the pool closes connections due to maximum lifetime exceeded. Set this property to false to suppress log messages when connections expire.- Parameters:
logExpiredConnections
- Whether or not log messages are generated when the pool closes connections due to maximum lifetime exceeded.
-
getJmxName
public String getJmxName()
Returns the JMX name that has been requested for this DataSource. If the requested name is not valid, an alternative may be chosen.- Returns:
- The JMX name that has been requested for this DataSource.
-
setJmxName
public void setJmxName(String jmxName)
Sets the JMX name that has been requested for this DataSource. If the requested name is not valid, an alternative may be chosen. This DataSource will attempt to register itself using this name. If another component registers this DataSource with JMX and this name is valid this name will be used in preference to any specified by the other component.- Parameters:
jmxName
- The JMX name that has been requested for this DataSource
-
getEnableAutoCommitOnReturn
public boolean getEnableAutoCommitOnReturn()
Returns the value of the flag that controls whether or not connections being returned to the pool will be checked and configured withConnection.setAutoCommit(true)
if the auto commit setting isfalse
when the connection is returned. It istrue
by default.- Returns:
- Whether or not connections being returned to the pool will be checked and configured with auto-commit.
-
setEnableAutoCommitOnReturn
public void setEnableAutoCommitOnReturn(boolean enableAutoCommitOnReturn)
Sets the value of the flag that controls whether or not connections being returned to the pool will be checked and configured withConnection.setAutoCommit(true)
if the auto commit setting isfalse
when the connection is returned. It istrue
by default.- Parameters:
enableAutoCommitOnReturn
- Whether or not connections being returned to the pool will be checked and configured with auto-commit.
-
getRollbackOnReturn
public boolean getRollbackOnReturn()
Gets the current value of the flag that controls whether a connection will be rolled back when it is returned to the pool if auto commit is not enabled and the connection is not read only.- Returns:
- whether a connection will be rolled back when it is returned to the pool.
-
setRollbackOnReturn
public void setRollbackOnReturn(boolean rollbackOnReturn)
Sets the flag that controls if a connection will be rolled back when it is returned to the pool if auto commit is not enabled and the connection is not read only.- Parameters:
rollbackOnReturn
- whether a connection will be rolled back when it is returned to the pool.
-
getDisconnectionSqlCodes
public Set<String> getDisconnectionSqlCodes()
Returns the set of SQL_STATE codes considered to signal fatal conditions.- Returns:
- fatal disconnection state codes
- Since:
- 2.1
- See Also:
setDisconnectionSqlCodes(Collection)
-
getDisconnectionSqlCodesAsArray
public String[] getDisconnectionSqlCodesAsArray()
Provides the same data asgetDisconnectionSqlCodes()
but in an array so it is accessible via JMX.- Specified by:
getDisconnectionSqlCodesAsArray
in interfaceBasicDataSourceMXBean
- Returns:
getDisconnectionSqlCodesAsArray()
- Since:
- 2.1
-
setDisconnectionSqlCodes
public void setDisconnectionSqlCodes(Collection<String> disconnectionSqlCodes)
Sets the SQL_STATE codes considered to signal fatal conditions.Overrides the defaults in
Utils.DISCONNECTION_SQL_CODES
(plus anything starting withUtils.DISCONNECTION_SQL_CODE_PREFIX
). If this property is non-null andgetFastFailValidation()
istrue
, whenever connections created by this datasource generate exceptions with SQL_STATE codes in this list, they will be marked as "fatally disconnected" and subsequent validations will fail fast (no attempt at isValid or validation query).If
getFastFailValidation()
isfalse
setting this property has no effect.Note: this method currently has no effect once the pool has been initialized. The pool is initialized the first time one of the following methods is invoked:
getConnection, setLogwriter, setLoginTimeout, getLoginTimeout, getLogWriter
.- Parameters:
disconnectionSqlCodes
- SQL_STATE codes considered to signal fatal conditions- Since:
- 2.1
-
getFastFailValidation
public boolean getFastFailValidation()
True means that validation will fail immediately for connections that have previously thrown SQLExceptions with SQL_STATE indicating fatal disconnection errors.- Specified by:
getFastFailValidation
in interfaceBasicDataSourceMXBean
- Returns:
- true if connections created by this datasource will fast fail validation.
- Since:
- 2.1
- See Also:
setDisconnectionSqlCodes(Collection)
-
setFastFailValidation
public void setFastFailValidation(boolean fastFailValidation)
- Parameters:
fastFailValidation
- true means connections created by this factory will fast fail validation- Since:
- 2.1
- See Also:
getFastFailValidation()
-
getConnectionPool
protected GenericObjectPool<PoolableConnection> getConnectionPool()
-
getConnection
public Connection getConnection() throws SQLException
Creates (if necessary) and return a connection to the database.- Specified by:
getConnection
in interfaceDataSource
- Returns:
- a database connection
- Throws:
SQLException
- if a database access error occurs
-
getConnection
public Connection getConnection(String user, String pass) throws SQLException
BasicDataSource does NOT support this method.- Specified by:
getConnection
in interfaceDataSource
- Parameters:
user
- Database user on whose behalf the Connection is being madepass
- The database user's password- Returns:
- nothing - always throws UnsupportedOperationException
- Throws:
UnsupportedOperationException
- always thrown.SQLException
- if a database access error occurs
-
getLoginTimeout
public int getLoginTimeout() throws SQLException
BasicDataSource does NOT support this method.Returns the login timeout (in seconds) for connecting to the database.
Calls
createDataSource()
, so has the side effect of initializing the connection pool.- Specified by:
getLoginTimeout
in interfaceCommonDataSource
- Returns:
- login timeout in seconds
- Throws:
SQLException
- if a database access error occursUnsupportedOperationException
- If the DataSource implementation does not support the login timeout feature.
-
getLogWriter
public PrintWriter getLogWriter() throws SQLException
Returns the log writer being used by this data source.
Calls
createDataSource()
, so has the side effect of initializing the connection pool.- Specified by:
getLogWriter
in interfaceCommonDataSource
- Returns:
- log writer in use
- Throws:
SQLException
- if a database access error occurs
-
setLoginTimeout
public void setLoginTimeout(int loginTimeout) throws SQLException
BasicDataSource does NOT support this method.Set the login timeout (in seconds) for connecting to the database.
Calls
createDataSource()
, so has the side effect of initializing the connection pool.- Specified by:
setLoginTimeout
in interfaceCommonDataSource
- Parameters:
loginTimeout
- The new login timeout, or zero for no timeout- Throws:
UnsupportedOperationException
- If the DataSource implementation does not support the login timeout feature.SQLException
- if a database access error occurs
-
setLogWriter
public void setLogWriter(PrintWriter logWriter) throws SQLException
Sets the log writer being used by this data source.
Calls
createDataSource()
, so has the side effect of initializing the connection pool.- Specified by:
setLogWriter
in interfaceCommonDataSource
- Parameters:
logWriter
- The new log writer- Throws:
SQLException
- if a database access error occurs
-
getRemoveAbandonedOnBorrow
public boolean getRemoveAbandonedOnBorrow()
Flag to remove abandoned connections if they exceed the removeAbandonedTimeout when borrowObject is invoked.
The default value is false.
If set to true a connection is considered abandoned and eligible for removal if it has not been used for more than
removeAbandonedTimeout
seconds.Abandoned connections are identified and removed when
getConnection()
is invoked and all of the following conditions hold:- Specified by:
getRemoveAbandonedOnBorrow
in interfaceBasicDataSourceMXBean
- Returns:
getRemoveAbandonedOnBorrow()
- See Also:
getRemoveAbandonedTimeout()
-
setRemoveAbandonedOnMaintenance
public void setRemoveAbandonedOnMaintenance(boolean removeAbandonedOnMaintenance)
- Parameters:
removeAbandonedOnMaintenance
- true means abandoned connections may be removed on pool maintenance.- See Also:
getRemoveAbandonedOnMaintenance()
-
getRemoveAbandonedOnMaintenance
public boolean getRemoveAbandonedOnMaintenance()
Flag to remove abandoned connections if they exceed the removeAbandonedTimeout during pool maintenance.
The default value is false.
If set to true a connection is considered abandoned and eligible for removal if it has not been used for more than
removeAbandonedTimeout
seconds.- Specified by:
getRemoveAbandonedOnMaintenance
in interfaceBasicDataSourceMXBean
- Returns:
getRemoveAbandonedOnMaintenance()
- See Also:
getRemoveAbandonedTimeout()
-
setRemoveAbandonedOnBorrow
public void setRemoveAbandonedOnBorrow(boolean removeAbandonedOnBorrow)
- Parameters:
removeAbandonedOnBorrow
- true means abandoned connections may be removed when connections are borrowed from the pool.- See Also:
getRemoveAbandonedOnBorrow()
-
getRemoveAbandonedTimeout
public int getRemoveAbandonedTimeout()
Timeout in seconds before an abandoned connection can be removed.
Creating a Statement, PreparedStatement or CallableStatement or using one of these to execute a query (using one of the execute methods) resets the lastUsed property of the parent connection.
Abandoned connection cleanup happens when:
getRemoveAbandonedOnBorrow()
orgetRemoveAbandonedOnMaintenance()
= truenumIdle
< 2numActive
>maxTotal
- 3
The default value is 300 seconds.
- Specified by:
getRemoveAbandonedTimeout
in interfaceBasicDataSourceMXBean
- Returns:
getRemoveAbandonedTimeout()
-
setRemoveAbandonedTimeout
public void setRemoveAbandonedTimeout(int removeAbandonedTimeout)
Sets the timeout in seconds before an abandoned connection can be removed.
Setting this property has no effect if
getRemoveAbandonedOnBorrow()
andgetRemoveAbandonedOnMaintenance()
are false.- Parameters:
removeAbandonedTimeout
- new abandoned timeout in seconds- See Also:
getRemoveAbandonedTimeout()
,getRemoveAbandonedOnBorrow()
,getRemoveAbandonedOnMaintenance()
-
getLogAbandoned
public boolean getLogAbandoned()
Flag to log stack traces for application code which abandoned a Statement or Connection.
Defaults to false.
Logging of abandoned Statements and Connections adds overhead for every Connection open or new Statement because a stack trace has to be generated.
- Specified by:
getLogAbandoned
in interfaceBasicDataSourceMXBean
- Returns:
getLogAbandoned()
-
setLogAbandoned
public void setLogAbandoned(boolean logAbandoned)
- Parameters:
logAbandoned
- new logAbandoned property value
-
getAbandonedLogWriter
public PrintWriter getAbandonedLogWriter()
Gets the print writer used by this configuration to log information on abandoned objects.- Returns:
- The print writer used by this configuration to log information on abandoned objects.
-
setAbandonedLogWriter
public void setAbandonedLogWriter(PrintWriter logWriter)
Sets the print writer to be used by this configuration to log information on abandoned objects.- Parameters:
logWriter
- The new log writer
-
getAbandonedUsageTracking
public boolean getAbandonedUsageTracking()
If the connection pool implementsUsageTracking
, should the connection pool record a stack trace every time a method is called on a pooled connection and retain the most recent stack trace to aid debugging of abandoned connections?- Specified by:
getAbandonedUsageTracking
in interfaceBasicDataSourceMXBean
- Returns:
true
if usage tracking is enabled
-
setAbandonedUsageTracking
public void setAbandonedUsageTracking(boolean usageTracking)
If the connection pool implementsUsageTracking
, configure whether the connection pool should record a stack trace every time a method is called on a pooled connection and retain the most recent stack trace to aid debugging of abandoned connections.- Parameters:
usageTracking
- A value oftrue
will enable the recording of a stack trace on every use of a pooled connection
-
addConnectionProperty
public void addConnectionProperty(String name, String value)
Adds a custom connection property to the set that will be passed to our JDBC driver. This MUST be called before the first connection is retrieved (along with all the other configuration property setters). Calls to this method after the connection pool has been initialized have no effect.- Parameters:
name
- Name of the custom connection propertyvalue
- Value of the custom connection property
-
removeConnectionProperty
public void removeConnectionProperty(String name)
Removes a custom connection property.- Parameters:
name
- Name of the custom connection property to remove- See Also:
addConnectionProperty(String, String)
-
setConnectionProperties
public void setConnectionProperties(String connectionProperties)
Sets the connection properties passed to driver.connect(...).Format of the string must be [propertyName=property;]*
NOTE - The "user" and "password" properties will be added explicitly, so they do not need to be included here.
- Parameters:
connectionProperties
- the connection properties used to create new connections
-
close
public void close() throws SQLException
Closes and releases all idle connections that are currently stored in the connection pool associated with this data source.
Connections that are checked out to clients when this method is invoked are not affected. When client applications subsequently invoke
Connection.close()
to return these connections to the pool, the underlying JDBC connections are closed.Attempts to acquire connections using
getConnection()
after this method has been invoked result in SQLExceptions.This method is idempotent - i.e., closing an already closed BasicDataSource has no effect and does not generate exceptions.
- Specified by:
close
in interfaceAutoCloseable
- Throws:
SQLException
- if an error occurs closing idle connections
-
isClosed
public boolean isClosed()
If true, this data source is closed and no more connections can be retrieved from this datasource.- Specified by:
isClosed
in interfaceBasicDataSourceMXBean
- Returns:
- true, if the data source is closed; false otherwise
-
isWrapperFor
public boolean isWrapperFor(Class<?> iface) throws SQLException
- Specified by:
isWrapperFor
in interfaceWrapper
- Throws:
SQLException
-
unwrap
public <T> T unwrap(Class<T> iface) throws SQLException
- Specified by:
unwrap
in interfaceWrapper
- Throws:
SQLException
-
getParentLogger
public Logger getParentLogger() throws SQLFeatureNotSupportedException
- Specified by:
getParentLogger
in interfaceCommonDataSource
- Throws:
SQLFeatureNotSupportedException
-
invalidateConnection
public void invalidateConnection(Connection connection) throws IllegalStateException
Manually invalidates a connection, effectively requesting the pool to try to close it, remove it from the pool and reclaim pool capacity.- Parameters:
connection
- The Connection to invalidate.- Throws:
IllegalStateException
- if invalidating the connection failed.- Since:
- 2.1
-
createDataSource
protected DataSource createDataSource() throws SQLException
Creates (if necessary) and return the internal data source we are using to manage our connections.
- Throws:
SQLException
- if the object pool cannot be created.
-
createConnectionFactory
protected ConnectionFactory createConnectionFactory() throws SQLException
Creates a JDBC connection factory for this datasource. The JDBC driver is loaded using the following algorithm:- If a Driver instance has been specified via
setDriver(Driver)
use it - If no Driver instance was specified and
driverClassName
is specified that class is loaded using theClassLoader
of this class or, ifdriverClassLoader
is set,driverClassName
is loaded with the specifiedClassLoader
. - If
driverClassName
is specified and the previous attempt fails, the class is loaded using the context class loader of the current thread. - If a driver still isn't loaded one is loaded via the
DriverManager
using the specifiedurl
.
- Throws:
SQLException
- If a Driver instance has been specified via
-
createConnectionPool
protected void createConnectionPool(PoolableConnectionFactory factory)
Creates a connection pool for this datasource. This method only exists so subclasses can replace the implementation class.This implementation configures all pool properties other than timeBetweenEvictionRunsMillis. Setting that property is deferred to
startPoolMaintenance()
, since setting timeBetweenEvictionRunsMillis to a positive value causesGenericObjectPool
's eviction timer to be started.
-
createObjectPool
protected GenericObjectPool<PoolableConnection> createObjectPool(PoolableConnectionFactory factory, GenericObjectPoolConfig poolConfig, AbandonedConfig abandonedConfig)
Creates an object pool used to provide pooling support forJDBC connections
.- Parameters:
factory
- the object factorypoolConfig
- the object pool configurationabandonedConfig
- the abandoned objects configuration- Returns:
- a non-null instance
-
startPoolMaintenance
protected void startPoolMaintenance()
Starts the connection pool maintenance task, if configured.
-
createDataSourceInstance
protected DataSource createDataSourceInstance() throws SQLException
Creates the actual data source instance. This method only exists so that subclasses can replace the implementation class.- Throws:
SQLException
- if unable to create a datasource instance
-
createPoolableConnectionFactory
protected PoolableConnectionFactory createPoolableConnectionFactory(ConnectionFactory driverConnectionFactory) throws SQLException
Creates the PoolableConnectionFactory and attaches it to the connection pool. This method only exists so subclasses can replace the default implementation.- Parameters:
driverConnectionFactory
- JDBC connection factory- Throws:
SQLException
- if an error occurs creating the PoolableConnectionFactory
-
validateConnectionFactory
protected static void validateConnectionFactory(PoolableConnectionFactory connectionFactory) throws Exception
- Throws:
Exception
-
preRegister
public ObjectName preRegister(MBeanServer server, ObjectName objectName)
- Specified by:
preRegister
in interfaceMBeanRegistration
-
postRegister
public void postRegister(Boolean registrationDone)
- Specified by:
postRegister
in interfaceMBeanRegistration
-
preDeregister
public void preDeregister() throws Exception
- Specified by:
preDeregister
in interfaceMBeanRegistration
- Throws:
Exception
-
postDeregister
public void postDeregister()
- Specified by:
postDeregister
in interfaceMBeanRegistration
-
getRegisteredJmxName
protected ObjectName getRegisteredJmxName()
-
-