ome.services.db

Class SelfCorrectingDataSource

java.lang.Object

org.springframework.jdbc.datasource.DelegatingDataSource

ome.services.db.SelfCorrectingDataSource

All Implemented Interfaces:

Wrapper, EventListener, CommonDataSource, DataSource, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationListener<UserSignalMessage>

public class SelfCorrectingDataSource
extends org.springframework.jdbc.datasource.DelegatingDataSource
implements org.springframework.context.ApplicationListener<UserSignalMessage>

DataSource delegate which wraps the

Constructor Summary

Constructors

Constructor and Description
SelfCorrectingDataSource(DataSource delegate, long timeoutInMilliseconds)
SelfCorrectingDataSource(DataSource delegate, long timeoutInMilliseconds, int maxRetries, long maxBackOff)

Method Summary

Modifier and Type	Method and Description
protected long	calculateBackOff(int numberOfErrors)
protected Connection	call(String username, String password, boolean useArgs)
protected Connection	callWithRetries(String username, String password, boolean useArgs)
Connection	getConnection()
Connection	getConnection(String username, String password)
protected long	markAndSweep() First removes all entries in errorTimes that are older than some given time and then uses the remaining number of errors to determine the backoff : (#^1/2)*1000 milliseconds.
void	onApplicationEvent(UserSignalMessage usm) Handles the USR1 posix signal by calling close on the underlying data source via reflection.

Methods inherited from class org.springframework.jdbc.datasource.DelegatingDataSource

afterPropertiesSet, getLoginTimeout, getLogWriter, getTargetDataSource, isWrapperFor, setLoginTimeout, setLogWriter, setTargetDataSource, unwrap

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

getParentLogger

Constructor Detail

SelfCorrectingDataSource

public SelfCorrectingDataSource(DataSource delegate,
                                long timeoutInMilliseconds)

SelfCorrectingDataSource

public SelfCorrectingDataSource(DataSource delegate,
                                long timeoutInMilliseconds,
                                int maxRetries,
                                long maxBackOff)

Method Detail

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface DataSource

Overrides:

getConnection in class org.springframework.jdbc.datasource.DelegatingDataSource

Throws:

SQLException

getConnection

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

Specified by:

getConnection in interface DataSource

Overrides:

getConnection in class org.springframework.jdbc.datasource.DelegatingDataSource

Throws:

SQLException

onApplicationEvent

public void onApplicationEvent(UserSignalMessage usm)

Handles the USR1 posix signal by calling close on the underlying data source via reflection. The assumption is that the next call to any methods will re-initialize the data source. This is the case with bitronix.tm.resource.jdbc.PoolingDataSource

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<UserSignalMessage>

See Also:

ticket:4210

callWithRetries

protected Connection callWithRetries(String username,
                                     String password,
                                     boolean useArgs)
                              throws SQLException

Throws:

SQLException

call

protected Connection call(String username,
                          String password,
                          boolean useArgs)
                   throws SQLException

Throws:

SQLException

markAndSweep

protected long markAndSweep()

First removes all entries in errorTimes that are older than some given time and then uses the remaining number of errors to determine the backoff : (#^1/2)*1000 milliseconds.

calculateBackOff

protected long calculateBackOff(int numberOfErrors)