public final class PooledConnection extends Object implements Connection
Connection that works with the PooledConnectionMgr. Closing this connection marks it as closed and
returns it to the pool.
The connection can be retrieved and closed as many times as needed. It is very important that a connection be closed after use (this is true for all connections, pooled or regular).
Typically one does so by saying:
Connection con;
try {
con = [..get either a pooled or regular connection..]
..use..
con.commit(); //if transactional
}
catch (SQLException e) {
con.rollback(); //if transactional
}
finally {
con.close(); //always (transactional or not)
}
Super Important: transactions are not rolled back or committed when close is
invoked. You must either commit or rollback the transaction if in transaction mode (ie you
have called setAutoCommit(false) on this connection). Returning the connection (via close)
back to the pool without committing/rolling-back will keep the prior statements around and those will
be committed/rolledback at a later date if commit/rollback is invoked upon retrieving/using the connection
again.TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE| Constructor and Description |
|---|
PooledConnection(PooledConnectionMgr pool,
Connection con)
Creates a initially open pooled connection that wraps the
specified jdbc connection.
|
public PooledConnection(PooledConnectionMgr pool, Connection con)
public void close() throws SQLException
close is invoked. You must either commit or
rollback the transaction if in transaction mode (ie you have called setAutoCommit(false) on this
connection).
eturning the connection (via close) back to the pool without committing/rolling-back will keep the prior statements around and those will be committed/rolledback at a later date if commit/rollback is invoked upon retrieving/using the connection again.
close in interface AutoCloseableclose in interface ConnectionSQLExceptionpublic boolean isClosed()
isClosed in interface Connectionpublic PreparedStatement getCachedPreparedStatement(String sql) throws SQLException
SQLExceptionpublic void clearWarnings() throws SQLException
clearWarnings in interface ConnectionSQLExceptionpublic void commit() throws SQLException
commit in interface ConnectionSQLExceptionpublic Statement createStatement() throws SQLException
createStatement in interface ConnectionSQLExceptionpublic Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException
createStatement in interface ConnectionSQLExceptionpublic boolean getAutoCommit() throws SQLException
getAutoCommit in interface ConnectionSQLExceptionpublic String getCatalog() throws SQLException
getCatalog in interface ConnectionSQLExceptionpublic DatabaseMetaData getMetaData() throws SQLException
getMetaData in interface ConnectionSQLExceptionpublic int getTransactionIsolation() throws SQLException
getTransactionIsolation in interface ConnectionSQLExceptionpublic Map getTypeMap() throws SQLException
getTypeMap in interface ConnectionSQLExceptionpublic SQLWarning getWarnings() throws SQLException
getWarnings in interface ConnectionSQLExceptionpublic boolean isReadOnly() throws SQLException
isReadOnly in interface ConnectionSQLExceptionpublic String nativeSQL(String sql) throws SQLException
nativeSQL in interface ConnectionSQLExceptionpublic CallableStatement prepareCall(String sql) throws SQLException
prepareCall in interface ConnectionSQLExceptionpublic CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency) throws SQLException
prepareCall in interface ConnectionSQLExceptionpublic PreparedStatement prepareStatement(String sql) throws SQLException
prepareStatement in interface ConnectionSQLExceptionpublic PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException
prepareStatement in interface ConnectionSQLExceptionpublic void rollback() throws SQLException
rollback in interface ConnectionSQLExceptionpublic void setAutoCommit(boolean b) throws SQLException
setAutoCommit in interface ConnectionSQLExceptionpublic void setCatalog(String catalog) throws SQLException
setCatalog in interface ConnectionSQLExceptionpublic void setReadOnly(boolean readOnly) throws SQLException
setReadOnly in interface ConnectionSQLExceptionpublic void setTransactionIsolation(int level) throws SQLException
setTransactionIsolation in interface ConnectionSQLExceptionpublic void setTypeMap(Map map) throws SQLException
setTypeMap in interface ConnectionSQLExceptionpublic int getHoldability() throws SQLException
getHoldability in interface ConnectionSQLExceptionpublic void setHoldability(int holdability) throws SQLException
setHoldability in interface ConnectionSQLExceptionpublic Savepoint setSavepoint() throws SQLException
setSavepoint in interface ConnectionSQLExceptionpublic Savepoint setSavepoint(String name) throws SQLException
setSavepoint in interface ConnectionSQLExceptionpublic void rollback(Savepoint savepoint) throws SQLException
rollback in interface ConnectionSQLExceptionpublic void releaseSavepoint(Savepoint savepoint) throws SQLException
releaseSavepoint in interface ConnectionSQLExceptionpublic Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
createStatement in interface ConnectionSQLExceptionpublic Struct createStruct(String str, Object[] arr) throws SQLException
createStruct in interface ConnectionSQLExceptionpublic Properties getClientInfo() throws SQLException
getClientInfo in interface ConnectionSQLExceptionpublic String getClientInfo(String name) throws SQLException
getClientInfo in interface ConnectionSQLExceptionpublic void setClientInfo(String key, String val) throws SQLClientInfoException
setClientInfo in interface ConnectionSQLClientInfoExceptionpublic void setClientInfo(Properties props) throws SQLClientInfoException
setClientInfo in interface ConnectionSQLClientInfoExceptionpublic Array createArrayOf(String str, Object[] arr) throws SQLException
createArrayOf in interface ConnectionSQLExceptionpublic Blob createBlob() throws SQLException
createBlob in interface ConnectionSQLExceptionpublic Clob createClob() throws SQLException
createClob in interface ConnectionSQLExceptionpublic NClob createNClob() throws SQLException
createNClob in interface ConnectionSQLExceptionpublic SQLXML createSQLXML() throws SQLException
createSQLXML in interface ConnectionSQLExceptionpublic boolean isValid(int timeout) throws SQLException
isValid in interface ConnectionSQLExceptionpublic boolean isWrapperFor(Class iface) throws SQLException
isWrapperFor in interface WrapperSQLExceptionpublic Object unwrap(Class iface) throws SQLException
unwrap in interface WrapperSQLExceptionpublic PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
prepareStatement in interface ConnectionSQLExceptionpublic CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
prepareCall in interface ConnectionSQLExceptionpublic PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException
prepareStatement in interface ConnectionSQLExceptionpublic PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException
prepareStatement in interface ConnectionSQLExceptionpublic PreparedStatement prepareStatement(String sql, String[] columnNames) throws SQLException
prepareStatement in interface ConnectionSQLExceptionpublic int getNetworkTimeout() throws SQLException
getNetworkTimeout in interface ConnectionSQLExceptionpublic void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException
setNetworkTimeout in interface ConnectionSQLExceptionpublic void abort(Executor executor) throws SQLException
abort in interface ConnectionSQLExceptionpublic String getSchema() throws SQLException
getSchema in interface ConnectionSQLExceptionpublic void setSchema(String schema) throws SQLException
setSchema in interface ConnectionSQLException