Module is.codion.common.db

Package is.codion.common.db.pool

Class AbstractConnectionPoolWrapper<T>

java.lang.Object

is.codion.common.db.pool.AbstractConnectionPoolWrapper<T>

Type Parameters:

T - the type representing the actual pool object

All Implemented Interfaces:

ConnectionPoolWrapper

public abstract class AbstractConnectionPoolWrapper<T>
extends Object
implements ConnectionPoolWrapper

A default base implementation of the ConnectionPool wrapper, handling the collection of statistics

Field Summary

Fields inherited from interface is.codion.common.db.pool.ConnectionPoolWrapper

DEFAULT_IDLE_TIMEOUT, DEFAULT_MAXIMUM_POOL_SIZE, DEFAULT_MINIMUM_POOL_SIZE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractConnectionPoolWrapper(ConnectionFactory connectionFactory, User user, DataSource poolDataSource)	Instantiates a new AbstractConnectionPool instance.

Method Summary

Modifier and Type	Method	Description
protected abstract int	available()
final Connection	connection(User user)	Fetches a connection from the pool.
protected abstract Connection	fetchConnection()	Fetches a connection from the underlying pool.
protected final T	getPool()
protected abstract int	inUse()
final boolean	isCollectCheckOutTimes()
final boolean	isCollectSnapshotStatistics()
final DataSource	poolDataSource()
final void	resetStatistics()	Resets the collected usage statistics
final void	setCollectCheckOutTimes(boolean collectCheckOutTimes)	Specifies whether to collect connection check out times.
final void	setCollectSnapshotStatistics(boolean collectSnapshotStatistics)	Specifies whether to collect usage statistics for a snapshot.
protected final void	setPool(T pool)
final ConnectionPoolStatistics	statistics(long since)	Retrives usage statistics for the connection pool since time since.
final User	user()
protected abstract int	waiting()

Methods inherited from class java.lang.Object

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

Methods inherited from interface is.codion.common.db.pool.ConnectionPoolWrapper

close, getCleanupInterval, getIdleConnectionTimeout, getMaximumCheckOutTime, getMaximumPoolSize, getMinimumPoolSize, setCleanupInterval, setIdleConnectionTimeout, setMaximumCheckOutTime, setMaximumPoolSize, setMinimumPoolSize

Constructor Details

AbstractConnectionPoolWrapper

protected AbstractConnectionPoolWrapper(ConnectionFactory connectionFactory,
 User user,
 DataSource poolDataSource)

Instantiates a new AbstractConnectionPool instance.

Parameters:

connectionFactory - the connection factory

user - the connection pool user

poolDataSource - the DataSource

Method Details

user

public final User user()

Specified by:

user in interface ConnectionPoolWrapper

Returns:

the user this connection pool is based on.

poolDataSource

public final DataSource poolDataSource()

Specified by:

poolDataSource in interface ConnectionPoolWrapper

Returns:

the DataSource used by this connection pool

connection

public final Connection connection(User user)
                            throws DatabaseException

Description copied from interface: ConnectionPoolWrapper

Fetches a connection from the pool. Close the connection to return it to the pool.

Specified by:

connection in interface ConnectionPoolWrapper

Parameters:

user - the user credentials

Returns:

a database connection retrieved from the pool

Throws:

DatabaseException - in case of an exception while fetching the connection

See Also:

• ConnectionPoolWrapper.setMaximumCheckOutTime(int)
• Connection.close()

resetStatistics

public final void resetStatistics()

Description copied from interface: ConnectionPoolWrapper

Resets the collected usage statistics

Specified by:

resetStatistics in interface ConnectionPoolWrapper

isCollectSnapshotStatistics

public final boolean isCollectSnapshotStatistics()

Specified by:

isCollectSnapshotStatistics in interface ConnectionPoolWrapper

Returns:

true if pool usage statistics for a snapshot should be collected.

See Also:

• ConnectionPoolWrapper.statistics(long)
• ConnectionPoolStatistics.snapshot()

setCollectSnapshotStatistics

public final void setCollectSnapshotStatistics(boolean collectSnapshotStatistics)

Description copied from interface: ConnectionPoolWrapper

Specifies whether to collect usage statistics for a snapshot.

Specified by:

setCollectSnapshotStatistics in interface ConnectionPoolWrapper

Parameters:

collectSnapshotStatistics - the value

See Also:

• ConnectionPoolWrapper.statistics(long)
• ConnectionPoolStatistics.snapshot()

isCollectCheckOutTimes

public final boolean isCollectCheckOutTimes()

Specified by:

isCollectCheckOutTimes in interface ConnectionPoolWrapper

Returns:

true if connection check out times should be collected.

See Also:

• ConnectionPoolWrapper.statistics(long)

setCollectCheckOutTimes

public final void setCollectCheckOutTimes(boolean collectCheckOutTimes)

Description copied from interface: ConnectionPoolWrapper

Specifies whether to collect connection check out times.

Specified by:

setCollectCheckOutTimes in interface ConnectionPoolWrapper

Parameters:

collectCheckOutTimes - the value

See Also:

• ConnectionPoolWrapper.statistics(long)

statistics

public final ConnectionPoolStatistics statistics(long since)

Description copied from interface: ConnectionPoolWrapper

Retrives usage statistics for the connection pool since time since.

Specified by:

statistics in interface ConnectionPoolWrapper

Parameters:

since - the time from which statistics should be retrieved

Returns:

connection pool usage statistics

fetchConnection

protected abstract Connection fetchConnection()
                                       throws SQLException

Fetches a connection from the underlying pool.

Returns:

a connection from the underlying pool

Throws:

SQLException - in case of an exception.

setPool

protected final void setPool(T pool)

Parameters:

pool - the underlying connection pool

getPool

protected final T getPool()

Returns:

the underlying pool object

available

protected abstract int available()

Returns:

the number of available connections in this pool

inUse

protected abstract int inUse()

Returns:

the number of connections in active use

waiting

protected abstract int waiting()

Returns:

the number of waiting connection requests