Module iu.util.jdbc.pool

Package edu.iu.jdbc.pool

Class IuPooledConnection

java.lang.Object

edu.iu.jdbc.pool.IuPooledConnection

All Implemented Interfaces:

EventListener, ConnectionEventListener, PooledConnection, StatementEventListener

public class IuPooledConnection
extends Object
implements PooledConnection, ConnectionEventListener, StatementEventListener

Generic PooledConnection implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	IuPooledConnection.StatementKey	Hash key for PreparedStatement initialization args.

Constructor Summary

Constructors

Constructor	Description
IuPooledConnection(Instant initTime, PooledConnection physicalConnection, UnsafeFunction<Connection,Connection> connectionInitializer, Duration abandonedConnectionTimeout, Consumer<IuPooledConnection> onClose)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	addConnectionEventListener(ConnectionEventListener listener)
void	addStatementEventListener(StatementEventListener listener)
void	close()
void	connectionClosed(ConnectionEvent event)
void	connectionErrorOccurred(ConnectionEvent event)
(package private) Throwable	error()	Gets the error that invalidated this connection, if invalid due to an error.
Duration	getAverageTransactionSegmentDuration()	Gets the average Duration of the transaction segments completed via this physical connection.
Connection	getConnection()
Instant	getConnectionInitiated()	Gets the Instant the connection factory initiated this physical connection.
Instant	getConnectionOpened()	Gets the Instant the connection factory opened this physical connection.
Instant	getLastTransactionSegmentEnded()	Gets the end Instant of the last transaction segment completed on this physical connection.
Instant	getLastTransactionSegmentStarted()	Gets the start Instant of the last transaction segment completed on this physical connection.
Instant	getLogicalConnectionOpened()	Gets the Instant the logical connection associated with this physical connection was opened.
Duration	getMaxTransactionSegmentDuration()	Gets the average Duration of the transaction segments completed via this physical connection.
long	getTransactionSegmentCount()	Gets the number of times this connection has been used.
boolean	isClosed()	Determines whether or not the physical connection is closed.
void	removeConnectionEventListener(ConnectionEventListener listener)
void	removeStatementEventListener(StatementEventListener listener)
void	statementClosed(StatementEvent event)
void	statementErrorOccurred(StatementEvent event)
String	toString()
(package private) void	validate(String validationQuery)	Pre-emptively establishes and validates the logical connection.

Methods inherited from class java.lang.Object

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

Constructor Details

IuPooledConnection

public IuPooledConnection(Instant initTime,
 PooledConnection physicalConnection,
 UnsafeFunction<Connection,Connection> connectionInitializer,
 Duration abandonedConnectionTimeout,
 Consumer<IuPooledConnection> onClose)

Constructor.

Parameters:

initTime - Instant the physical connection was initiated

physicalConnection - PooledConnection downstream physical connection

connectionInitializer - From IuCommonDataSource.setConnectionInitializer(UnsafeFunction)

abandonedConnectionTimeout - Duration after getConnection() is invoked when the connection will be considered abandoned and removed from the pool

onClose - receives a handle to this pooled connection decorator when close() is invoked

Method Details

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface PooledConnection

Throws:

SQLException

addConnectionEventListener

public void addConnectionEventListener(ConnectionEventListener listener)

Specified by:

addConnectionEventListener in interface PooledConnection

connectionClosed

public void connectionClosed(ConnectionEvent event)

Specified by:

connectionClosed in interface ConnectionEventListener

connectionErrorOccurred

public void connectionErrorOccurred(ConnectionEvent event)

Specified by:

connectionErrorOccurred in interface ConnectionEventListener

removeConnectionEventListener

public void removeConnectionEventListener(ConnectionEventListener listener)

Specified by:

removeConnectionEventListener in interface PooledConnection

addStatementEventListener

public void addStatementEventListener(StatementEventListener listener)

Specified by:

addStatementEventListener in interface PooledConnection

statementClosed

public void statementClosed(StatementEvent event)

Specified by:

statementClosed in interface StatementEventListener

statementErrorOccurred

public void statementErrorOccurred(StatementEvent event)

Specified by:

statementErrorOccurred in interface StatementEventListener

removeStatementEventListener

public void removeStatementEventListener(StatementEventListener listener)

Specified by:

removeStatementEventListener in interface PooledConnection

close

public void close()
           throws SQLException

Specified by:

close in interface PooledConnection

Throws:

SQLException

toString

public String toString()

Overrides:

toString in class Object

getConnectionInitiated

public Instant getConnectionInitiated()

Gets the Instant the connection factory initiated this physical connection.

Returns:

Instant

getConnectionOpened

public Instant getConnectionOpened()

Gets the Instant the connection factory opened this physical connection.

Returns:

Instant

getLogicalConnectionOpened

public Instant getLogicalConnectionOpened()

Gets the Instant the logical connection associated with this physical connection was opened.

Returns:

Instant

getLastTransactionSegmentStarted

public Instant getLastTransactionSegmentStarted()

Gets the start Instant of the last transaction segment completed on this physical connection.

Returns:

Instant

getLastTransactionSegmentEnded

public Instant getLastTransactionSegmentEnded()

Gets the end Instant of the last transaction segment completed on this physical connection.

Returns:

Instant

getAverageTransactionSegmentDuration

public Duration getAverageTransactionSegmentDuration()

Gets the average Duration of the transaction segments completed via this physical connection.

Returns:

Duration

getMaxTransactionSegmentDuration

public Duration getMaxTransactionSegmentDuration()

Gets the average Duration of the transaction segments completed via this physical connection.

Returns:

Duration

getTransactionSegmentCount

public long getTransactionSegmentCount()

Gets the number of times this connection has been used.

Returns:

invalid reference

long

isClosed

public boolean isClosed()

Determines whether or not the physical connection is closed.

Returns:

true if the physical connection is closed; else false

error

Throwable error()

Gets the error that invalidated this connection, if invalid due to an error.

Returns:

SQLException; null if the connection has not experienced a error

validate

void validate(String validationQuery)
       throws SQLException

Pre-emptively establishes and validates the logical connection.

Parameters:

validationQuery - SQL to execute on the connection, should produce at least one row with a non-null value in the first column

Throws:

SQLException - if the logical connection cannot be established or the validation query fails