Module com.aoapps.sql.tracker

Package com.aoapps.sql.tracker

Class ConnectionTrackerImpl

java.lang.Object

com.aoapps.sql.wrapper.ConnectionWrapperImpl

com.aoapps.sql.tracker.ConnectionTrackerImpl

All Implemented Interfaces:

ConnectionTracker, OnCloseHandler, TrackedArrays, TrackedBlobs, TrackedCallableStatements, TrackedClobs, TrackedDatabaseMetaDatas, TrackedInputStreams, TrackedNClobs, TrackedOutputStreams, TrackedParameterMetaDatas, TrackedPreparedStatements, TrackedReaders, TrackedRefs, TrackedResultSetMetaDatas, TrackedResultSets, TrackedRowIds, TrackedSavepoints, TrackedSQLDatas, TrackedSQLInputs, TrackedSQLOutputs, TrackedSQLXMLs, TrackedStatements, TrackedStructs, TrackedWriters, ConnectionWrapper, Wrapper, AutoCloseable, Connection, Wrapper

public class ConnectionTrackerImpl
extends ConnectionWrapperImpl
implements ConnectionTracker

Tracks a Connection for unclosed or unfreed objects.

Author:

AO Industries, Inc.

Field Summary

Fields

Modifier and Type	Field	Description
static final Level	ALLOCATION_STACKTRACE_LOG_LEVEL	The logging level that enables allocation stack trace logging.

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors

Constructor	Description
ConnectionTrackerImpl(DriverTracker driver, Connection wrapped)	Creates a new Connection tracker.
ConnectionTrackerImpl(Connection wrapped)	Creates a new Connection tracker.

Method Summary

Modifier and Type	Method	Description
void	abort(Executor executor)	Calls onClose handlers, clears all tracking, then calls doAbort(java.util.concurrent.Executor).
void	addOnClose(Runnable onCloseHandler)	Will call the handler once on close/free.
protected void	clearTracking()	Clears all tracking.
void	close()	Calls onClose handlers, closes all tracked objects, rolls-back any transaction in-progress and puts back in auto-commit mode, then calls doClose().
protected Throwable	closeTracked(Throwable t0, String sourceMethod)	Closes / frees all tracked objects except savepoints, which are expected to be closed by a following rollback().
void	commit()	Removes tracking of savepoints while committing the transaction.
protected void	doAbort(Executor executor)	Performs the actual abort, called once all onClose handlers completed and all tracking cleared.
protected void	doClose()	Performs the actual close, called once all onClose handlers completed and all tracked objects closed.
Logger	getAllocationLogger()
Exception	getAllocationStacktrace()
final Map<Array,ArrayTrackerImpl>	getTrackedArrays()	Gets all the arrays that have not yet been freed.
final Map<Blob,BlobTrackerImpl>	getTrackedBlobs()	Gets all the blobs that have not yet been freed.
final Map<CallableStatement,CallableStatementTrackerImpl>	getTrackedCallableStatements()	Gets all the callable statements that have not yet been closed.
final Map<Clob,ClobTrackerImpl>	getTrackedClobs()	Gets all the clobs that have not yet been freed.
final Map<DatabaseMetaData,DatabaseMetaDataTrackerImpl>	getTrackedDatabaseMetaDatas()	Gets all the meta data that have not yet been closed.
final Map<InputStream,InputStreamTracker>	getTrackedInputStreams()	Gets all the input streams that have not yet been closed.
final Map<NClob,NClobTrackerImpl>	getTrackedNClobs()	Gets all the nclobs that have not yet been freed.
final Map<OutputStream,OutputStreamTracker>	getTrackedOutputStreams()	Gets all the output streams that have not yet been closed.
final Map<ParameterMetaData,ParameterMetaDataTrackerImpl>	getTrackedParameterMetaDatas()	Gets all the meta data that have not yet been closed.
final Map<PreparedStatement,PreparedStatementTrackerImpl>	getTrackedPreparedStatements()	Gets all the prepared statements that have not yet been closed.
final Map<Reader,ReaderTracker>	getTrackedReaders()	Gets all the readers that have not yet been closed.
final Map<Ref,RefTrackerImpl>	getTrackedRefs()	Gets all the refs that have not yet been closed.
final Map<ResultSetMetaData,ResultSetMetaDataTrackerImpl>	getTrackedResultSetMetaDatas()	Gets all the meta data that have not yet been closed.
final Map<ResultSet,ResultSetTrackerImpl>	getTrackedResultSets()	Gets all the result sets that have not yet been closed.
final Map<RowId,RowIdTrackerImpl>	getTrackedRowIds()	Gets all the row IDs that have not yet been closed.
final Map<Savepoint,SavepointTrackerImpl>	getTrackedSavepoints()	Gets all the savepoints that have not yet been released.
final Map<SQLData,SQLDataTrackerImpl>	getTrackedSQLDatas()	Gets all the SQL datas that have not yet been closed.
final Map<SQLInput,SQLInputTrackerImpl>	getTrackedSQLInputs()	Gets all the SQL inputs that have not yet been closed.
final Map<SQLOutput,SQLOutputTrackerImpl>	getTrackedSQLOutputs()	Gets all the SQL outputs that have not yet been closed.
final Map<SQLXML,SQLXMLTrackerImpl>	getTrackedSQLXMLs()	Gets all the SQL XMLs that have not yet been freed.
final Map<Statement,StatementTrackerImpl>	getTrackedStatements()	Gets all the statements that have not yet been closed.
final Map<Struct,StructTrackerImpl>	getTrackedStructs()	Gets all the structs that have not yet been closed.
final Map<Writer,WriterTracker>	getTrackedWriters()	Gets all the writers that have not yet been closed.
protected ArrayTrackerImpl	newArrayWrapper(StatementWrapperImpl stmtWrapper, Array array)
protected BlobTrackerImpl	newBlobWrapper(Blob blob)
protected CallableStatementTrackerImpl	newCallableStatementWrapper(CallableStatement cstmt)
protected ClobTrackerImpl	newClobWrapper(Clob clob)
protected DatabaseMetaDataTrackerImpl	newDatabaseMetaDataWrapper(DatabaseMetaData metaData)
protected InputStreamTracker	newInputStreamWrapper(InputStream in)
protected NClobTrackerImpl	newNClobWrapper(NClob nclob)
protected OutputStreamTracker	newOutputStreamWrapper(OutputStream out)
protected ParameterMetaDataTrackerImpl	newParameterMetaDataWrapper(ParameterMetaData metaData)
protected PreparedStatementTrackerImpl	newPreparedStatementWrapper(PreparedStatement pstmt)
protected ReaderTracker	newReaderWrapper(Reader in)
protected RefTrackerImpl	newRefWrapper(Ref ref)
protected ResultSetMetaDataTrackerImpl	newResultSetMetaDataWrapper(ResultSetMetaData metaData)
protected ResultSetTrackerImpl	newResultSetWrapper(StatementWrapperImpl stmtWrapper, ResultSet results)
protected RowIdTrackerImpl	newRowIdWrapper(RowId rowId)
protected SavepointTrackerImpl	newSavepointWrapper(Savepoint savepoint)
protected SQLDataTrackerImpl	newSQLDataWrapper(SQLData sqlData)
protected SQLInputTrackerImpl	newSQLInputWrapper(SQLInput sqlInput)
protected SQLOutputTrackerImpl	newSQLOutputWrapper(SQLOutput sqlOutput)
protected SQLXMLTrackerImpl	newSQLXMLWrapper(SQLXML sqlXml)
protected StatementTrackerImpl	newStatementWrapper(Statement stmt)
protected StructTrackerImpl	newStructWrapper(Struct struct)
protected WriterTracker	newWriterWrapper(Writer out)
protected Throwable	releaseAllTrackedSavepoints(Throwable t0)	Releases all tracked savepoints.
void	releaseSavepoint(Savepoint savepoint)	Removes tracking while releasing the savepoint.
void	rollback()	Removes tracking of savepoints while rolling-back the transaction.
void	rollback(Savepoint savepoint)	Removes tracking of all savepoints after the given savepoint, the rolls-back to the given savepoint.
void	setAutoCommit(boolean autoCommit)	Removes tracking of savepoints when auto-commit mode is enabled (which commits any transaction in-progress).

Methods inherited from class com.aoapps.sql.wrapper.ConnectionWrapperImpl

createArrayOf, createBlob, createClob, createNClob, createSQLXML, createStatement, createStatement, createStatement, createStruct, getDriver, getMetaData, getWrapped, prepareCall, prepareCall, prepareCall, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, setSavepoint, setSavepoint, toString, unwrapArray, unwrapBlob, unwrapClob, unwrapInputStream, unwrapNClob, unwrapReader, unwrapRef, unwrapRowId, unwrapSavepoint, unwrapSQLXML, unwrapStruct, wrapArray, wrapBlob, wrapCallableStatement, wrapClob, wrapDatabaseMetaData, wrapInputStream, wrapNClob, wrapOutputStream, wrapParameterMetaData, wrapPreparedStatement, wrapReader, wrapRef, wrapResultSet, wrapResultSetMetaData, wrapRowId, wrapSavepoint, wrapSQLData, wrapSQLInput, wrapSQLOutput, wrapSQLXML, wrapStatement, wrapStruct, wrapWriter

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Connection

beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid

Methods inherited from interface com.aoapps.sql.wrapper.ConnectionWrapper

clearWarnings, createArrayOf, createBlob, createClob, createNClob, createSQLXML, createStatement, createStatement, createStatement, createStruct, getAutoCommit, getCatalog, getClientInfo, getClientInfo, getHoldability, getMetaData, getNetworkTimeout, getSchema, getTransactionIsolation, getTypeMap, getWarnings, getWrapped, getWrappedConnection, isClosed, isReadOnly, isValid, nativeSQL, prepareCall, prepareCall, prepareCall, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, setCatalog, setClientInfo, setClientInfo, setHoldability, setNetworkTimeout, setReadOnly, setSavepoint, setSavepoint, setSchema, setTransactionIsolation, setTypeMap

Methods inherited from interface com.aoapps.sql.wrapper.Wrapper

isWrapperFor, unwrap

Field Details

ALLOCATION_STACKTRACE_LOG_LEVEL

static final Level ALLOCATION_STACKTRACE_LOG_LEVEL

The logging level that enables allocation stack trace logging.

Constructor Details

ConnectionTrackerImpl

public ConnectionTrackerImpl(DriverTracker driver,
 Connection wrapped)

Creates a new Connection tracker.

ConnectionTrackerImpl

public ConnectionTrackerImpl(Connection wrapped)

Creates a new Connection tracker.

Method Details

getAllocationStacktrace

public Exception getAllocationStacktrace()

getAllocationLogger

public Logger getAllocationLogger()

addOnClose

public void addOnClose(Runnable onCloseHandler)

Description copied from interface: OnCloseHandler

Will call the handler once on close/free.

Specified by:

addOnClose in interface OnCloseHandler

getTrackedArrays

public final Map<Array,ArrayTrackerImpl> getTrackedArrays()

Description copied from interface: TrackedArrays

Gets all the arrays that have not yet been freed.

Specified by:

getTrackedArrays in interface TrackedArrays

Returns:

The mapping from wrapped array to tracker without any defensive copy.

See Also:

• Array.free()

getTrackedBlobs

public final Map<Blob,BlobTrackerImpl> getTrackedBlobs()

Description copied from interface: TrackedBlobs

Gets all the blobs that have not yet been freed.

Specified by:

getTrackedBlobs in interface TrackedBlobs

Returns:

The mapping from wrapped blob to tracker without any defensive copy.

See Also:

• Blob.free()

getTrackedCallableStatements

public final Map<CallableStatement,CallableStatementTrackerImpl> getTrackedCallableStatements()

Description copied from interface: TrackedCallableStatements

Gets all the callable statements that have not yet been closed.

Specified by:

getTrackedCallableStatements in interface TrackedCallableStatements

Returns:

The mapping from wrapped callable statement to tracker without any defensive copy.

See Also:

• Statement.close()

getTrackedClobs

public final Map<Clob,ClobTrackerImpl> getTrackedClobs()

Description copied from interface: TrackedClobs

Gets all the clobs that have not yet been freed. This only contains Clob, please see other method for NClob.

Specified by:

getTrackedClobs in interface TrackedClobs

Returns:

The mapping from wrapped clob to tracker without any defensive copy.

See Also:

• TrackedNClobs.getTrackedNClobs()
• Clob.free()

getTrackedDatabaseMetaDatas

public final Map<DatabaseMetaData,DatabaseMetaDataTrackerImpl> getTrackedDatabaseMetaDatas()

Description copied from interface: TrackedDatabaseMetaDatas

Gets all the meta data that have not yet been closed. Meta datas are assumed to be closed with their connection.

Specified by:

getTrackedDatabaseMetaDatas in interface TrackedDatabaseMetaDatas

Returns:

The mapping from wrapped meta data to tracker without any defensive copy.

See Also:

• Connection.close()

getTrackedInputStreams

public final Map<InputStream,InputStreamTracker> getTrackedInputStreams()

Description copied from interface: TrackedInputStreams

Gets all the input streams that have not yet been closed.

Specified by:

getTrackedInputStreams in interface TrackedInputStreams

Returns:

The mapping from wrapped input stream to tracker without any defensive copy.

See Also:

• InputStream.close()

getTrackedNClobs

public final Map<NClob,NClobTrackerImpl> getTrackedNClobs()

Description copied from interface: TrackedNClobs

Gets all the nclobs that have not yet been freed.

Specified by:

getTrackedNClobs in interface TrackedNClobs

Returns:

The mapping from wrapped nclob to tracker without any defensive copy.

See Also:

• Clob.free()

getTrackedOutputStreams

public final Map<OutputStream,OutputStreamTracker> getTrackedOutputStreams()

Description copied from interface: TrackedOutputStreams

Gets all the output streams that have not yet been closed.

Specified by:

getTrackedOutputStreams in interface TrackedOutputStreams

Returns:

The mapping from wrapped output stream to tracker without any defensive copy.

See Also:

• OutputStream.close()

getTrackedParameterMetaDatas

public final Map<ParameterMetaData,ParameterMetaDataTrackerImpl> getTrackedParameterMetaDatas()

Description copied from interface: TrackedParameterMetaDatas

Gets all the meta data that have not yet been closed. Meta datas are assumed to be closed with their prepared statement.

Specified by:

getTrackedParameterMetaDatas in interface TrackedParameterMetaDatas

Returns:

The mapping from wrapped meta data to tracker without any defensive copy.

See Also:

• Statement.close()

getTrackedPreparedStatements

public final Map<PreparedStatement,PreparedStatementTrackerImpl> getTrackedPreparedStatements()

Description copied from interface: TrackedPreparedStatements

Gets all the prepared statements that have not yet been closed. This only contains PreparedStatement, please see other method for CallableStatement.

Specified by:

getTrackedPreparedStatements in interface TrackedPreparedStatements

Returns:

The mapping from wrapped prepared statement to tracker without any defensive copy.

See Also:

• TrackedCallableStatements.getTrackedCallableStatements()
• Statement.close()

getTrackedReaders

public final Map<Reader,ReaderTracker> getTrackedReaders()

Description copied from interface: TrackedReaders

Gets all the readers that have not yet been closed.

Specified by:

getTrackedReaders in interface TrackedReaders

Returns:

The mapping from wrapped reader to tracker without any defensive copy.

See Also:

• Reader.close()

getTrackedRefs

public final Map<Ref,RefTrackerImpl> getTrackedRefs()

Description copied from interface: TrackedRefs

Gets all the refs that have not yet been closed. Refs are assumed to be closed with their connection.

Specified by:

getTrackedRefs in interface TrackedRefs

Returns:

The mapping from wrapped ref to tracker without any defensive copy.

See Also:

• Connection.close()

getTrackedResultSets

public final Map<ResultSet,ResultSetTrackerImpl> getTrackedResultSets()

Description copied from interface: TrackedResultSets

Gets all the result sets that have not yet been closed.

Specified by:

getTrackedResultSets in interface TrackedResultSets

Returns:

The mapping from wrapped result set to tracker without any defensive copy.

See Also:

• ResultSet.close()

getTrackedResultSetMetaDatas

public final Map<ResultSetMetaData,ResultSetMetaDataTrackerImpl> getTrackedResultSetMetaDatas()

Description copied from interface: TrackedResultSetMetaDatas

Gets all the meta data that have not yet been closed. Meta datas are assumed to be closed with their result set.

Specified by:

getTrackedResultSetMetaDatas in interface TrackedResultSetMetaDatas

Returns:

The mapping from wrapped meta data to tracker without any defensive copy.

See Also:

• ResultSet.close()

getTrackedRowIds

public final Map<RowId,RowIdTrackerImpl> getTrackedRowIds()

Description copied from interface: TrackedRowIds

Gets all the row IDs that have not yet been closed. Row IDs are assumed to be closed with their connection.

Specified by:

getTrackedRowIds in interface TrackedRowIds

Returns:

The mapping from wrapped row ID to tracker without any defensive copy.

See Also:

• Connection.close()

getTrackedSQLDatas

public final Map<SQLData,SQLDataTrackerImpl> getTrackedSQLDatas()

Description copied from interface: TrackedSQLDatas

Gets all the SQL datas that have not yet been closed.

Specified by:

getTrackedSQLDatas in interface TrackedSQLDatas

Returns:

The mapping from wrapped SQL data to tracker without any defensive copy.

See Also:

• SQLOutputWrapperImpl.writeObject(java.sql.SQLData)

getTrackedSQLInputs

public final Map<SQLInput,SQLInputTrackerImpl> getTrackedSQLInputs()

Description copied from interface: TrackedSQLInputs

Gets all the SQL inputs that have not yet been closed.

Specified by:

getTrackedSQLInputs in interface TrackedSQLInputs

Returns:

The mapping from wrapped SQL input to tracker without any defensive copy.

See Also:

• SQLDataWrapperImpl.readSQL(java.sql.SQLInput, java.lang.String)

getTrackedSQLOutputs

public final Map<SQLOutput,SQLOutputTrackerImpl> getTrackedSQLOutputs()

Description copied from interface: TrackedSQLOutputs

Gets all the SQL outputs that have not yet been closed.

Specified by:

getTrackedSQLOutputs in interface TrackedSQLOutputs

Returns:

The mapping from wrapped SQL output to tracker without any defensive copy.

See Also:

• SQLDataWrapperImpl.writeSQL(java.sql.SQLOutput)

getTrackedSQLXMLs

public final Map<SQLXML,SQLXMLTrackerImpl> getTrackedSQLXMLs()

Description copied from interface: TrackedSQLXMLs

Gets all the SQL XMLs that have not yet been freed.

Specified by:

getTrackedSQLXMLs in interface TrackedSQLXMLs

Returns:

The mapping from wrapped SQL XML to tracker without any defensive copy.

See Also:

• SQLXML.free()

getTrackedSavepoints

public final Map<Savepoint,SavepointTrackerImpl> getTrackedSavepoints()

Description copied from interface: TrackedSavepoints

Gets all the savepoints that have not yet been released.

Specified by:

getTrackedSavepoints in interface TrackedSavepoints

Returns:

The mapping from wrapped savepoint to tracker without any defensive copy.

See Also:

• Connection.releaseSavepoint(java.sql.Savepoint)

getTrackedStatements

public final Map<Statement,StatementTrackerImpl> getTrackedStatements()

Description copied from interface: TrackedStatements

Gets all the statements that have not yet been closed. This only contains Statement, please see other methods for PreparedStatement and CallableStatement.

Specified by:

getTrackedStatements in interface TrackedStatements

Returns:

The mapping from wrapped statement to tracker without any defensive copy.

See Also:

• TrackedPreparedStatements.getTrackedPreparedStatements()
• TrackedCallableStatements.getTrackedCallableStatements()
• Statement.close()

getTrackedStructs

public final Map<Struct,StructTrackerImpl> getTrackedStructs()

Description copied from interface: TrackedStructs

Gets all the structs that have not yet been closed. Structs are assumed to be closed with their connection.

Specified by:

getTrackedStructs in interface TrackedStructs

Returns:

The mapping from wrapped struct to tracker without any defensive copy.

See Also:

• Connection.close()

getTrackedWriters

public final Map<Writer,WriterTracker> getTrackedWriters()

Description copied from interface: TrackedWriters

Gets all the writers that have not yet been closed.

Specified by:

getTrackedWriters in interface TrackedWriters

Returns:

The mapping from wrapped writer to tracker without any defensive copy.

See Also:

• Writer.close()

closeTracked

protected Throwable closeTracked(Throwable t0,
 String sourceMethod)

Closes / frees all tracked objects except savepoints, which are expected to be closed by a following rollback().

clearTracking

protected void clearTracking()

Clears all tracking.

releaseAllTrackedSavepoints

protected Throwable releaseAllTrackedSavepoints(Throwable t0)

Releases all tracked savepoints.

newArrayWrapper

protected ArrayTrackerImpl newArrayWrapper(StatementWrapperImpl stmtWrapper,
 Array array)

Overrides:

newArrayWrapper in class ConnectionWrapperImpl

newBlobWrapper

protected BlobTrackerImpl newBlobWrapper(Blob blob)

Overrides:

newBlobWrapper in class ConnectionWrapperImpl

newCallableStatementWrapper

protected CallableStatementTrackerImpl newCallableStatementWrapper(CallableStatement cstmt)

Overrides:

newCallableStatementWrapper in class ConnectionWrapperImpl

newClobWrapper

protected ClobTrackerImpl newClobWrapper(Clob clob)

Overrides:

newClobWrapper in class ConnectionWrapperImpl

newDatabaseMetaDataWrapper

protected DatabaseMetaDataTrackerImpl newDatabaseMetaDataWrapper(DatabaseMetaData metaData)

Overrides:

newDatabaseMetaDataWrapper in class ConnectionWrapperImpl

newInputStreamWrapper

protected InputStreamTracker newInputStreamWrapper(InputStream in)

Overrides:

newInputStreamWrapper in class ConnectionWrapperImpl

newNClobWrapper

protected NClobTrackerImpl newNClobWrapper(NClob nclob)

Overrides:

newNClobWrapper in class ConnectionWrapperImpl

newOutputStreamWrapper

protected OutputStreamTracker newOutputStreamWrapper(OutputStream out)

Overrides:

newOutputStreamWrapper in class ConnectionWrapperImpl

newParameterMetaDataWrapper

protected ParameterMetaDataTrackerImpl newParameterMetaDataWrapper(ParameterMetaData metaData)

Overrides:

newParameterMetaDataWrapper in class ConnectionWrapperImpl

newPreparedStatementWrapper

protected PreparedStatementTrackerImpl newPreparedStatementWrapper(PreparedStatement pstmt)

Overrides:

newPreparedStatementWrapper in class ConnectionWrapperImpl

newReaderWrapper

protected ReaderTracker newReaderWrapper(Reader in)

Overrides:

newReaderWrapper in class ConnectionWrapperImpl

newRefWrapper

protected RefTrackerImpl newRefWrapper(Ref ref)

Overrides:

newRefWrapper in class ConnectionWrapperImpl

newResultSetWrapper

protected ResultSetTrackerImpl newResultSetWrapper(StatementWrapperImpl stmtWrapper,
 ResultSet results)

Overrides:

newResultSetWrapper in class ConnectionWrapperImpl

newResultSetMetaDataWrapper

protected ResultSetMetaDataTrackerImpl newResultSetMetaDataWrapper(ResultSetMetaData metaData)

Overrides:

newResultSetMetaDataWrapper in class ConnectionWrapperImpl

newRowIdWrapper

protected RowIdTrackerImpl newRowIdWrapper(RowId rowId)

Overrides:

newRowIdWrapper in class ConnectionWrapperImpl

newSQLDataWrapper

protected SQLDataTrackerImpl newSQLDataWrapper(SQLData sqlData)

Overrides:

newSQLDataWrapper in class ConnectionWrapperImpl

newSQLInputWrapper

protected SQLInputTrackerImpl newSQLInputWrapper(SQLInput sqlInput)

Overrides:

newSQLInputWrapper in class ConnectionWrapperImpl

newSQLOutputWrapper

protected SQLOutputTrackerImpl newSQLOutputWrapper(SQLOutput sqlOutput)

Overrides:

newSQLOutputWrapper in class ConnectionWrapperImpl

newSQLXMLWrapper

protected SQLXMLTrackerImpl newSQLXMLWrapper(SQLXML sqlXml)

Overrides:

newSQLXMLWrapper in class ConnectionWrapperImpl

newSavepointWrapper

protected SavepointTrackerImpl newSavepointWrapper(Savepoint savepoint)

Overrides:

newSavepointWrapper in class ConnectionWrapperImpl

newStatementWrapper

protected StatementTrackerImpl newStatementWrapper(Statement stmt)

Overrides:

newStatementWrapper in class ConnectionWrapperImpl

newStructWrapper

protected StructTrackerImpl newStructWrapper(Struct struct)

Overrides:

newStructWrapper in class ConnectionWrapperImpl

newWriterWrapper

protected WriterTracker newWriterWrapper(Writer out)

Overrides:

newWriterWrapper in class ConnectionWrapperImpl

setAutoCommit

public void setAutoCommit(boolean autoCommit)
                   throws SQLException

Removes tracking of savepoints when auto-commit mode is enabled (which commits any transaction in-progress).

Specified by:

setAutoCommit in interface Connection

Specified by:

setAutoCommit in interface ConnectionTracker

Specified by:

setAutoCommit in interface ConnectionWrapper

Throws:

SQLException

See Also:

• SavepointTrackerImpl.onRelease()

commit

public void commit()
            throws SQLException

Removes tracking of savepoints while committing the transaction.

Specified by:

commit in interface Connection

Specified by:

commit in interface ConnectionTracker

Specified by:

commit in interface ConnectionWrapper

Throws:

SQLException

See Also:

• SavepointTrackerImpl.onRelease()

rollback

public void rollback()
              throws SQLException

Removes tracking of savepoints while rolling-back the transaction.

Specified by:

rollback in interface Connection

Specified by:

rollback in interface ConnectionTracker

Specified by:

rollback in interface ConnectionWrapper

Throws:

SQLException

See Also:

• SavepointTrackerImpl.onRelease()

close

public void close()
           throws SQLException

Calls onClose handlers, closes all tracked objects, rolls-back any transaction in-progress and puts back in auto-commit mode, then calls doClose().

This default implementation calls doClose().

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Connection

Specified by:

close in interface ConnectionTracker

Specified by:

close in interface ConnectionWrapper

Overrides:

close in class ConnectionWrapperImpl

Throws:

SQLException

See Also:

• closeTracked(java.lang.Throwable, java.lang.String)
• doClose()

rollback

public void rollback(Savepoint savepoint)
              throws SQLException

Removes tracking of all savepoints after the given savepoint, the rolls-back to the given savepoint.

Specified by:

rollback in interface Connection

Specified by:

rollback in interface ConnectionTracker

Specified by:

rollback in interface ConnectionWrapper

Overrides:

rollback in class ConnectionWrapperImpl

Throws:

SQLException

See Also:

• SavepointTrackerImpl.onRelease()

releaseSavepoint

public void releaseSavepoint(Savepoint savepoint)
                      throws SQLException

Removes tracking while releasing the savepoint.

Specified by:

releaseSavepoint in interface Connection

Specified by:

releaseSavepoint in interface ConnectionTracker

Specified by:

releaseSavepoint in interface ConnectionWrapper

Overrides:

releaseSavepoint in class ConnectionWrapperImpl

Throws:

SQLException

See Also:

• SavepointTrackerImpl.close()
• SavepointTrackerImpl.onRelease()

abort

public void abort(Executor executor)
           throws SQLException

Calls onClose handlers, clears all tracking, then calls doAbort(java.util.concurrent.Executor). Trusts the underlying implementation of Connection.abort(java.util.concurrent.Executor) will free all resources.

This default implementation calls doAbort(java.util.concurrent.Executor).

Specified by:

abort in interface Connection

Specified by:

abort in interface ConnectionTracker

Specified by:

abort in interface ConnectionWrapper

Overrides:

abort in class ConnectionWrapperImpl

Throws:

SQLException

See Also:

• clearTracking()
• doAbort(java.util.concurrent.Executor)

doClose

protected void doClose()
                throws SQLException

Performs the actual close, called once all onClose handlers completed and all tracked objects closed.

This default implementation calls super.close()

Throws:

SQLException

See Also:

• close()

doAbort

protected void doAbort(Executor executor)
                throws SQLException

Performs the actual abort, called once all onClose handlers completed and all tracking cleared.

This default implementation calls super.abort(executor)

Throws:

SQLException

See Also:

• abort(java.util.concurrent.Executor)