Package overit.geocall.sql

Class ElasticConnectionPool

java.lang.Object

overit.geocall.sql.ConnectionPool<ElasticPooledConnection>

overit.geocall.sql.ElasticConnectionPool

public class ElasticConnectionPool
extends ConnectionPool<ElasticPooledConnection>

Database connection pool based on the apache commons pool implementation. In particular this pool allows you to manage a variable number of connections to the database, opening new ones as needed.

It is possible to configure a maximum number of open connections, but also a minimum number to ensure that open sockets are always available to the db.

The pool uses a mechanism for automatically removing unused connections to avoid having to keep many sockets open unnecessarily.

Field Summary

Fields inherited from class overit.geocall.sql.ConnectionPool

_dbom, _dbSetupStatments, _maxQueryRows, _name, _ph, _qh, cross, encryptionKey, TYPE_DATASOURCE, TYPE_ELASTIC, TYPE_STANDARD

Constructor Summary

Constructors

Constructor	Description
ElasticConnectionPool(PooledConnectionConfiguration config)	Creates a new instance of an ElasticConnectionPool given the database references and the number of the minimum and maximum available connections.

Method Summary

Modifier and Type	Method	Description
void	disconnect(long id)	Close the connection identified by a specific id value
void	dispose()	Disposes the ConnectionPool.
ElasticPooledConnection	getConnection(String activity)	Extracts a Connection from the pool
List<PooledConnectionInfo>	getConnectionInfo()	Returns the informations about the connections of the pool
Date	getDate()	Returns the Date of the max number of utilized connections
int	getMax()	Returns the max number of utilized connections
int	locked()	Returns the number of locked connections, i.e. the connections that are currently used by the application
void	releaseConnection(ElasticPooledConnection conn)	Releases a Connection previously extracted with getConnection()
void	resetMax()	Resets the max number of utilized connections
int	size()	Returns the size of the ConnectionPool

Methods inherited from class overit.geocall.sql.ConnectionPool

getCross, getDBObjectMap, getDBType, getEncryptionKey, getHistory, getMaxQueryRows, getName, getParameters, getQueryHistory, setCross, setDBType, setEncryptionKey

Methods inherited from class java.lang.Object

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

Constructor Details

ElasticConnectionPool

public ElasticConnectionPool(PooledConnectionConfiguration config)
                      throws Exception

Creates a new instance of an ElasticConnectionPool given the database references and the number of the minimum and maximum available connections.

Parameters:

config - instance used to retrieve the pool's configuration parameters

Throws:

Exception - in case of some problem during the pool's initialization

Method Details

getMax

public int getMax()

Returns the max number of utilized connections

Returns:

The max number of utilized connections

getDate

public Date getDate()

Returns the Date of the max number of utilized connections

Returns:

The Date of the max number of utilized connections

resetMax

public void resetMax()

Resets the max number of utilized connections

getConnection

public ElasticPooledConnection getConnection(String activity)
                                      throws SQLException

Description copied from class: ConnectionPool

Extracts a Connection from the pool

Specified by:

getConnection in class ConnectionPool<ElasticPooledConnection>

Parameters:

activity - The motivation / operation for which the extract request originates

Returns:

The Connection extracted

Throws:

SQLException - If there is an error during the extraction, an SQLException will be raised

releaseConnection

public void releaseConnection(ElasticPooledConnection conn)
                       throws SQLException

Description copied from class: ConnectionPool

Releases a Connection previously extracted with getConnection()

Specified by:

releaseConnection in class ConnectionPool<ElasticPooledConnection>

Parameters:

conn - The Connection to release

Throws:

SQLException - If there is an error during the release, an SQLException will be raised

getConnectionInfo

public List<PooledConnectionInfo> getConnectionInfo()

Description copied from class: ConnectionPool

Returns the informations about the connections of the pool

Specified by:

getConnectionInfo in class ConnectionPool<ElasticPooledConnection>

Returns:

The List that contains the informations about the connections

locked

public int locked()

Description copied from class: ConnectionPool

Returns the number of locked connections, i.e. the connections that are currently used by the application

Specified by:

locked in class ConnectionPool<ElasticPooledConnection>

Returns:

The number of currently locked connections

size

public int size()

Description copied from class: ConnectionPool

Returns the size of the ConnectionPool

Specified by:

size in class ConnectionPool<ElasticPooledConnection>

Returns:

The number of Connection of this instance of ConnectionPool

disconnect

public void disconnect(long id)

Close the connection identified by a specific id value

Parameters:

id - the connection identifier

dispose

public void dispose()

Description copied from class: ConnectionPool

Disposes the ConnectionPool. Use this method when the object is no longer needed, for example when the application is closed

Overrides:

dispose in class ConnectionPool<ElasticPooledConnection>