de.must.dataobj

Class ConnectionPool

java.lang.Object

de.must.dataobj.ConnectionPool

public class ConnectionPool
extends java.lang.Object

Connection pool. More exactly it is a pool of connection holders. Provides re-usage of temporarily privately used connections.

See Also:

ConnectionHolder

Constructor Summary

Constructors

Constructor and Description
ConnectionPool(ConnectionSpecification connectionSpecification) Constructs a new connection pool.

Method Summary

Modifier and Type	Method and Description
void	checkAndCleanUpPool() Cleans up the connection pool and removes no more valid connections or vacant connection more than defined maximum.
void	closeAllConnections() Closes all connections of the pool.
protected void	finalize()
ConnectionHolder	getPrivateConnectionHolder() Returns a for private use locked connection holder.
java.sql.Connection	recover(java.sql.Connection connection) Checks in pool whether this connection is cached and closed or broken, recovers and returns newly created connection if so.
void	removeAllExcept(java.sql.Connection connection) Removes all connection holder except the holder that holds the connection as specified.
void	reset() Resets the connection pool - sets the pool size to zero.
boolean	resetIfAnyConnectionIsBroken()
void	takeBack(java.sql.Connection connectionToGiveBack) Takes back a connection.
void	takeBack(ConnectionHolder connectionHolderToGiveBack) Takes back a connection holder.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionPool

public ConnectionPool(ConnectionSpecification connectionSpecification)

Constructs a new connection pool.

Parameters:

connectionSpecification - the specification how to create the connection

Method Detail

getPrivateConnectionHolder

public ConnectionHolder getPrivateConnectionHolder()

Returns a for private use locked connection holder.

Returns:

a for private use locked connection holder

recover

public java.sql.Connection recover(java.sql.Connection connection)

Checks in pool whether this connection is cached and closed or broken, recovers and returns newly created connection if so.

Parameters:

connection - the connection to check if closed or broken

Returns:

unmodified connection of OK or newly created connection if closed or broken

takeBack

public void takeBack(java.sql.Connection connectionToGiveBack)

Takes back a connection.

Parameters:

connectionToGiveBack - the connection to give back.

takeBack

public void takeBack(ConnectionHolder connectionHolderToGiveBack)

Takes back a connection holder.

Parameters:

connectionToGiveBack - the connection to give back.

removeAllExcept

public void removeAllExcept(java.sql.Connection connection)

Removes all connection holder except the holder that holds the connection as specified. Connection will be closed before remove.

Parameters:

connection - the connection to be kept

resetIfAnyConnectionIsBroken

public boolean resetIfAnyConnectionIsBroken()

checkAndCleanUpPool

public void checkAndCleanUpPool()

Cleans up the connection pool and removes no more valid connections or vacant connection more than defined maximum. Removed vacant connection will be closed before they are removed.

closeAllConnections

public void closeAllConnections()

Closes all connections of the pool.

reset

public void reset()

Resets the connection pool - sets the pool size to zero.

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable