org.mule.extension.db.internal

Class StatementStreamingResultSetCloser

java.lang.Object

org.mule.extension.db.internal.result.statement.AbstractStreamingResultSetCloser

org.mule.extension.db.internal.StatementStreamingResultSetCloser

All Implemented Interfaces:

StreamingResultSetCloser

public class StatementStreamingResultSetCloser
extends AbstractStreamingResultSetCloser

Closes a ResultSet once it has been processed

Since:

4.0

Field Summary

Fields inherited from class org.mule.extension.db.internal.result.statement.AbstractStreamingResultSetCloser

LOGGER

Constructor Summary

Constructors

Constructor and Description
StatementStreamingResultSetCloser()
StatementStreamingResultSetCloser(boolean autoCloseConnection)

Method Summary

Modifier and Type	Method and Description
protected void	checkValidConnectionLock(DbConnection connection, Object connectionLock)
void	close(DbConnection connection, ResultSet resultSet) Closes the given resultset.
void	closeResultSets(DbConnection connection) Closes all tracked ResultSets for the passed connection.
protected Object	getConnectionLock(DbConnection connection)
protected Set<ResultSet>	getConnectionResultSets(DbConnection connection, ResultSet resultSet)
protected int	getLocksCount()
protected Optional<Object>	getTrackedConnectionLock(DbConnection connection)
protected void	releaseResources(DbConnection connection)
void	trackResultSet(DbConnection connection, ResultSet resultSet) Adds a resultSet for tracking in order to be able to close it later

Methods inherited from class java.lang.Object

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

Constructor Detail

StatementStreamingResultSetCloser

public StatementStreamingResultSetCloser()

StatementStreamingResultSetCloser

public StatementStreamingResultSetCloser(boolean autoCloseConnection)

Method Detail

closeResultSets

public void closeResultSets(DbConnection connection)

Closes all tracked ResultSets for the passed connection.

Parameters:

connection -

close

public void close(DbConnection connection,
                  ResultSet resultSet)

Description copied from interface: StreamingResultSetCloser

Closes the given resultset. It also must invoke DbConnection.endStreaming() and DbConnection.release() even if the operation fails

Specified by:

close in interface StreamingResultSetCloser

Overrides:

close in class AbstractStreamingResultSetCloser

Parameters:

connection - the connection to the DB

resultSet - the ResultSet

trackResultSet

public void trackResultSet(DbConnection connection,
                           ResultSet resultSet)

Adds a resultSet for tracking in order to be able to close it later

Parameters:

connection - connection that holds the resultSet

resultSet - resultSet to track

getTrackedConnectionLock

protected Optional<Object> getTrackedConnectionLock(DbConnection connection)

releaseResources

protected void releaseResources(DbConnection connection)

getConnectionResultSets

protected Set<ResultSet> getConnectionResultSets(DbConnection connection,
                                                 ResultSet resultSet)

checkValidConnectionLock

protected void checkValidConnectionLock(DbConnection connection,
                                        Object connectionLock)

getConnectionLock

protected Object getConnectionLock(DbConnection connection)

getLocksCount

protected int getLocksCount()