Package io.mats3.util.wrappers

Class DataSourceWrapper

java.lang.Object

io.mats3.util.wrappers.DataSourceWrapper

All Implemented Interfaces:

MatsFactory.MatsWrapper<DataSource>, Wrapper, CommonDataSource, DataSource

Direct Known Subclasses:

DeferredConnectionProxyDataSourceWrapper

public class DataSourceWrapper
extends Object
implements DataSource, MatsFactory.MatsWrapper<DataSource>

A base Wrapper for a JDBC DataSource, which simply implements DataSource, takes a DataSource instance and forwards all calls to that. Meant to be extended to add extra functionality, e.g. Spring integration.

Constructor Summary

Constructors

Constructor	Description
DataSourceWrapper()	No-args constructor, which implies that you either need to invoke setWrappee(DataSource) before publishing the instance (making it available for other threads), or override unwrap() to provide the desired DataSource instance.
DataSourceWrapper(DataSource targetDataSource)	Standard constructor, taking the wrapped DataSource instance.

Method Summary

Modifier and Type	Method	Description
Connection	getConnection()
Connection	getConnection(String username, String password)
int	getLoginTimeout()
PrintWriter	getLogWriter()
Logger	getParentLogger()
boolean	isWrapperFor(Class<?> iface)
void	setLoginTimeout(int seconds)
void	setLogWriter(PrintWriter out)
void	setWrappee(DataSource targetDataSource)	Sets the wrapped DataSource, e.g.
String	toString()
DataSource	unwrap()
<T> T	unwrap(Class<T> iface)

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.sql.CommonDataSource

createShardingKeyBuilder

Methods inherited from interface javax.sql.DataSource

createConnectionBuilder

Methods inherited from interface io.mats3.MatsFactory.MatsWrapper

unwrapFully, unwrapTo

Constructor Details

DataSourceWrapper

public DataSourceWrapper(DataSource targetDataSource)

Standard constructor, taking the wrapped DataSource instance.

Parameters:

targetDataSource - the DataSource instance which unwrap() will return (and hence all forwarded methods will use).

DataSourceWrapper

public DataSourceWrapper()

No-args constructor, which implies that you either need to invoke setWrappee(DataSource) before publishing the instance (making it available for other threads), or override unwrap() to provide the desired DataSource instance. In these cases, make sure to honor memory visibility semantics - i.e. establish a happens-before edge between the setting of the instance and any other threads getting it.

Method Details

setWrappee

public void setWrappee(DataSource targetDataSource)

Sets the wrapped DataSource, e.g. in case you instantiated it with the no-args constructor. Do note that the field holding the wrapped instance is not volatile nor synchronized. This means that if you want to set it after it has been published to other threads, you will have to override both this method and unwrap() to provide for needed memory visibility semantics, i.e. establish a happens-before edge between the setting of the instance and any other threads getting it.

Specified by:

setWrappee in interface MatsFactory.MatsWrapper<DataSource>

Parameters:

targetDataSource - the DataSource which is returned by unwrap(), unless that is overridden.

unwrap

public DataSource unwrap()

Specified by:

unwrap in interface MatsFactory.MatsWrapper<DataSource>

Returns:

the wrapped DataSource. All forwarding methods invokes this method to get the wrapped DataSource, thus if you want to get creative wrt. how and when the DataSource is decided, you can override this method.

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface DataSource

Throws:

SQLException

getConnection

public Connection getConnection(String username,
 String password)
                         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

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 seconds)
                     throws SQLException

Specified by:

setLoginTimeout in interface CommonDataSource

Specified by:

setLoginTimeout 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

getParentLogger

public Logger getParentLogger()
                       throws SQLFeatureNotSupportedException

Specified by:

getParentLogger in interface CommonDataSource

Throws:

SQLFeatureNotSupportedException

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

toString

public String toString()

Overrides:

toString in class Object