Module com.aoapps.sql.tracker

Package com.aoapps.sql.tracker

Class ResultSetTrackerImpl

java.lang.Object

com.aoapps.sql.wrapper.ResultSetWrapperImpl

com.aoapps.sql.tracker.ResultSetTrackerImpl

All Implemented Interfaces:

OnCloseHandler, ResultSetTracker, TrackedArrays, TrackedBlobs, TrackedClobs, TrackedInputStreams, TrackedNClobs, TrackedReaders, TrackedRefs, TrackedResultSetMetaDatas, TrackedRowIds, TrackedSQLXMLs, ResultSetWrapper, Wrapper, AutoCloseable, ResultSet, Wrapper

public class ResultSetTrackerImpl
extends ResultSetWrapperImpl
implements ResultSetTracker

Tracks a ResultSet 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.ResultSet

CLOSE_CURSORS_AT_COMMIT, CONCUR_READ_ONLY, CONCUR_UPDATABLE, FETCH_FORWARD, FETCH_REVERSE, FETCH_UNKNOWN, HOLD_CURSORS_OVER_COMMIT, TYPE_FORWARD_ONLY, TYPE_SCROLL_INSENSITIVE, TYPE_SCROLL_SENSITIVE

Constructor Summary

Constructors

Constructor	Description
ResultSetTrackerImpl(ConnectionTrackerImpl connectionTracker, StatementWrapperImpl stmtTracker, ResultSet wrapped)	Creates a new ResultSet tracker.

Method Summary

Modifier and Type	Method	Description
void	addOnClose(Runnable onCloseHandler)	Will call the handler once on close/free.
void	close()	Calls onClose handlers, closes all tracked objects, then calls super.close().
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<Clob,ClobTrackerImpl>	getTrackedClobs()	Gets all the clobs that have not yet been freed.
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<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<RowId,RowIdTrackerImpl>	getTrackedRowIds()	Gets all the row IDs that have not yet been closed.
final Map<SQLXML,SQLXMLTrackerImpl>	getTrackedSQLXMLs()	Gets all the SQL XMLs that have not yet been freed.
protected ArrayTrackerImpl	wrapArray(Array array)
protected BlobTrackerImpl	wrapBlob(Blob blob)
protected ClobTrackerImpl	wrapClob(Clob clob)
protected InputStreamTracker	wrapInputStream(InputStream in)
protected NClobTrackerImpl	wrapNClob(NClob nclob)
protected ReaderTracker	wrapReader(Reader in)
protected RefTrackerImpl	wrapRef(Ref ref)
protected ResultSetMetaDataTrackerImpl	wrapResultSetMetaData(ResultSetMetaData metaData)
protected RowIdTrackerImpl	wrapRowId(RowId rowId)
protected SQLXMLTrackerImpl	wrapSQLXML(SQLXML sqlXml)

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

getArray, getArray, getAsciiStream, getAsciiStream, getBinaryStream, getBinaryStream, getBlob, getBlob, getCharacterStream, getCharacterStream, getClob, getClob, getConnectionWrapper, getMetaData, getNCharacterStream, getNCharacterStream, getNClob, getNClob, getRef, getRef, getRowId, getRowId, getSQLXML, getSQLXML, getStatement, getStatementWrapper, getUnicodeStream, getUnicodeStream, getWrapped, toString, unwrapArray, unwrapBlob, unwrapClob, unwrapInputStream, unwrapNClob, unwrapReader, unwrapRef, unwrapRowId, unwrapSQLXML, updateArray, updateArray, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateClob, updateClob, updateClob, updateClob, updateClob, updateClob, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateRef, updateRef, updateRowId, updateRowId, updateSQLXML, updateSQLXML, wrapStatement

Methods inherited from class java.lang.Object

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

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

absolute, afterLast, beforeFirst, cancelRowUpdates, clearWarnings, deleteRow, findColumn, first, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBigDecimal, getBigDecimal, getBinaryStream, getBinaryStream, getBlob, getBlob, getBoolean, getBoolean, getByte, getByte, getBytes, getBytes, getCharacterStream, getCharacterStream, getClob, getClob, getConcurrency, getCursorName, getDate, getDate, getDate, getDate, getDouble, getDouble, getFetchDirection, getFetchSize, getFloat, getFloat, getHoldability, getInt, getInt, getLong, getLong, getMetaData, getNCharacterStream, getNCharacterStream, getNClob, getNClob, getNString, getNString, getObject, getObject, getObject, getObject, getObject, getObject, getRef, getRef, getRow, getRowId, getRowId, getShort, getShort, getSQLXML, getSQLXML, getStatement, getString, getString, getTime, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getTimestamp, getType, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, getWrapped, insertRow, isAfterLast, isBeforeFirst, isClosed, isFirst, isLast, last, moveToCurrentRow, moveToInsertRow, next, previous, refreshRow, relative, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setFetchSize, updateArray, updateArray, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateBigDecimal, updateBigDecimal, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBoolean, updateBoolean, updateByte, updateByte, updateBytes, updateBytes, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateClob, updateClob, updateClob, updateClob, updateClob, updateClob, updateDate, updateDate, updateDouble, updateDouble, updateFloat, updateFloat, updateInt, updateInt, updateLong, updateLong, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNString, updateNString, updateNull, updateNull, updateObject, updateObject, updateObject, updateObject, updateObject, updateObject, updateObject, updateObject, updateRef, updateRef, updateRow, updateRowId, updateRowId, updateShort, updateShort, updateSQLXML, updateSQLXML, updateString, updateString, updateTime, updateTime, updateTimestamp, updateTimestamp, wasNull

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

ResultSetTrackerImpl

public ResultSetTrackerImpl(ConnectionTrackerImpl connectionTracker,
 StatementWrapperImpl stmtTracker,
 ResultSet wrapped)

Creates a new ResultSet 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()

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()

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()

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()

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()

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()

wrapArray

protected ArrayTrackerImpl wrapArray(Array array)

Overrides:

wrapArray in class ResultSetWrapperImpl

wrapBlob

protected BlobTrackerImpl wrapBlob(Blob blob)

Overrides:

wrapBlob in class ResultSetWrapperImpl

wrapClob

protected ClobTrackerImpl wrapClob(Clob clob)

Overrides:

wrapClob in class ResultSetWrapperImpl

wrapInputStream

protected InputStreamTracker wrapInputStream(InputStream in)

Overrides:

wrapInputStream in class ResultSetWrapperImpl

wrapNClob

protected NClobTrackerImpl wrapNClob(NClob nclob)

Overrides:

wrapNClob in class ResultSetWrapperImpl

wrapReader

protected ReaderTracker wrapReader(Reader in)

Overrides:

wrapReader in class ResultSetWrapperImpl

wrapRef

protected RefTrackerImpl wrapRef(Ref ref)

Overrides:

wrapRef in class ResultSetWrapperImpl

wrapResultSetMetaData

protected ResultSetMetaDataTrackerImpl wrapResultSetMetaData(ResultSetMetaData metaData)

Overrides:

wrapResultSetMetaData in class ResultSetWrapperImpl

wrapRowId

protected RowIdTrackerImpl wrapRowId(RowId rowId)

Overrides:

wrapRowId in class ResultSetWrapperImpl

wrapSQLXML

protected SQLXMLTrackerImpl wrapSQLXML(SQLXML sqlXml)

Overrides:

wrapSQLXML in class ResultSetWrapperImpl

close

public void close()
           throws SQLException

Calls onClose handlers, closes all tracked objects, then calls super.close().

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ResultSet

Specified by:

close in interface ResultSetTracker

Specified by:

close in interface ResultSetWrapper

Throws:

SQLException

See Also:

• ArrayWrapper.close()
• BlobWrapper.close()
• ClobWrapper.close()
• InputStreamTracker.close()
• ClobWrapper.close()
• ReaderTracker.close()
• RefTrackerImpl.close()
• ResultSetMetaDataTrackerImpl.close()
• RowIdTrackerImpl.close()
• SQLXMLWrapper.close()