c3p0 0.10.1 · com.mchange.v2.c3p0.impl.NewPooledConnection

Modifier and Type	Field and Description
pack-priv final boolean	autoCommitOnClose
pack-priv volatile boolean	catalog_nondefault
pack-priv final ConnectionEventSupport	ces
pack-priv boolean	connection_error_signaled
pack-priv int	connection_status
pack-priv final int	connectionIsValidTimeout
pack-priv final ConnectionTester	connectionTester
pack-priv final String	dflt_catalog
pack-priv final int	dflt_holdability
pack-priv final boolean	dflt_readOnly
pack-priv final int	dflt_txn_isolation
pack-priv final Map<K, V>	dflt_typeMap
pack-priv volatile NewProxyConnection	exposedProxy
pack-priv final boolean	forceIgnoreUnresolvedTransactions
pack-priv volatile boolean	holdability_nondefault
pack-priv static Set<E>	holdabilityBugKeys
pack-priv Throwable	invalidatingException
pack-priv volatile boolean	isolation_lvl_nondefault
private static final MLogger	logger
pack-priv Set<E>	metaDataResultSets
private static final SQLException	NORMAL_CLOSE_PLACEHOLDER
pack-priv final Connection	physicalConnection
pack-priv final String	preferredTestQuery
pack-priv Set<E>	rawConnectionResultSets
pack-priv volatile boolean	readOnly_nondefault
pack-priv Map<K, V>	resultSetsForStatements
pack-priv GooGooStatementCache	scache
pack-priv final StatementEventSupport	ses
pack-priv final boolean	supports_setHoldability
pack-priv final boolean	supports_setReadOnly
pack-priv final boolean	supports_setTypeMap
pack-priv volatile boolean	typeMap_nondefault
pack-priv Set<E>	uncachedActiveStatements

Access	Constructor and Description
public	NewPooledConnection(Connection con, ConnectionTester connectionTester, int connectionIsValidTimeout, boolean autoCommitOnClose, boolean forceIgnoreUnresolvedTransactions, String preferredTestQuery, ConnectionCustomizer cc, String pdsIdt)

Method Summary

Modifier and Type	Method and Description
public void	addConnectionEventListener(ConnectionEventListener a component, usually the connection pool manager, that has implemented the `ConnectionEventListener` interface and wants to be notified when the connection is closed or has an error cel) Implements javax.sql.PooledConnection.addConnectionEventListener. Registers the given event listener so that it will be notified when an event occurs on this `PooledConnection` object.
public void	addStatementEventListener(StatementEventListener an component which implements the `StatementEventListener` interface that is to be registered with this `PooledConnection` object sel) Implements javax.sql.PooledConnection.addStatementEventListener. Registers a `StatementEventListener` with this `PooledConnection` object.
private static int	carefulCheckHoldability(Connection con)
private static boolean	carefulCheckReadOnly(Connection con)
private static Map<K, V>	carefulCheckTypeMap(Connection con)
private void	checkinAllCachedStatements(List<E> closeExceptions)
pack-priv synchronized void	checkinStatement(Statement stmt)
pack-priv synchronized Object	checkoutStatement(Method stmtProducingMethod, Object[] args)
private void	cleanupAllStatementResultSets(List<E> closeExceptions)
private void	cleanupResultSets(List<E> closeExceptions)
private void	cleanupStatementResultSets(Statement stmt)
private void	cleanupUncachedStatements(List<E> closeExceptions)
private void	cleanupUnclosedResultSetsSet(Set<E> rsSet, List<E> closeExceptions)
public synchronized void	close() Implements javax.sql.PooledConnection.close, com.mchange.v1.util.ClosableResource.close. Closes the physical connection that this `PooledConnection` object represents.
private void	close(Throwable cause)
private void	close(Throwable cause, boolean forced)
public synchronized void	closeAll()
private void	closeAllCachedStatements()
pack-priv synchronized void	closeMaybeCheckedOut(boolean checked_out) Implements abstract com.mchange.v2.c3p0.impl.AbstractC3P0PooledConnection.closeMaybeCheckedOut.
private void	fireConnectionClosed()
private void	fireConnectionErrorOccurred(SQLException error)
public synchronized Connection	getConnection() Implements javax.sql.PooledConnection.getConnection. Creates and returns a `Connection` object that is a handle for the physical connection that this `PooledConnection` object represents.
public synchronized int	getConnectionStatus()
pack-priv Connection	getPhysicalConnection() Implements abstract com.mchange.v2.c3p0.impl.AbstractC3P0PooledConnection.getPhysicalConnection.
public synchronized GooGooStatementCache	getStatementCache()
pack-priv SQLException	handleThrowable(Throwable t)
private static String	holdabilityBugKey(Connection con, Error err)
public synchronized void	initStatementCache(GooGooStatementCache scache) Implements abstract com.mchange.v2.c3p0.impl.AbstractC3P0PooledConnection.initStatementCache.
pack-priv synchronized boolean	isStatementCaching()
private static void	logCloseExceptions(Throwable cause, Collection<E> exceptions)
pack-priv synchronized void	markActiveMetaDataResultSet(ResultSet rs)
pack-priv synchronized void	markActiveRawConnectionResultSet(ResultSet rs)
pack-priv synchronized void	markActiveResultSetForStatement(Statement stmt, ResultSet rs)
pack-priv synchronized void	markActiveUncachedStatement(Statement stmt)
pack-priv void	markClosedProxyConnection(NewProxyConnection npc, boolean txn_known_resolved)
pack-priv synchronized void	markInactiveMetaDataResultSet(ResultSet rs)
pack-priv synchronized void	markInactiveRawConnectionResultSet(ResultSet rs)
pack-priv synchronized void	markInactiveResultSetForStatement(Statement stmt, ResultSet rs)
pack-priv synchronized void	markInactiveUncachedStatement(Statement stmt)
pack-priv void	markNewCatalog(String catalog)
pack-priv void	markNewHoldability(int holdability)
pack-priv void	markNewReadOnly(boolean readOnly)
pack-priv void	markNewTxnIsolation(int lvl)
pack-priv void	markNewTypeMap(Map<K, V> typeMap)
public void	printConnectionListeners()
public void	printStatementListeners()
public void	removeConnectionEventListener(ConnectionEventListener a component, usually the connection pool manager, that has implemented the `ConnectionEventListener` interface and been registered with this `PooledConnection` object as a listener cel) Implements javax.sql.PooledConnection.removeConnectionEventListener. Removes the given event listener from the list of components that will be notified when an event occurs on this `PooledConnection` object.
public void	removeStatementEventListener(StatementEventListener the component which implements the `StatementEventListener` interface that was previously registered with this `PooledConnection` object sel) Implements javax.sql.PooledConnection.removeStatementEventListener. Removes the specified `StatementEventListener` from the list of components that will be notified when the driver detects that a `PreparedStatement` has been closed or is invalid.
private void	reset(boolean txn_known_resolved)
private Set<E>	resultSets(Statement stmt, boolean create)
private void	updateConnectionStatus(int status)

Field Detail

autoCommitOnClose	back to summary
pack-priv final boolean autoCommitOnClose

catalog_nondefault	back to summary
pack-priv volatile boolean catalog_nondefault

ces	back to summary
pack-priv final ConnectionEventSupport ces

connection_error_signaled	back to summary
pack-priv boolean connection_error_signaled

connection_status	back to summary
pack-priv int connection_status

connectionIsValidTimeout	back to summary
pack-priv final int connectionIsValidTimeout

connectionTester	back to summary
pack-priv final ConnectionTester connectionTester

dflt_catalog	back to summary
pack-priv final String dflt_catalog

dflt_holdability	back to summary
pack-priv final int dflt_holdability

dflt_readOnly	back to summary
pack-priv final boolean dflt_readOnly

dflt_txn_isolation	back to summary
pack-priv final int dflt_txn_isolation

dflt_typeMap	back to summary
pack-priv final Map<K, V> dflt_typeMap

exposedProxy	back to summary
pack-priv volatile NewProxyConnection exposedProxy

forceIgnoreUnresolvedTransactions	back to summary
pack-priv final boolean forceIgnoreUnresolvedTransactions

holdability_nondefault	back to summary
pack-priv volatile boolean holdability_nondefault

holdabilityBugKeys	back to summary
pack-priv static Set<E> holdabilityBugKeys

invalidatingException	back to summary
pack-priv Throwable invalidatingException

isolation_lvl_nondefault	back to summary
pack-priv volatile boolean isolation_lvl_nondefault

logger	back to summary
private static final MLogger logger

metaDataResultSets	back to summary
pack-priv Set<E> metaDataResultSets

NORMAL_CLOSE_PLACEHOLDER	back to summary
private static final SQLException NORMAL_CLOSE_PLACEHOLDER

physicalConnection	back to summary
pack-priv final Connection physicalConnection

preferredTestQuery	back to summary
pack-priv final String preferredTestQuery

rawConnectionResultSets	back to summary
pack-priv Set<E> rawConnectionResultSets

readOnly_nondefault	back to summary
pack-priv volatile boolean readOnly_nondefault

resultSetsForStatements	back to summary
pack-priv Map<K, V> resultSetsForStatements

scache	back to summary
pack-priv GooGooStatementCache scache

ses	back to summary
pack-priv final StatementEventSupport ses

supports_setHoldability	back to summary
pack-priv final boolean supports_setHoldability

supports_setReadOnly	back to summary
pack-priv final boolean supports_setReadOnly

supports_setTypeMap	back to summary
pack-priv final boolean supports_setTypeMap

typeMap_nondefault	back to summary
pack-priv volatile boolean typeMap_nondefault

uncachedActiveStatements	back to summary
pack-priv Set<E> uncachedActiveStatements

Constructor Detail

NewPooledConnection	back to summary
public NewPooledConnection(Connection con, ConnectionTester connectionTester, int connectionIsValidTimeout, boolean autoCommitOnClose, boolean forceIgnoreUnresolvedTransactions, String preferredTestQuery, ConnectionCustomizer cc, String pdsIdt) throws SQLException

Method Detail

addConnectionEventListener back to summary

addConnectionEventListener	back to summary
public void addConnectionEventListener(ConnectionEventListener cel) Implements javax.sql.PooledConnection.addConnectionEventListener. Doc from javax.sql.PooledConnection.addConnectionEventListener. Registers the given event listener so that it will be notified when an event occurs on this `PooledConnection` object. Parameters cel:ConnectionEventListener a component, usually the connection pool manager, that has implemented the `ConnectionEventListener` interface and wants to be notified when the connection is closed or has an error

public void addConnectionEventListener(ConnectionEventListener cel)

Implements javax.sql.PooledConnection.addConnectionEventListener.

Doc from javax.sql.PooledConnection.addConnectionEventListener.

Registers the given event listener so that it will be notified when an event occurs on this PooledConnection object.

Parameters

cel:ConnectionEventListener: a component, usually the connection pool manager, that has implemented the ConnectionEventListener interface and wants to be notified when the connection is closed or has an error

addStatementEventListener back to summary

addStatementEventListener	back to summary
public void addStatementEventListener(StatementEventListener sel) Implements javax.sql.PooledConnection.addStatementEventListener. Doc from javax.sql.PooledConnection.addStatementEventListener. Registers a `StatementEventListener` with this `PooledConnection` object. Components that wish to be notified when `PreparedStatement`s created by the connection are closed or are detected to be invalid may use this method to register a `StatementEventListener` with this `PooledConnection` object. Parameters sel:StatementEventListener an component which implements the `StatementEventListener` interface that is to be registered with this `PooledConnection` object

public void addStatementEventListener(StatementEventListener sel)

Implements javax.sql.PooledConnection.addStatementEventListener.

Doc from javax.sql.PooledConnection.addStatementEventListener.

Registers a StatementEventListener with this PooledConnection object. Components that wish to be notified when PreparedStatements created by the connection are closed or are detected to be invalid may use this method to register a StatementEventListener with this PooledConnection object.

Parameters

sel:StatementEventListener: an component which implements the StatementEventListener interface that is to be registered with this PooledConnection object

carefulCheckHoldability	back to summary
private static int carefulCheckHoldability(Connection con)

carefulCheckReadOnly	back to summary
private static boolean carefulCheckReadOnly(Connection con)

carefulCheckTypeMap	back to summary
private static Map<K, V> carefulCheckTypeMap(Connection con)

checkinAllCachedStatements	back to summary
private void checkinAllCachedStatements(List<E> closeExceptions)

checkinStatement	back to summary
pack-priv synchronized void checkinStatement(Statement stmt) throws SQLException

checkoutStatement	back to summary
pack-priv synchronized Object checkoutStatement(Method stmtProducingMethod, Object[] args) throws SQLException

cleanupAllStatementResultSets	back to summary
private void cleanupAllStatementResultSets(List<E> closeExceptions)

cleanupResultSets	back to summary
private void cleanupResultSets(List<E> closeExceptions)

cleanupStatementResultSets	back to summary
private void cleanupStatementResultSets(Statement stmt)

cleanupUncachedStatements	back to summary
private void cleanupUncachedStatements(List<E> closeExceptions)

cleanupUnclosedResultSetsSet	back to summary
private void cleanupUnclosedResultSetsSet(Set<E> rsSet, List<E> closeExceptions)

close back to summary

public synchronized void close() throws SQLException

Implements javax.sql.PooledConnection.close, com.mchange.v1.util.ClosableResource.close.

Doc from javax.sql.PooledConnection.close.

Closes the physical connection that this PooledConnection object represents. An application never calls this method directly; it is called by the connection pool module, or manager.

See the interface description for more information.

Exceptions

SQLException:: if a database access error occurs

close	back to summary
private void close(Throwable cause) throws SQLException

close	back to summary
private void close(Throwable cause, boolean forced) throws SQLException

closeAll	back to summary
public synchronized void closeAll() throws SQLException

closeAllCachedStatements	back to summary
private void closeAllCachedStatements() throws SQLException

closeMaybeCheckedOut	back to summary
pack-priv synchronized void closeMaybeCheckedOut(boolean checked_out) throws SQLException Implements abstract com.mchange.v2.c3p0.impl.AbstractC3P0PooledConnection.closeMaybeCheckedOut.

fireConnectionClosed	back to summary
private void fireConnectionClosed()

fireConnectionErrorOccurred	back to summary
private void fireConnectionErrorOccurred(SQLException error)

getConnection back to summary

public synchronized Connection getConnection() throws SQLException

Implements javax.sql.PooledConnection.getConnection.

Doc from javax.sql.PooledConnection.getConnection.

Creates and returns a Connection object that is a handle for the physical connection that this PooledConnection object represents. The connection pool manager calls this method when an application has called the method DataSource.getConnection and there are no PooledConnection objects available. See the interface description for more information.

Returns:Connection

a Connection object that is a handle to this PooledConnection object

Exceptions

SQLException:: if a database access error occurs

getConnectionStatus	back to summary
public synchronized int getConnectionStatus()

getPhysicalConnection	back to summary
pack-priv Connection getPhysicalConnection() Implements abstract com.mchange.v2.c3p0.impl.AbstractC3P0PooledConnection.getPhysicalConnection.

getStatementCache	back to summary
public synchronized GooGooStatementCache getStatementCache()

handleThrowable	back to summary
pack-priv SQLException handleThrowable(Throwable t)

holdabilityBugKey	back to summary
private static String holdabilityBugKey(Connection con, Error err)

initStatementCache	back to summary
public synchronized void initStatementCache(GooGooStatementCache scache) Implements abstract com.mchange.v2.c3p0.impl.AbstractC3P0PooledConnection.initStatementCache.

isStatementCaching	back to summary
pack-priv synchronized boolean isStatementCaching()

logCloseExceptions	back to summary
private static void logCloseExceptions(Throwable cause, Collection<E> exceptions)

markActiveMetaDataResultSet	back to summary
pack-priv synchronized void markActiveMetaDataResultSet(ResultSet rs)

markActiveRawConnectionResultSet	back to summary
pack-priv synchronized void markActiveRawConnectionResultSet(ResultSet rs)

markActiveResultSetForStatement	back to summary
pack-priv synchronized void markActiveResultSetForStatement(Statement stmt, ResultSet rs)

markActiveUncachedStatement	back to summary
pack-priv synchronized void markActiveUncachedStatement(Statement stmt)

markClosedProxyConnection	back to summary
pack-priv void markClosedProxyConnection(NewProxyConnection npc, boolean txn_known_resolved)

markInactiveMetaDataResultSet	back to summary
pack-priv synchronized void markInactiveMetaDataResultSet(ResultSet rs)

markInactiveRawConnectionResultSet	back to summary
pack-priv synchronized void markInactiveRawConnectionResultSet(ResultSet rs)

markInactiveResultSetForStatement	back to summary
pack-priv synchronized void markInactiveResultSetForStatement(Statement stmt, ResultSet rs)

markInactiveUncachedStatement	back to summary
pack-priv synchronized void markInactiveUncachedStatement(Statement stmt)

markNewCatalog	back to summary
pack-priv void markNewCatalog(String catalog)

markNewHoldability	back to summary
pack-priv void markNewHoldability(int holdability)

markNewReadOnly	back to summary
pack-priv void markNewReadOnly(boolean readOnly)

markNewTxnIsolation	back to summary
pack-priv void markNewTxnIsolation(int lvl)

markNewTypeMap	back to summary
pack-priv void markNewTypeMap(Map<K, V> typeMap)

printConnectionListeners	back to summary
public void printConnectionListeners()

printStatementListeners	back to summary
public void printStatementListeners()

removeConnectionEventListener back to summary

public void removeConnectionEventListener(ConnectionEventListener cel)

Implements javax.sql.PooledConnection.removeConnectionEventListener.

Doc from javax.sql.PooledConnection.removeConnectionEventListener.

Removes the given event listener from the list of components that will be notified when an event occurs on this PooledConnection object.

Parameters

cel:ConnectionEventListener: a component, usually the connection pool manager, that has implemented the ConnectionEventListener interface and been registered with this PooledConnection object as a listener

removeStatementEventListener back to summary

public void removeStatementEventListener(StatementEventListener sel)

Implements javax.sql.PooledConnection.removeStatementEventListener.

Doc from javax.sql.PooledConnection.removeStatementEventListener.

Removes the specified StatementEventListener from the list of components that will be notified when the driver detects that a PreparedStatement has been closed or is invalid.

Parameters

sel:StatementEventListener: the component which implements the StatementEventListener interface that was previously registered with this PooledConnection object

reset	back to summary
private void reset(boolean txn_known_resolved) throws SQLException

resultSets	back to summary
private Set<E> resultSets(Statement stmt, boolean create)

updateConnectionStatus	back to summary
private void updateConnectionStatus(int status)

public final Class NewPooledConnection

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail