Package lu.kbra.pclib.db.connector

Class ThreadLocalDatabaseConnector

java.lang.Object

lu.kbra.pclib.db.connector.AbstractDatabaseConnector

lu.kbra.pclib.db.connector.ThreadLocalDatabaseConnector

All Implemented Interfaces:

Cloneable, DatabaseConnector

Direct Known Subclasses:

MySQLDatabaseConnector, PostgreSQLDatabaseConnector, SQLiteDatabaseConnector

public abstract class ThreadLocalDatabaseConnector
extends AbstractDatabaseConnector

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	ThreadLocalDatabaseConnector.PerThreadCachedConnection

Nested classes/interfaces inherited from class lu.kbra.pclib.db.connector.AbstractDatabaseConnector

AbstractDatabaseConnector.CachedConnection, AbstractDatabaseConnector.ConnectionCachingStrategy

Field Summary

Fields

Modifier and Type	Field	Description
protected final Set<AbstractDatabaseConnector.CachedConnection>	connections
protected final AtomicLong	generation
protected final ThreadLocal<AbstractDatabaseConnector.CachedConnection>	threadConnection

Constructor Summary

Constructors

Constructor	Description
ThreadLocalDatabaseConnector()

Method Summary

Modifier and Type	Method	Description
final Connection	connect()
final AbstractDatabaseConnector.ConnectionCachingStrategy	getConnectionCachingStrategy()
boolean	keepAlive(int timeoutSeconds)
final void	reset()
final AbstractDatabaseConnector.CachedConnection.ConnectionHolder	use()

Methods inherited from class lu.kbra.pclib.db.connector.AbstractDatabaseConnector

clone

Methods inherited from class java.lang.Object

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

Methods inherited from interface lu.kbra.pclib.db.connector.impl.DatabaseConnector

createConnection, getDatabase, getProtocol, getURI, preDelete, setDatabase

Field Details

threadConnection

protected final transient ThreadLocal<AbstractDatabaseConnector.CachedConnection> threadConnection

connections

protected final transient Set<AbstractDatabaseConnector.CachedConnection> connections

generation

protected final transient AtomicLong generation

Constructor Details

ThreadLocalDatabaseConnector

public ThreadLocalDatabaseConnector()

Method Details

connect

public final Connection connect()
                         throws DBException

Throws:

DBException

keepAlive

public boolean keepAlive(int timeoutSeconds)

Parameters:

timeoutSeconds -

Returns:

false if the connection was still alive or isn't created.
true if the connection needed to be reset

reset

public final void reset()
                 throws DBException

Throws:

DBException

use

public final AbstractDatabaseConnector.CachedConnection.ConnectionHolder use()
                                                                      throws DBException

Throws:

DBException

getConnectionCachingStrategy

public final AbstractDatabaseConnector.ConnectionCachingStrategy getConnectionCachingStrategy()

Specified by:

getConnectionCachingStrategy in class AbstractDatabaseConnector