org.jminor.common.db.pool

Class AbstractConnectionPool<T>

java.lang.Object

org.jminor.common.db.pool.AbstractConnectionPool<T>

Type Parameters:

T - the type representing the actual pool object

All Implemented Interfaces:

ConnectionPool

public abstract class AbstractConnectionPool<T>
extends java.lang.Object
implements ConnectionPool

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

Nested Class Summary

Nested classes/interfaces inherited from interface org.jminor.common.db.pool.ConnectionPool

ConnectionPool.Counter

Constructor Summary

Constructors

Constructor and Description
AbstractConnectionPool(Database database, User user)

Method Summary

Modifier and Type	Method and Description
protected ConnectionPool.Counter	getCounter()
Database	getDatabase()
protected abstract int	getInUse()
protected T	getPool()
protected abstract int	getSize()
ConnectionPoolStatistics	getStatistics(long since) Retrives usage statistics for the connection pool since time since.
User	getUser()
protected abstract int	getWaiting()
protected java.lang.Object	handleInvocation(Database database, User user, javax.sql.DataSource dataSource, java.lang.reflect.Method dataSourceMethod, java.lang.Object[] dataSourceArgs) Handles a method invocation for this pool, counting created and destroyed connections.
boolean	isCollectFineGrainedStatistics()
void	resetStatistics() Resets the collected usage statistics
void	setCollectFineGrainedStatistics(boolean collectFineGrainedStatistics) Specifies whether or not fine grained usage statistics should be collected.
protected void	setPool(T pool)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jminor.common.db.pool.ConnectionPool

close, getCleanupInterval, getConnection, getConnectionTimeout, getMaximumCheckOutTime, getMaximumPoolSize, getMaximumRetryWaitPeriod, getMinimumPoolSize, getNewConnectionThreshold, returnConnection, setCleanupInterval, setConnectionTimeout, setMaximumCheckOutTime, setMaximumPoolSize, setMaximumRetryWaitPeriod, setMinimumPoolSize, setNewConnectionThreshold

Constructor Detail

AbstractConnectionPool

public AbstractConnectionPool(Database database,
                              User user)

Parameters:

database - the underlying database

user - the connection pool user

Method Detail

getDatabase

public Database getDatabase()

Specified by:

getDatabase in interface ConnectionPool

Returns:

the underlying database

getUser

public final User getUser()

Specified by:

getUser in interface ConnectionPool

Returns:

the user this connection pool is based on.

resetStatistics

public final void resetStatistics()

Resets the collected usage statistics

Specified by:

resetStatistics in interface ConnectionPool

isCollectFineGrainedStatistics

public final boolean isCollectFineGrainedStatistics()

Specified by:

isCollectFineGrainedStatistics in interface ConnectionPool

Returns:

true if fine grained pool usage statistics should be collected.

See Also:

ConnectionPool.getStatistics(long), ConnectionPoolStatistics.getFineGrainedStatistics()

setCollectFineGrainedStatistics

public final void setCollectFineGrainedStatistics(boolean collectFineGrainedStatistics)

Specifies whether or not fine grained usage statistics should be collected.

Specified by:

setCollectFineGrainedStatistics in interface ConnectionPool

Parameters:

collectFineGrainedStatistics - the value

See Also:

ConnectionPool.getStatistics(long), ConnectionPoolStatistics.getFineGrainedStatistics()

getStatistics

public final ConnectionPoolStatistics getStatistics(long since)

Retrives usage statistics for the connection pool since time since.

Specified by:

getStatistics in interface ConnectionPool

Parameters:

since - the time from which statistics should be retrieved

Returns:

connection pool usage statistics

setPool

protected void setPool(T pool)

Parameters:

pool - the underlying connection pool

getPool

protected T getPool()

Returns:

the underlying pool object

getSize

protected abstract int getSize()

Returns:

the number of connections in this pool

getInUse

protected abstract int getInUse()

Returns:

the number of connections in active use

getWaiting

protected abstract int getWaiting()

Returns:

the number of waiting connections

getCounter

protected final ConnectionPool.Counter getCounter()

Returns:

the counter

handleInvocation

protected final java.lang.Object handleInvocation(Database database,
                                                  User user,
                                                  javax.sql.DataSource dataSource,
                                                  java.lang.reflect.Method dataSourceMethod,
                                                  java.lang.Object[] dataSourceArgs)
                                           throws DatabaseException,
                                                  java.lang.IllegalAccessException,
                                                  java.lang.reflect.InvocationTargetException

Handles a method invocation for this pool, counting created and destroyed connections.

Parameters:

database - the database

user - the user

dataSource - the data source

dataSourceMethod - the data source method being called

dataSourceArgs - the data source method arguments

Returns:

the method return value

Throws:

DatabaseException - in case of a an exception

java.lang.IllegalAccessException - in case of illegal access

java.lang.reflect.InvocationTargetException - in case of invocation exception