org.enhydra.jdbc.standard

Class StandardConnectionHandle

java.lang.Object

org.enhydra.jdbc.util.JdbcUtil

org.enhydra.jdbc.core.CoreConnection

org.enhydra.jdbc.standard.StandardConnectionHandle

All Implemented Interfaces:

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

Direct Known Subclasses:

InformixConnectionHandle, StandardXAConnectionHandle, SybaseConnectionHandle

public class StandardConnectionHandle
extends CoreConnection

This is an implementation of java.sql.Connection which simply delegates almost everything to an underlying physical implemention of the same interface. It relies on a StandardPooledConnection to create it and to supply the physical connection and a cache of PreparedStatements. This class will try to re-use PreparedStatements wherever possible and will add to the cache when totally new PreparedStatements get created.

Field Summary

Fields

Modifier and Type	Field and Description
java.util.Hashtable	inUse
boolean	isReallyUsed
protected java.util.Hashtable	masterPrepStmtCache
protected LRUCache	preparedStatementCache

Fields inherited from class org.enhydra.jdbc.core.CoreConnection

con

Fields inherited from class org.enhydra.jdbc.util.JdbcUtil

log

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors

Constructor and Description
StandardConnectionHandle(StandardPooledConnection pooledCon, java.util.Hashtable preparedStatementCache, int preparedStmtCacheSize) Constructor.

Method Summary

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)

Methods inherited from class org.enhydra.jdbc.core.CoreConnection

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

Methods inherited from class org.enhydra.jdbc.util.JdbcUtil

setLogger

Methods inherited from class java.lang.Object

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

Field Detail

masterPrepStmtCache

protected java.util.Hashtable masterPrepStmtCache

preparedStatementCache

protected LRUCache preparedStatementCache

inUse

public java.util.Hashtable inUse

isReallyUsed

public boolean isReallyUsed

Constructor Detail

StandardConnectionHandle

public StandardConnectionHandle(StandardPooledConnection pooledCon,
                                java.util.Hashtable preparedStatementCache,
                                int preparedStmtCacheSize)

Constructor.

Method Detail

setupPreparedStatementCache

protected void setupPreparedStatementCache()

preInvoke

public void preInvoke()
               throws java.sql.SQLException

Pre-invokation of the delegation, in case of connection is closed, we throw an exception

Specified by:

preInvoke in class CoreConnection

Throws:

java.sql.SQLException

catchInvoke

public void catchInvoke(java.sql.SQLException e)
                 throws java.sql.SQLException

Exception management : catch or throw the exception

Specified by:

catchInvoke in class CoreConnection

Throws:

java.sql.SQLException

close

public void close()
           throws java.sql.SQLException

Closes this StandardConnectionHandle and prevents it from being reused. It also returns used PreparedStatements to the PreparedStatement cache and notifies all listeners.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.sql.Connection

Overrides:

close in class CoreConnection

Throws:

java.sql.SQLException

createPreparedStatement

protected java.sql.PreparedStatement createPreparedStatement(java.lang.String sql,
                                                             int type,
                                                             int concurrency,
                                                             int holdability)
                                                      throws java.sql.SQLException

Throws:

java.sql.SQLException

createPreparedStatement

protected java.sql.PreparedStatement createPreparedStatement(java.lang.String sql,
                                                             int autogeneratedkeys)
                                                      throws java.sql.SQLException

Throws:

java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql)
                                            throws java.sql.SQLException

Creates a PreparedStatement for the given SQL. If possible, the statement is fetched from the cache.

Specified by:

prepareStatement in interface java.sql.Connection

Overrides:

prepareStatement in class CoreConnection

Throws:

java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   int resultSetType,
                                                   int resultSetConcurrency)
                                            throws java.sql.SQLException

Creates a PreparedStatement for the given SQL, type and concurrency. If possible, the statement is fetched from the cache.

Specified by:

prepareStatement in interface java.sql.Connection

Overrides:

prepareStatement in class CoreConnection

Throws:

java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   int resultSetType,
                                                   int resultSetConcurrency,
                                                   int resultSetHoldability)
                                            throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Overrides:

prepareStatement in class CoreConnection

Throws:

java.sql.SQLException

isClosed

public boolean isClosed()
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

prepareCall

public java.sql.CallableStatement prepareCall(java.lang.String sql,
                                              int resultSetType,
                                              int resultSetConcurrency)
                                       throws java.sql.SQLException

Throws:

java.sql.SQLException

getNetworkTimeout

public int getNetworkTimeout()
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

setNetworkTimeout

public void setNetworkTimeout(java.util.concurrent.Executor executor,
                              int timeout)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

abort

public void abort(java.util.concurrent.Executor executor)
           throws java.sql.SQLException

Throws:

java.sql.SQLException

getSchema

public java.lang.String getSchema()
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

setSchema

public void setSchema(java.lang.String schema)
               throws java.sql.SQLException

Throws:

java.sql.SQLException

createStruct

public java.sql.Struct createStruct(java.lang.String typeName,
                                    java.lang.Object[] attributes)
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

createArrayOf

public java.sql.Array createArrayOf(java.lang.String typeName,
                                    java.lang.Object[] elements)
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getClientInfo

public java.util.Properties getClientInfo()
                                   throws java.sql.SQLException

Throws:

java.sql.SQLException

getClientInfo

public java.lang.String getClientInfo(java.lang.String name)
                               throws java.sql.SQLException

Throws:

java.sql.SQLException

setClientInfo

public void setClientInfo(java.util.Properties properties)
                   throws java.sql.SQLClientInfoException

Throws:

java.sql.SQLClientInfoException

setClientInfo

public void setClientInfo(java.lang.String name,
                          java.lang.String value)
                   throws java.sql.SQLClientInfoException

Throws:

java.sql.SQLClientInfoException

isValid

public boolean isValid(int timeout)
                throws java.sql.SQLException

Throws:

java.sql.SQLException

createSQLXML

public java.sql.SQLXML createSQLXML()
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

createNClob

public java.sql.NClob createNClob()
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

createBlob

public java.sql.Blob createBlob()
                         throws java.sql.SQLException

Throws:

java.sql.SQLException

createClob

public java.sql.Clob createClob()
                         throws java.sql.SQLException

Throws:

java.sql.SQLException

isWrapperFor

public boolean isWrapperFor(java.lang.Class<?> iface)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

unwrap

public <T> T unwrap(java.lang.Class<T> iface)
             throws java.sql.SQLException

Throws:

java.sql.SQLException

setBlob

public void setBlob(int parameterIndex,
                    java.io.InputStream inputStream,
                    long length)
             throws java.sql.SQLException

Throws:

java.sql.SQLException