public class StandardConnectionHandle extends CoreConnection
Modifier and Type | Field and Description |
---|---|
java.util.Hashtable |
inUse |
boolean |
isReallyUsed |
protected java.util.Hashtable |
masterPrepStmtCache |
protected LRUCache |
preparedStatementCache |
con
Constructor and Description |
---|
StandardConnectionHandle(StandardPooledConnection pooledCon,
java.util.Hashtable preparedStatementCache,
int preparedStmtCacheSize)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
abort(java.util.concurrent.Executor executor) |
void |
catchInvoke(java.sql.SQLException e)
Exception management : catch or throw the exception
|
void |
close()
Closes this StandardConnectionHandle and prevents it
from being reused.
|
java.sql.Array |
createArrayOf(java.lang.String typeName,
java.lang.Object[] elements) |
java.sql.Blob |
createBlob() |
java.sql.Clob |
createClob() |
java.sql.NClob |
createNClob() |
protected java.sql.PreparedStatement |
createPreparedStatement(java.lang.String sql,
int autogeneratedkeys) |
protected java.sql.PreparedStatement |
createPreparedStatement(java.lang.String sql,
int type,
int concurrency,
int holdability) |
java.sql.SQLXML |
createSQLXML() |
java.sql.Struct |
createStruct(java.lang.String typeName,
java.lang.Object[] attributes) |
java.util.Properties |
getClientInfo() |
java.lang.String |
getClientInfo(java.lang.String name) |
int |
getNetworkTimeout() |
java.lang.String |
getSchema() |
boolean |
isClosed() |
boolean |
isValid(int timeout) |
boolean |
isWrapperFor(java.lang.Class<?> iface) |
void |
preInvoke()
Pre-invokation of the delegation, in case of connection is
closed, we throw an exception
|
java.sql.CallableStatement |
prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql)
Creates a PreparedStatement for the given SQL.
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency)
Creates a PreparedStatement for the given SQL, type and concurrency.
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
void |
setBlob(int parameterIndex,
java.io.InputStream inputStream,
long length) |
void |
setClientInfo(java.util.Properties properties) |
void |
setClientInfo(java.lang.String name,
java.lang.String value) |
void |
setNetworkTimeout(java.util.concurrent.Executor executor,
int timeout) |
void |
setSchema(java.lang.String schema) |
protected void |
setupPreparedStatementCache() |
<T> T |
unwrap(java.lang.Class<T> iface) |
clearWarnings, commit, createStatement, createStatement, createStatement, getAutoCommit, getCatalog, getHoldability, getMetaData, getTransactionIsolation, getTypeMap, getWarnings, isReadOnly, nativeSQL, prepareCall, prepareCall, prepareStatement, prepareStatement, prepareStatement, releaseSavepoint, rollback, rollback, setAutoCommit, setCatalog, setHoldability, setReadOnly, setSavepoint, setSavepoint, setTransactionIsolation, setTypeMap
protected java.util.Hashtable masterPrepStmtCache
protected LRUCache preparedStatementCache
public java.util.Hashtable inUse
public boolean isReallyUsed
public StandardConnectionHandle(StandardPooledConnection pooledCon, java.util.Hashtable preparedStatementCache, int preparedStmtCacheSize)
protected void setupPreparedStatementCache()
public void preInvoke() throws java.sql.SQLException
preInvoke
in class CoreConnection
java.sql.SQLException
public void catchInvoke(java.sql.SQLException e) throws java.sql.SQLException
catchInvoke
in class CoreConnection
java.sql.SQLException
public void close() throws java.sql.SQLException
close
in interface java.lang.AutoCloseable
close
in interface java.sql.Connection
close
in class CoreConnection
java.sql.SQLException
protected java.sql.PreparedStatement createPreparedStatement(java.lang.String sql, int type, int concurrency, int holdability) throws java.sql.SQLException
java.sql.SQLException
protected java.sql.PreparedStatement createPreparedStatement(java.lang.String sql, int autogeneratedkeys) throws java.sql.SQLException
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
prepareStatement
in class CoreConnection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
prepareStatement
in class CoreConnection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
prepareStatement
in class CoreConnection
java.sql.SQLException
public boolean isClosed() throws java.sql.SQLException
java.sql.SQLException
public java.sql.CallableStatement prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
java.sql.SQLException
public int getNetworkTimeout() throws java.sql.SQLException
java.sql.SQLException
public void setNetworkTimeout(java.util.concurrent.Executor executor, int timeout) throws java.sql.SQLException
java.sql.SQLException
public void abort(java.util.concurrent.Executor executor) throws java.sql.SQLException
java.sql.SQLException
public java.lang.String getSchema() throws java.sql.SQLException
java.sql.SQLException
public void setSchema(java.lang.String schema) throws java.sql.SQLException
java.sql.SQLException
public java.sql.Struct createStruct(java.lang.String typeName, java.lang.Object[] attributes) throws java.sql.SQLException
java.sql.SQLException
public java.sql.Array createArrayOf(java.lang.String typeName, java.lang.Object[] elements) throws java.sql.SQLException
java.sql.SQLException
public java.util.Properties getClientInfo() throws java.sql.SQLException
java.sql.SQLException
public java.lang.String getClientInfo(java.lang.String name) throws java.sql.SQLException
java.sql.SQLException
public void setClientInfo(java.util.Properties properties) throws java.sql.SQLClientInfoException
java.sql.SQLClientInfoException
public void setClientInfo(java.lang.String name, java.lang.String value) throws java.sql.SQLClientInfoException
java.sql.SQLClientInfoException
public boolean isValid(int timeout) throws java.sql.SQLException
java.sql.SQLException
public java.sql.SQLXML createSQLXML() throws java.sql.SQLException
java.sql.SQLException
public java.sql.NClob createNClob() throws java.sql.SQLException
java.sql.SQLException
public java.sql.Blob createBlob() throws java.sql.SQLException
java.sql.SQLException
public java.sql.Clob createClob() throws java.sql.SQLException
java.sql.SQLException
public boolean isWrapperFor(java.lang.Class<?> iface) throws java.sql.SQLException
java.sql.SQLException
public <T> T unwrap(java.lang.Class<T> iface) throws java.sql.SQLException
java.sql.SQLException
public void setBlob(int parameterIndex, java.io.InputStream inputStream, long length) throws java.sql.SQLException
java.sql.SQLException