Package org.apache.openjpa.jdbc.kernel

Class JDBCStoreManager.RefCountConnection

java.lang.Object

org.apache.openjpa.lib.jdbc.DelegatingConnection

org.apache.openjpa.jdbc.kernel.JDBCStoreManager.RefCountConnection

All Implemented Interfaces:

java.lang.AutoCloseable, java.sql.Connection, java.sql.Wrapper, Closeable

Enclosing class:

JDBCStoreManager

protected class JDBCStoreManager.RefCountConnection
extends DelegatingConnection

Connection wrapper that keeps an internal ref count so that it knows when to really close.

Field Summary

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
RefCountConnection(java.sql.Connection conn)

Method Summary

Modifier and Type	Method	Description
void	close()
protected java.sql.Statement	createStatement(boolean wrap)	Create a statement, with the option of not wrapping it in a DelegatingStatement, which is the default.
protected java.sql.Statement	createStatement(int rsType, int rsConcur, boolean wrap)	Create a statement, with the option of not wrapping it in a DelegatingStatement, which is the default.
void	free()
boolean	getRetain()
protected java.sql.PreparedStatement	prepareStatement(java.lang.String sql, boolean wrap)	Prepare a statement, with the option of not wrapping it in a DelegatingPreparedStatement, which is the default.
protected java.sql.PreparedStatement	prepareStatement(java.lang.String sql, int rsType, int rsConcur, boolean wrap)	Prepare a statement, with the option of not wrapping it in a DelegatingPreparedStatement, which is the default.
void	ref()
void	setRetain(boolean retain)

Methods inherited from class org.apache.openjpa.lib.jdbc.DelegatingConnection

abort, appendInfo, clearWarnings, commit, createArrayOf, createBlob, createClob, createNClob, createSQLXML, createStatement, createStatement, createStatement, createStatement, createStruct, equals, getAutoCommit, getCatalog, getClientInfo, getClientInfo, getDelegate, getHoldability, getInnermostDelegate, getMetaData, getMetaData, getNetworkTimeout, getSchema, getTransactionIsolation, getTypeMap, getWarnings, hashCode, isClosed, isReadOnly, isValid, isWrapperFor, nativeSQL, prepareCall, prepareCall, prepareCall, prepareCall, prepareCall, prepareCall, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, releaseSavepoint, rollback, rollback, setAutoCommit, setCatalog, setClientInfo, setClientInfo, setHoldability, setNetworkTimeout, setReadOnly, setSavepoint, setSavepoint, setSchema, setTransactionIsolation, setTypeMap, toString, unwrap

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.sql.Connection

beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid

Constructor Detail

RefCountConnection

public RefCountConnection(java.sql.Connection conn)

Method Detail

getRetain

public boolean getRetain()

setRetain

public void setRetain(boolean retain)

ref

public void ref()

close

public void close()
           throws java.sql.SQLException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface java.sql.Connection

Overrides:

close in class DelegatingConnection

Throws:

java.sql.SQLException

free

public void free()

createStatement

protected java.sql.Statement createStatement(boolean wrap)
                                      throws java.sql.SQLException

Description copied from class: DelegatingConnection

Create a statement, with the option of not wrapping it in a DelegatingStatement, which is the default.

Overrides:

createStatement in class DelegatingConnection

Throws:

java.sql.SQLException

createStatement

protected java.sql.Statement createStatement(int rsType,
                                             int rsConcur,
                                             boolean wrap)
                                      throws java.sql.SQLException

Description copied from class: DelegatingConnection

Create a statement, with the option of not wrapping it in a DelegatingStatement, which is the default.

Overrides:

createStatement in class DelegatingConnection

Throws:

java.sql.SQLException

prepareStatement

protected java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                      boolean wrap)
                                               throws java.sql.SQLException

Description copied from class: DelegatingConnection

Prepare a statement, with the option of not wrapping it in a DelegatingPreparedStatement, which is the default.

Overrides:

prepareStatement in class DelegatingConnection

Throws:

java.sql.SQLException

prepareStatement

protected java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                      int rsType,
                                                      int rsConcur,
                                                      boolean wrap)
                                               throws java.sql.SQLException

Description copied from class: DelegatingConnection

Prepare a statement, with the option of not wrapping it in a DelegatingPreparedStatement, which is the default.

Overrides:

prepareStatement in class DelegatingConnection

Throws:

java.sql.SQLException