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
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description javax.sql.DataSource
asDataSource()
Expose this DatabaseConnection as a DataSourceprotected 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
-
-
-
-
Field Detail
-
connectionPool
protected transient PooledDataSource connectionPool
-
-
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 classDatabaseConnection
- 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 classDatabaseConnection
- 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 classDatabaseConnection
- 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 classDatabaseConnection
-
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 classDatabaseConnection
-
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 classDatabaseConnection
- 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 classDatabaseConnection
- Returns:
- a name for this connection for logging purposes
-
getConnectUrl
public java.lang.String getConnectUrl()
-
setConnectUrl
public void setConnectUrl(java.lang.String connectUrl)
-
-