Package com.adaptris.jdbc.connection

Class FailoverDataSource

java.lang.Object

com.adaptris.jdbc.connection.FailoverDataSource

All Implemented Interfaces:

Wrapper, CommonDataSource, DataSource

public class FailoverDataSource
extends Object
implements DataSource

Datasource that has a connection capable of failover to an alternate database.

Because of we want to failover to an alternate database, the implementation of getConnection(String username, String password) simply discards the username and password and relies on the configuration that was supplied when constructing this class. This is the desired behaviour.

The underlying pool implementation is a org.apache.commons.pool.impl.GenericObjectPool. The default size of the pool is 10 with a wait time of 20seconds. If the pool is exhausted, then a NoSuchElementException will be thrown after the wait time.

See Also:

• DataSource
• FailoverConnection
• FailoverConfig

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	FailoverDataSource.ConnectionProxy	This class proxies the underlying FailoverConnection class.
protected class	FailoverDataSource.PoolAttendant	This class is reponsible for creating swimmers who swim in the Datasource Pool.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	logR
static final String	POOL_MAX_SIZE	Resource Key for the maximum size of the pool.
static final String	POOL_TIME_TO_WAIT	Resource Key for the time to wait for an available connection.

Constructor Summary

Constructors

Constructor	Description
FailoverDataSource(Properties p)

Method Summary

Modifier and Type	Method	Description
protected FailoverConfig	config()
protected void	destroy()
Connection	getConnection()	Get the configured connection.
Connection	getConnection(String username, String password)	Get the configured connection.
int	getLoginTimeout()
PrintWriter	getLogWriter()
Logger	getParentLogger()
boolean	isWrapperFor(Class<?> iface)
protected int	maxPoolSize()
protected void	overrideObjectPool(org.apache.commons.pool.impl.GenericObjectPool p)
void	setLoginTimeout(int loginTimeout)
void	setLogWriter(PrintWriter logWriter)
protected long	timeToWait()
<T> T	unwrap(Class<T> iface)
protected static SQLClientInfoException	wrapSQLClientInfoException(Exception e)
protected static SQLException	wrapSQLException(Exception e)

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

Field Details

POOL_MAX_SIZE

public static final String POOL_MAX_SIZE

Resource Key for the maximum size of the pool.

See Also:

• Constant Field Values

POOL_TIME_TO_WAIT

public static final String POOL_TIME_TO_WAIT

Resource Key for the time to wait for an available connection.

See Also:

• Constant Field Values

logR

protected transient org.slf4j.Logger logR

Constructor Details

FailoverDataSource

public FailoverDataSource(Properties p)

Method Details

config

protected FailoverConfig config()

maxPoolSize

protected int maxPoolSize()

timeToWait

protected long timeToWait()

overrideObjectPool

protected void overrideObjectPool(org.apache.commons.pool.impl.GenericObjectPool p)
                           throws Exception

Throws:

Exception

destroy

protected void destroy()
                throws Exception

Throws:

Exception

getConnection

public Connection getConnection()
                         throws SQLException

Get the configured connection.

Specified by:

getConnection in interface DataSource

Throws:

SQLException

See Also:

• DataSource.getConnection()

getConnection

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

Get the configured connection.

This class will ignore the supplied credentials, relying on the configuration used to create this source instead.

This can be considered breaking the javax.sql.DataSource contract, however, this is the desired behaviour when you are failing over to multiple databases.

Specified by:

getConnection in interface DataSource

Throws:

SQLException

See Also:

• DataSource.getConnection(String, String)

setLoginTimeout

public void setLoginTimeout(int loginTimeout)
                     throws SQLException

Specified by:

setLoginTimeout in interface CommonDataSource

Specified by:

setLoginTimeout in interface DataSource

Throws:

SQLException

See Also:

• DataSource.setLoginTimeout(int)

getLoginTimeout

public int getLoginTimeout()
                    throws SQLException

Specified by:

getLoginTimeout in interface CommonDataSource

Specified by:

getLoginTimeout in interface DataSource

Throws:

SQLException

See Also:

• DataSource.getLoginTimeout()

setLogWriter

public void setLogWriter(PrintWriter logWriter)
                  throws SQLException

Specified by:

setLogWriter in interface CommonDataSource

Specified by:

setLogWriter in interface DataSource

Throws:

SQLException

See Also:

• DataSource.setLogWriter(java.io.PrintWriter)

getLogWriter

public PrintWriter getLogWriter()
                         throws SQLException

Specified by:

getLogWriter in interface CommonDataSource

Specified by:

getLogWriter in interface DataSource

Throws:

SQLException

See Also:

• DataSource.getLogWriter()

isWrapperFor

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

Specified by:

isWrapperFor in interface Wrapper

Throws:

SQLException

See Also:

• Wrapper.isWrapperFor(java.lang.Class)

unwrap

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

Specified by:

unwrap in interface Wrapper

Throws:

SQLException

See Also:

• Wrapper.unwrap(java.lang.Class)

getParentLogger

public Logger getParentLogger()
                       throws SQLFeatureNotSupportedException

Specified by:

getParentLogger in interface CommonDataSource

Throws:

SQLFeatureNotSupportedException

wrapSQLClientInfoException

protected static SQLClientInfoException wrapSQLClientInfoException(Exception e)

wrapSQLException

protected static SQLException wrapSQLException(Exception e)