winstone.jndi.resourceFactories

Class WinstoneDataSource

java.lang.Object

winstone.jndi.resourceFactories.WinstoneDataSource

All Implemented Interfaces:

Runnable, Wrapper, CommonDataSource, DataSource

public class WinstoneDataSource
extends Object
implements DataSource, Runnable

Implements a JDBC 2.0 pooling datasource. This is meant to act as a wrapper around a JDBC 1.0 driver, just providing the pool management functions. Supports keep alives, and check-connection-before-get options, as well as normal reclaimable pool management options like maxIdle, maxConnections and startConnections. Additionally it supports poll-retry on full, which means the getConnection call will block and retry after a certain period when the pool is maxed out (good for high load conditions). This class was originally drawn from the generator-runtime servlet framework and modified to make it more JDBC-API only compliant.

Version:

$Id: WinstoneDataSource.java,v 1.8 2006/11/07 01:30:39 rickknowles Exp $

Author:

Rick Knowles

Field Summary

Fields

Modifier and Type	Field and Description
static WinstoneResourceBundle	DS_RESOURCES

Constructor Summary

Constructors

Constructor and Description
WinstoneDataSource(String name, Map args, ClassLoader loader) Main constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() Close this pool - probably because we will want to re-init the pool
protected void	executeKeepAlive(Connection connection)
protected void	executeKeepAliveOnUnused() Executes keep alive for each of the connections in the supplied pool
Connection	getConnection()
protected Connection	getConnection(int retriesAllowed) Get a read-write connection - preferably from the pool, but fresh if needed
Connection	getConnection(String username, String password) Gets a connection with a specific username/password.
int	getLoginTimeout()
PrintWriter	getLogWriter()
Logger	getParentLogger()
boolean	isWrapperFor(Class<?> iface)
protected void	killPooledConnections(List pool, int maxIdleCount) Iterates through a list and kills off unused connections until we reach the minimum idle count for that pool.
protected Connection	makeNewRealConnection(List pool) This makes a new rw connection.
void	run() Clean up and keep-alive thread.
void	setLoginTimeout(int timeout)
void	setLogWriter(PrintWriter writer)
String	toString()
<T> T	unwrap(Class<T> iface)

Methods inherited from class java.lang.Object

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

Field Detail

DS_RESOURCES

public static final WinstoneResourceBundle DS_RESOURCES

Constructor Detail

WinstoneDataSource

public WinstoneDataSource(String name,
                  Map args,
                  ClassLoader loader)

Main constructor. Basically just calls the init method

Method Detail

destroy

public void destroy()

Close this pool - probably because we will want to re-init the pool

getConnection

public Connection getConnection(String username,
                       String password)
                         throws SQLException

Gets a connection with a specific username/password. These are not pooled.

Specified by:

getConnection in interface DataSource

Throws:

SQLException

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface DataSource

Throws:

SQLException

getConnection

protected Connection getConnection(int retriesAllowed)
                            throws SQLException

Get a read-write connection - preferably from the pool, but fresh if needed

Throws:

SQLException

getLoginTimeout

public int getLoginTimeout()

Specified by:

getLoginTimeout in interface CommonDataSource

getLogWriter

public PrintWriter getLogWriter()

Specified by:

getLogWriter in interface CommonDataSource

setLoginTimeout

public void setLoginTimeout(int timeout)

Specified by:

setLoginTimeout in interface CommonDataSource

setLogWriter

public void setLogWriter(PrintWriter writer)

Specified by:

setLogWriter in interface CommonDataSource

run

public void run()

Clean up and keep-alive thread. Note - this needs a lot more attention to the semaphore use during keepAlive etc

Specified by:

run in interface Runnable

executeKeepAliveOnUnused

protected void executeKeepAliveOnUnused()

Executes keep alive for each of the connections in the supplied pool

executeKeepAlive

protected void executeKeepAlive(Connection connection)
                         throws SQLException

Throws:

SQLException

makeNewRealConnection

protected Connection makeNewRealConnection(List pool)
                                    throws SQLException

This makes a new rw connection. It assumes that the synchronization has taken place in the calling code, so is unsafe for use outside this class.

Throws:

SQLException

killPooledConnections

protected void killPooledConnections(List pool,
                         int maxIdleCount)

Iterates through a list and kills off unused connections until we reach the minimum idle count for that pool.

getParentLogger

public Logger getParentLogger()
                       throws SQLFeatureNotSupportedException

Specified by:

getParentLogger in interface CommonDataSource

Throws:

SQLFeatureNotSupportedException

toString

public String toString()

Overrides:

toString in class Object

unwrap

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

Specified by:

unwrap in interface Wrapper

Throws:

SQLException

isWrapperFor

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

Specified by:

isWrapperFor in interface Wrapper

Throws:

SQLException