Package com.zfabrik.impl.db.data

Class PoolingDataSource

java.lang.Object

com.zfabrik.impl.db.data.PoolingDataSource

All Implemented Interfaces:

Wrapper, CommonDataSource, DataSource

public class PoolingDataSource
extends Object
implements DataSource

A simple but effective data base connection pool. This pool manages a number of spare and a number of maximum connections. Connections that have errors will be closed. Connections will be forcibly closed after some expiration period (no stale connections)

Configuration properties:

maxInUseConnection

Maximum number of connections provided by this pool

maxSpareConnection

Maximum number of spare connections

exhaustWarningDelay

Delay to pass until warning for pool exhaustion (again)

connectionExpiration

Connections expire after this many milli-seconds

connectionMaxUse

Connections expire after they have been checked out this many times

transactionIsolation

If set, all connections provided will be set to this isolation level. Use the transaction isolation constants on Connection.

driverClass

Set this, if you want the pool to use a driver class rather than using connections from a data source. The latter is is recommended. See DataSourceResource on how to specify a data source class.

user

If configuring the pool via a driver class, this user name will be used to request new connections.

password

If configuring the pool via a driver class, this password will be used to request new connections.

password

If configuring the pool via a driver class, this password will be used to request new connections.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	PoolingDataSource.PoolMBean

Constructor Summary

Constructors

Constructor	Description
PoolingDataSource(IResourceHandle rh, String name)
PoolingDataSource(IResourceHandle rh, String name, DataSource ds)

Method Summary

Modifier and Type	Method	Description
void	destroy()
Connection	getConnection()
Connection	getConnection(String arg0, String arg1)
int	getLoginTimeout()
PrintWriter	getLogWriter()
Logger	getParentLogger()
boolean	isWrapperFor(Class<?> arg0)
void	setConnectionExpiration(int ex)	Change the number of milliseconds a connection will be kept open at least before it will be considered stale by the pool and closed at the next opportunity.
void	setConnectionMaxUse(int connectionMaxUse)	Change the number of times a connection from this pool may be used before it will be dumped
void	setDriverClass(String driverClass)
void	setExhaustWarningDelay(int exhaustWarningDelay)	Delay for exhaust warnings before warning again.
void	setLoginTimeout(int arg0)
void	setLogWriter(PrintWriter out)
void	setMaxInUseConnections(int mc)	Change the number of connections to be provided by this pool at most.
void	setMaxSpareConnections(int mc)	Change the number of spare connections to be held open by this pool.
void	setPassword(String password)
void	setTransactionIsolation(int transactionIsolation)
void	setUrl(String url)
void	setUser(String user)
<T> T	unwrap(Class<T> arg0)

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.sql.CommonDataSource

createShardingKeyBuilder

Methods inherited from interface javax.sql.DataSource

createConnectionBuilder

Constructor Details

PoolingDataSource

public PoolingDataSource(IResourceHandle rh,
 String name,
 DataSource ds)

PoolingDataSource

public PoolingDataSource(IResourceHandle rh,
 String name)

Method Details

destroy

public void destroy()

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface DataSource

Throws:

SQLException

getConnection

public Connection getConnection(String arg0,
 String arg1)
                         throws SQLException

Specified by:

getConnection in interface DataSource

Throws:

SQLException

getLogWriter

public PrintWriter getLogWriter()
                         throws SQLException

Specified by:

getLogWriter in interface CommonDataSource

Specified by:

getLogWriter in interface DataSource

Throws:

SQLException

getLoginTimeout

public int getLoginTimeout()
                    throws SQLException

Specified by:

getLoginTimeout in interface CommonDataSource

Specified by:

getLoginTimeout in interface DataSource

Throws:

SQLException

setLogWriter

public void setLogWriter(PrintWriter out)
                  throws SQLException

Specified by:

setLogWriter in interface CommonDataSource

Specified by:

setLogWriter in interface DataSource

Throws:

SQLException

setLoginTimeout

public void setLoginTimeout(int arg0)
                     throws SQLException

Specified by:

setLoginTimeout in interface CommonDataSource

Specified by:

setLoginTimeout in interface DataSource

Throws:

SQLException

isWrapperFor

public boolean isWrapperFor(Class<?> arg0)
                     throws SQLException

Specified by:

isWrapperFor in interface Wrapper

Throws:

SQLException

unwrap

public <T> T unwrap(Class<T> arg0)
             throws SQLException

Specified by:

unwrap in interface Wrapper

Throws:

SQLException

setUrl

public void setUrl(String url)

setUser

public void setUser(String user)

setTransactionIsolation

public void setTransactionIsolation(int transactionIsolation)

setPassword

public void setPassword(String password)

setDriverClass

public void setDriverClass(String driverClass)

getParentLogger

public Logger getParentLogger()
                       throws SQLFeatureNotSupportedException

Specified by:

getParentLogger in interface CommonDataSource

Throws:

SQLFeatureNotSupportedException

setMaxInUseConnections

public void setMaxInUseConnections(int mc)

Change the number of connections to be provided by this pool at most. Request that would exceed this number have to wait for connections to return. This setting can be changed at runtime.

Parameters:

mc -

setMaxSpareConnections

public void setMaxSpareConnections(int mc)

Change the number of spare connections to be held open by this pool. Can be changed at runtime and the pool will adapt to the new setting

Parameters:

mc -

setConnectionMaxUse

public void setConnectionMaxUse(int connectionMaxUse)

Change the number of times a connection from this pool may be used before it will be dumped

setConnectionExpiration

public void setConnectionExpiration(int ex)

Change the number of milliseconds a connection will be kept open at least before it will be considered stale by the pool and closed at the next opportunity.

Parameters:

mc -

setExhaustWarningDelay

public void setExhaustWarningDelay(int exhaustWarningDelay)

Delay for exhaust warnings before warning again. Set to <=0 to never warn