com.adaptris.core.jdbc

Class JdbcPooledConnection

java.lang.Object

com.adaptris.core.AdaptrisConnectionImp

com.adaptris.core.AllowsRetriesConnection

com.adaptris.core.jdbc.DatabaseConnection

com.adaptris.core.jdbc.JdbcPooledConnectionImpl

com.adaptris.core.jdbc.JdbcPooledConnection

All Implemented Interfaces:

AdaptrisComponent, AdaptrisConnection, ComponentLifecycle, ComponentLifecycleExtension, JdbcPoolConfiguration, JndiBindable, StateManagedComponent

@ComponentProfile(summary="Connect to a database using a JDBC driver; connection pooling handled via C3P0",
                  tag="connections,jdbc")
public class JdbcPooledConnection
extends JdbcPooledConnectionImpl
implements JdbcPoolConfiguration

A DatabaseConnection instance that provides connection pooling via c3p0.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_ACQUIRE_INCREMENT
static int	DEFAULT_MAXIMUM_POOL_SIZE
static int	DEFAULT_MINIMUM_POOL_SIZE

Fields inherited from class com.adaptris.core.jdbc.JdbcPooledConnectionImpl

connectionPool

Fields inherited from class com.adaptris.core.AdaptrisConnectionImp

log

Constructor Summary

Constructors

Constructor and Description
JdbcPooledConnection()

Method Summary

Modifier and Type	Method and Description
int	acquireIncrement()
int	connectionAcquireWait()
protected com.mchange.v2.c3p0.ComboPooledDataSource	createPool()
int	currentBusyConnectionCount()
int	currentConnectionCount()
int	currentIdleConnectionCount()
boolean	equals(java.lang.Object o) Force implementations to over-ride equals with a semantic implementation.
java.lang.Integer	getAcquireIncrement()
TimeInterval	getConnectionAcquireWait()
TimeInterval	getIdleConnectionTestPeriod()
TimeInterval	getMaxIdleTime()
java.lang.Integer	getMaximumPoolSize()
java.lang.Integer	getMinimumPoolSize()
JdbcPoolFactory	getPoolFactory()
int	hashCode() Force implementations to over-ride hashcode.
int	idleConnectionTestPeriod()
int	maxIdleTime()
int	maxPoolSize()
int	minPoolSize()
void	setAcquireIncrement(java.lang.Integer acquireIncrement)
void	setConnectionAcquireWait(TimeInterval connectionAcquireWait)
void	setIdleConnectionTestPeriod(TimeInterval idleConnectionTestPeriod)
void	setMaxIdleTime(TimeInterval t)
void	setMaximumPoolSize(java.lang.Integer maximumPoolSize)
void	setMinimumPoolSize(java.lang.Integer minimumPoolSize)
void	setPoolFactory(JdbcPoolFactory f)

Methods inherited from class com.adaptris.core.jdbc.JdbcPooledConnectionImpl

asDataSource, closeDatabaseConnection, getConnectionName, getConnectUrl, initialiseDatabaseConnection, makeConnection, setConnectUrl, startDatabaseConnection, stopDatabaseConnection

Methods inherited from class com.adaptris.core.jdbc.DatabaseConnection

alwaysValidateConnection, autoCommit, checkInternalState, closeConnection, connect, connectionProperties, debugMode, getAlwaysValidateConnection, getAutoCommit, getConnectionProperties, getDebugMode, getDriverImp, getPassword, getTestStatement, getUsername, initConnection, prepareConnection, setAlwaysValidateConnection, setAutoCommit, setConnectionProperties, setDebugMode, setDriverImp, setPassword, setTestStatement, setUsername, startConnection, stopConnection

Methods inherited from class com.adaptris.core.AllowsRetriesConnection

connectionAttempts, connectionRetryInterval, createLoggingStatement, getConnectionAttempts, getConnectionRetryInterval, logWarning, setConnectionAttempts, setConnectionRetryInterval

Methods inherited from class com.adaptris.core.AdaptrisConnectionImp

addExceptionListener, addMessageConsumer, addMessageProducer, changeState, cloneForTesting, close, connectionErrorHandler, getConnectionErrorHandler, getLookupName, getUniqueId, getWorkersFirstOnShutdown, init, prepare, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, retrieveConnection, retrieveExceptionListeners, retrieveMessageConsumers, retrieveMessageProducers, setConnectionErrorHandler, setLookupName, setUniqueId, setWorkersFirstOnShutdown, start, stop, workersFirstOnShutdown

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.adaptris.core.jdbc.JdbcPoolConfiguration

alwaysValidateConnection, connectionAttempts, connectionRetryInterval

Field Detail

DEFAULT_MINIMUM_POOL_SIZE

public static final int DEFAULT_MINIMUM_POOL_SIZE

See Also:

Constant Field Values

DEFAULT_MAXIMUM_POOL_SIZE

public static final int DEFAULT_MAXIMUM_POOL_SIZE

See Also:

Constant Field Values

DEFAULT_ACQUIRE_INCREMENT

public static final int DEFAULT_ACQUIRE_INCREMENT

See Also:

Constant Field Values

Constructor Detail

JdbcPooledConnection

public JdbcPooledConnection()

Method Detail

createPool

protected com.mchange.v2.c3p0.ComboPooledDataSource createPool()
                                                        throws CoreException

Specified by:

createPool in class JdbcPooledConnectionImpl

Throws:

CoreException

equals

public boolean equals(java.lang.Object o)

Description copied from class: DatabaseConnection

Force implementations to over-ride equals with a semantic implementation.

Specified by:

equals in class DatabaseConnection

See Also:

Object.equals(java.lang.Object)

hashCode

public int hashCode()

Description copied from class: DatabaseConnection

Force implementations to over-ride hashcode.

Specified by:

hashCode in class DatabaseConnection

See Also:

Object.hashCode()

getMinimumPoolSize

public java.lang.Integer getMinimumPoolSize()

setMinimumPoolSize

public void setMinimumPoolSize(java.lang.Integer minimumPoolSize)

minPoolSize

public int minPoolSize()

Specified by:

minPoolSize in interface JdbcPoolConfiguration

getMaximumPoolSize

public java.lang.Integer getMaximumPoolSize()

setMaximumPoolSize

public void setMaximumPoolSize(java.lang.Integer maximumPoolSize)

maxPoolSize

public int maxPoolSize()

Specified by:

maxPoolSize in interface JdbcPoolConfiguration

getAcquireIncrement

public java.lang.Integer getAcquireIncrement()

setAcquireIncrement

public void setAcquireIncrement(java.lang.Integer acquireIncrement)

acquireIncrement

public int acquireIncrement()

Specified by:

acquireIncrement in interface JdbcPoolConfiguration

getConnectionAcquireWait

public TimeInterval getConnectionAcquireWait()

connectionAcquireWait

public int connectionAcquireWait()

Specified by:

connectionAcquireWait in interface JdbcPoolConfiguration

setConnectionAcquireWait

public void setConnectionAcquireWait(TimeInterval connectionAcquireWait)

getIdleConnectionTestPeriod

public TimeInterval getIdleConnectionTestPeriod()

idleConnectionTestPeriod

public int idleConnectionTestPeriod()

Specified by:

idleConnectionTestPeriod in interface JdbcPoolConfiguration

setIdleConnectionTestPeriod

public void setIdleConnectionTestPeriod(TimeInterval idleConnectionTestPeriod)

getMaxIdleTime

public TimeInterval getMaxIdleTime()

setMaxIdleTime

public void setMaxIdleTime(TimeInterval t)

maxIdleTime

public int maxIdleTime()

Specified by:

maxIdleTime in interface JdbcPoolConfiguration

currentBusyConnectionCount

public int currentBusyConnectionCount()
                               throws java.sql.SQLException

Throws:

java.sql.SQLException

currentConnectionCount

public int currentConnectionCount()
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

currentIdleConnectionCount

public int currentIdleConnectionCount()
                               throws java.sql.SQLException

Throws:

java.sql.SQLException

getPoolFactory

public JdbcPoolFactory getPoolFactory()

Returns:

the poolFactory

setPoolFactory

public void setPoolFactory(JdbcPoolFactory f)

Parameters:

f - the poolFactory to set