Class ConnectionPool
- java.lang.Object
-
- org.eclipse.persistence.sessions.server.ConnectionPool
-
- Direct Known Subclasses:
ExternalConnectionPool,ReadConnectionPool
public class ConnectionPool extends Object
Purpose: Used to specify how connection should be pooled in a server session.
- See Also:
ServerSession
-
-
Field Summary
Fields Modifier and Type Field Description static longDEAD_CHECK_TIMEstatic intINITIAL_CONNECTIONSstatic intMAX_CONNECTIONSstatic intMIN_CONNECTIONSstatic intWAIT_TIMEOUT
-
Constructor Summary
Constructors Constructor Description ConnectionPool()PUBLIC: A connection pool is used to specify how connection should be pooled in a server session.ConnectionPool(String name, Login login, int initialNumberOfConnections, int minNumberOfConnections, int maxNumberOfConnections, ServerSession owner)PUBLIC: A connection pool is used to specify how connection should be pooled in a server session.ConnectionPool(String name, Login login, int minNumberOfConnections, int maxNumberOfConnections, ServerSession owner)PUBLIC: A connection pool is used to specify how connection should be pooled in a server session.ConnectionPool(String name, Login login, ServerSession owner)PUBLIC: A connection pool is used to specify how connection should be pooled in a server session.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.eclipse.persistence.internal.databaseaccess.AccessoracquireConnection()INTERNAL: Wait until a connection is available and allocate the connection for the client.booleanaddFailoverConnectionPool(String poolName)PUBLIC: Add the connection pool to used if this pool database goes down.org.eclipse.persistence.internal.databaseaccess.Accessorfailover()INTERNAL: The connection pool is dead fail over to the fail-over pool.List<org.eclipse.persistence.internal.databaseaccess.Accessor>getConnectionsAvailable()INTERNAL: returns the connections currently available for use in the poolList<String>getFailoverConnectionPools()PUBLIC: Return the list of connection pools to used if this pool database goes down.intgetInitialNumberOfConnections()PUBLIC: Return the initial number of connections allowed.LogingetLogin()PUBLIC: Return the login used to create connections.intgetMaxNumberOfConnections()PUBLIC: Return the maximum number of connections allowed.intgetMinNumberOfConnections()PUBLIC: Return the minimum number of connections.StringgetName()PUBLIC: Return the name of this pool.intgetTotalNumberOfConnections()INTERNAL: Return the total number of connections currently in use.intgetWaitTimeout()PUBLIC: Return the time in milliseconds to wait for a available connection.booleanhasConnectionAvailable()INTERNAL: Wait until a connection is avaiable and allocate the connection for the client.booleanisConnected()INTERNAL: Return if this pool has been connected to the database.booleanisDead()ADVANCED: Return if the connection pool's database is down, and failover should be used.booleanisThereConflictBetweenLoginAndType()INTERNAL: Checks for a conflict between pool's type and pool's loginvoidreleaseConnection(org.eclipse.persistence.internal.databaseaccess.Accessor connection)INTERNAL: Add the connection as single that a new connection is available.voidresetConnections()INTERNAL: Reset the connections on shutDown and when the pool is started.voidsetCheckConnections()INTERNAL: This method is called to indicate that all available connections should be checked.voidsetFailoverConnectionPools(List<String> failoverConnectionPools)PUBLIC: Set the list of connection pools to used if this pool database goes down.voidsetInitialNumberOfConnections(int initialNumberOfConnections)PUBLIC: Set the initial number of connections allowed.voidsetIsConnected(boolean isConnected)INTERNAL: Set if this pool has been connected to the database.voidsetIsDead(boolean isDead)ADVANCED: Set if the connection pool's database is down, and failover should be used.voidsetLogin(Login login)PUBLIC: Set the login used to create connections.voidsetMaxNumberOfConnections(int maxNumberOfConnections)PUBLIC: Set the maximum number of connections allowed.voidsetMinNumberOfConnections(int minNumberOfConnections)PUBLIC: Set the minimum number of connections.voidsetName(String name)PUBLIC: Set the name of this pool.voidsetWaitTimeout(int waitTimeout)PUBLIC: Set the time in milliseconds to wait for an available connection.voidshutDown()INTERNAL: Disconnect all connections.voidstartUp()INTERNAL: Allocate the minimum connections.StringtoString()INTERNAL: return a string representation of this connection pool
-
-
-
Field Detail
-
DEAD_CHECK_TIME
public static final long DEAD_CHECK_TIME
- See Also:
- Constant Field Values
-
MAX_CONNECTIONS
public static final int MAX_CONNECTIONS
- See Also:
- Constant Field Values
-
MIN_CONNECTIONS
public static final int MIN_CONNECTIONS
- See Also:
- Constant Field Values
-
INITIAL_CONNECTIONS
public static final int INITIAL_CONNECTIONS
- See Also:
- Constant Field Values
-
WAIT_TIMEOUT
public static final int WAIT_TIMEOUT
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ConnectionPool
public ConnectionPool()
PUBLIC: A connection pool is used to specify how connection should be pooled in a server session.
-
ConnectionPool
public ConnectionPool(String name, Login login, ServerSession owner)
PUBLIC: A connection pool is used to specify how connection should be pooled in a server session.
-
ConnectionPool
public ConnectionPool(String name, Login login, int minNumberOfConnections, int maxNumberOfConnections, ServerSession owner)
PUBLIC: A connection pool is used to specify how connection should be pooled in a server session.
-
ConnectionPool
public ConnectionPool(String name, Login login, int initialNumberOfConnections, int minNumberOfConnections, int maxNumberOfConnections, ServerSession owner)
PUBLIC: A connection pool is used to specify how connection should be pooled in a server session.
-
-
Method Detail
-
failover
public org.eclipse.persistence.internal.databaseaccess.Accessor failover()
INTERNAL: The connection pool is dead fail over to the fail-over pool.
-
acquireConnection
public org.eclipse.persistence.internal.databaseaccess.Accessor acquireConnection() throws ConcurrencyExceptionINTERNAL: Wait until a connection is available and allocate the connection for the client.- Throws:
ConcurrencyException
-
getConnectionsAvailable
public List<org.eclipse.persistence.internal.databaseaccess.Accessor> getConnectionsAvailable()
INTERNAL: returns the connections currently available for use in the pool
-
getLogin
public Login getLogin()
PUBLIC: Return the login used to create connections.
-
getMaxNumberOfConnections
public int getMaxNumberOfConnections()
PUBLIC: Return the maximum number of connections allowed. If all connections are in use, a new connection will be created until the maximum size is reach. Only the minimum number of connections will be pooled, if the pool is between the min and max size the connection will be disconnected when returned to the pool. Typically it is desirable to have the min and max connections the same to avoid connects and disconnects. When the max is reached clients must wait for a connection to become available.
-
getMinNumberOfConnections
public int getMinNumberOfConnections()
PUBLIC: Return the minimum number of connections. If all connections are in use, a new connection will be created until the maximum size is reach. Only the minimum number of connections will be pooled, if the pool is between the min and max size the connection will be disconnected when returned to the pool. Typically it is desirable to have the min and max connections the same to avoid connects and disconnects.
-
getName
public String getName()
PUBLIC: Return the name of this pool. Pools are identified by name to allow multiple connection pools.
-
getTotalNumberOfConnections
public int getTotalNumberOfConnections()
INTERNAL: Return the total number of connections currently in use.
-
hasConnectionAvailable
public boolean hasConnectionAvailable()
INTERNAL: Wait until a connection is avaiable and allocate the connection for the client.
-
isConnected
public boolean isConnected()
INTERNAL: Return if this pool has been connected to the database.
-
isThereConflictBetweenLoginAndType
public boolean isThereConflictBetweenLoginAndType()
INTERNAL: Checks for a conflict between pool's type and pool's login
-
releaseConnection
public void releaseConnection(org.eclipse.persistence.internal.databaseaccess.Accessor connection) throws DatabaseExceptionINTERNAL: Add the connection as single that a new connection is available.- Throws:
DatabaseException
-
resetConnections
public void resetConnections()
INTERNAL: Reset the connections on shutDown and when the pool is started.
-
setCheckConnections
public void setCheckConnections()
INTERNAL: This method is called to indicate that all available connections should be checked.
-
setIsConnected
public void setIsConnected(boolean isConnected)
INTERNAL: Set if this pool has been connected to the database.
-
setLogin
public void setLogin(Login login)
PUBLIC: Set the login used to create connections.
-
getInitialNumberOfConnections
public int getInitialNumberOfConnections()
PUBLIC: Return the initial number of connections allowed. This is the number of connections connected on startup.
-
setInitialNumberOfConnections
public void setInitialNumberOfConnections(int initialNumberOfConnections)
PUBLIC: Set the initial number of connections allowed. This is the number of connections connected on startup. The default is 1.
-
setMaxNumberOfConnections
public void setMaxNumberOfConnections(int maxNumberOfConnections)
PUBLIC: Set the maximum number of connections allowed. If all connections are in use, a new connection will be created until the maximum size is reach. Only the minimum number of connections will be pooled, if the pool is between the min and max size the connection will be disconnected when returned to the pool. Typically it is desirable to have the min and max connections the same to avoid connects and disconnects. When the max is reached clients must wait for a connection to become available. The default is 32.
-
setMinNumberOfConnections
public void setMinNumberOfConnections(int minNumberOfConnections)
PUBLIC: Set the minimum number of connections. If all connections are in use, a new connection will be created until the maximum size is reach. Only the minimum number of connections will be pooled, if the pool is between the min and max size the connection will be disconnected when returned to the pool. Typically it is desirable to have the min and max connections the same to avoid connects and disconnects. The default is 32.
-
setName
public void setName(String name)
PUBLIC: Set the name of this pool. Pools are identified by name to allow multiple connection pools.
-
shutDown
public void shutDown()
INTERNAL: Disconnect all connections.
-
startUp
public void startUp()
INTERNAL: Allocate the minimum connections.
-
toString
public String toString()
INTERNAL: return a string representation of this connection pool
-
getWaitTimeout
public int getWaitTimeout()
PUBLIC: Return the time in milliseconds to wait for a available connection. If the wait time is exceeded and exception will occur. The default is 180000 or 3 minutes. A value of 0 means wait forever.
-
setWaitTimeout
public void setWaitTimeout(int waitTimeout)
PUBLIC: Set the time in milliseconds to wait for an available connection. If the wait time is exceeded an exception will occur. The default is 180000 or 3 minutes. A value of 0 means wait forever.
-
isDead
public boolean isDead()
ADVANCED: Return if the connection pool's database is down, and failover should be used.
-
setIsDead
public void setIsDead(boolean isDead)
ADVANCED: Set if the connection pool's database is down, and failover should be used.
-
getFailoverConnectionPools
public List<String> getFailoverConnectionPools()
PUBLIC: Return the list of connection pools to used if this pool database goes down. The failover pools should be a clustered, replicated or backuped database.
-
setFailoverConnectionPools
public void setFailoverConnectionPools(List<String> failoverConnectionPools)
PUBLIC: Set the list of connection pools to used if this pool database goes down. The failover pools should be a clustered, replicated or backuped database.
-
addFailoverConnectionPool
public boolean addFailoverConnectionPool(String poolName)
PUBLIC: Add the connection pool to used if this pool database goes down. The failover pools should be a clustered, replicated or backuped database.
-
-