Package com.adaptris.core.jdbc

Class JdbcPooledConnectionImpl

java.lang.Object

com.adaptris.core.AdaptrisConnectionImp

com.adaptris.core.AllowsRetriesConnection

com.adaptris.core.jdbc.DatabaseConnection

com.adaptris.core.jdbc.JdbcPooledConnectionImpl

All Implemented Interfaces:

AdaptrisComponent, AdaptrisConnection, ComponentLifecycle, ComponentLifecycleExtension, StateManagedComponent

Direct Known Subclasses:

AdvancedJdbcPooledConnection, JdbcPooledConnection, PluggableJdbcPooledConnection

public abstract class JdbcPooledConnectionImpl
extends DatabaseConnection

Field Summary

Fields

Modifier and Type	Field	Description
protected PooledDataSource	connectionPool

Fields inherited from class com.adaptris.core.AdaptrisConnectionImp

log

Constructor Summary

Constructors

Constructor	Description
JdbcPooledConnectionImpl()

Method Summary

Modifier and Type	Method	Description
javax.sql.DataSource	asDataSource()	Expose this DatabaseConnection as a DataSource
protected void	closeDatabaseConnection()	Initialise the underlying database connection.
protected abstract PooledDataSource	createPool()
protected java.lang.String	getConnectionName()	Returns a name for this connection for logging purposes.
java.lang.String	getConnectUrl()
protected void	initialiseDatabaseConnection()	Initialise the underlying database connection.
protected java.sql.Connection	makeConnection()	Make the connection.
void	setConnectUrl(java.lang.String connectUrl)
protected void	startDatabaseConnection()	Initialise the underlying database connection.
protected void	stopDatabaseConnection()	Initialise the underlying database connection.

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

alwaysValidateConnection, autoCommit, checkInternalState, closeConnection, connect, connectionProperties, debugMode, equals, getAlwaysValidateConnection, getAutoCommit, getConnectionProperties, getDebugMode, getDriverImp, getPassword, getUsername, hashCode, initConnection, loadDriverClass, prepareConnection, setAlwaysValidateConnection, setAutoCommit, setConnectionProperties, setDebugMode, setDriverImp, setPassword, 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, getUniqueId, getWorkersFirstOnShutdown, init, prepare, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, retrieveConnection, retrieveExceptionListeners, retrieveMessageConsumers, retrieveMessageProducers, setConnectionErrorHandler, setUniqueId, setWorkersFirstOnShutdown, start, stop, workersFirstOnShutdown

Methods inherited from class java.lang.Object

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

Field Detail

connectionPool

protected transient PooledDataSource connectionPool

Constructor Detail

JdbcPooledConnectionImpl

public JdbcPooledConnectionImpl()

Method Detail

makeConnection

protected java.sql.Connection makeConnection()
                                      throws java.sql.SQLException

Description copied from class: DatabaseConnection

Make the connection.

This abstract method should be implemented by concrete sub-classes to make or check the current connection to the Jdbc source.

Specified by:

makeConnection in class DatabaseConnection

Returns:

a java.sql.Connection

Throws:

java.sql.SQLException - if the connection could not be made.

See Also:

DatabaseConnection.connect()

initialiseDatabaseConnection

protected void initialiseDatabaseConnection()
                                     throws CoreException

Description copied from class: DatabaseConnection

Initialise the underlying database connection.

This abstract method should be implemented by concrete sub-classes to initialise any components other than the DriverManager.

Specified by:

initialiseDatabaseConnection in class DatabaseConnection

Throws:

CoreException - wrapping any underlying exception.

startDatabaseConnection

protected void startDatabaseConnection()
                                throws CoreException

Description copied from class: DatabaseConnection

Initialise the underlying database connection.

This abstract method should be implemented by concrete sub-classes to initialise any components other than the DriverManager.

Specified by:

startDatabaseConnection in class DatabaseConnection

Throws:

CoreException - wrapping any underlying exception.

stopDatabaseConnection

protected void stopDatabaseConnection()

Description copied from class: DatabaseConnection

Initialise the underlying database connection.

This abstract method should be implemented by concrete sub-classes to stop any components other than the DriverManager.

Specified by:

stopDatabaseConnection in class DatabaseConnection

closeDatabaseConnection

protected void closeDatabaseConnection()

Description copied from class: DatabaseConnection

Initialise the underlying database connection.

This abstract method should be implemented by concrete sub-classes to close any components.

Specified by:

closeDatabaseConnection in class DatabaseConnection

createPool

protected abstract PooledDataSource createPool()
                                        throws java.lang.Exception

Throws:

java.lang.Exception

asDataSource

public javax.sql.DataSource asDataSource()
                                  throws java.sql.SQLException

Description copied from class: DatabaseConnection

Expose this DatabaseConnection as a DataSource

Overrides:

asDataSource in class DatabaseConnection

Returns:

a DataSource implementation

Throws:

java.sql.SQLException

See Also:

DataSource

getConnectionName

protected java.lang.String getConnectionName()

Description copied from class: DatabaseConnection

Returns a name for this connection for logging purposes.

Specified by:

getConnectionName in class DatabaseConnection

Returns:

a name for this connection for logging purposes

getConnectUrl

public java.lang.String getConnectUrl()

setConnectUrl

public void setConnectUrl(java.lang.String connectUrl)