org.apache.cayenne.conn
Class ConnectionWrapper
java.lang.Object
org.apache.cayenne.conn.ConnectionWrapper
- All Implemented Interfaces:
- java.sql.Connection
public class ConnectionWrapper
- extends java.lang.Object
- implements java.sql.Connection
ConnectionWrapper is a java.sql.Connection
implementation that wraps
another Connection, delegating method calls to this connection. It works in conjunction
with PooledConnectionImpl, to generate pool events, provide limited automated
reconnection functionality, etc.
Fields inherited from interface java.sql.Connection |
TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE |
Method Summary |
void |
abort(java.util.concurrent.Executor executor)
|
void |
clearWarnings()
|
void |
close()
|
void |
commit()
|
java.sql.Array |
createArrayOf(java.lang.String arg0,
java.lang.Object[] arg1)
|
java.sql.Blob |
createBlob()
|
java.sql.Clob |
createClob()
|
NClob |
createNClob()
|
SQLXML |
createSQLXML()
|
java.sql.Statement |
createStatement()
|
java.sql.Statement |
createStatement(int resultSetType,
int resultSetConcurrency)
|
java.sql.Statement |
createStatement(int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
java.sql.Struct |
createStruct(java.lang.String arg0,
java.lang.Object[] arg1)
|
boolean |
getAutoCommit()
|
java.lang.String |
getCatalog()
|
java.util.Properties |
getClientInfo()
|
java.lang.String |
getClientInfo(java.lang.String arg0)
|
int |
getHoldability()
|
java.sql.DatabaseMetaData |
getMetaData()
|
int |
getNetworkTimeout()
|
java.lang.String |
getSchema()
|
int |
getTransactionIsolation()
|
java.util.Map<java.lang.String,java.lang.Class<?>> |
getTypeMap()
|
java.sql.SQLWarning |
getWarnings()
|
boolean |
isClosed()
|
boolean |
isReadOnly()
|
boolean |
isValid(int arg0)
|
boolean |
isWrapperFor(java.lang.Class<?> iface)
|
java.lang.String |
nativeSQL(java.lang.String sql)
|
java.sql.CallableStatement |
prepareCall(java.lang.String sql)
|
java.sql.CallableStatement |
prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency)
|
java.sql.CallableStatement |
prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int autoGeneratedKeys)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int[] columnIndexes)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
java.lang.String[] columnNames)
|
protected void |
reconnect(java.sql.SQLException exception)
|
void |
releaseSavepoint(java.sql.Savepoint savepoint)
|
protected void |
retire(java.sql.SQLException exception)
|
void |
rollback()
|
void |
rollback(java.sql.Savepoint savepoint)
|
void |
setAutoCommit(boolean autoCommit)
|
void |
setCatalog(java.lang.String catalog)
|
void |
setClientInfo(java.util.Properties properties)
|
void |
setClientInfo(java.lang.String name,
java.lang.String value)
|
void |
setHoldability(int holdability)
|
void |
setNetworkTimeout(java.util.concurrent.Executor executor,
int milliseconds)
|
void |
setReadOnly(boolean readOnly)
|
java.sql.Savepoint |
setSavepoint()
|
java.sql.Savepoint |
setSavepoint(java.lang.String name)
|
void |
setSchema(java.lang.String schema)
|
void |
setTransactionIsolation(int level)
|
void |
setTypeMap(java.util.Map<java.lang.String,java.lang.Class<?>> map)
|
|
unwrap(java.lang.Class<T> iface)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConnectionWrapper
public ConnectionWrapper(java.sql.Connection connection,
PooledConnectionImpl pooledConnection)
- Creates new ConnectionWrapper
reconnect
protected void reconnect(java.sql.SQLException exception)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
retire
protected void retire(java.sql.SQLException exception)
clearWarnings
public void clearWarnings()
throws java.sql.SQLException
- Specified by:
clearWarnings
in interface java.sql.Connection
- Throws:
java.sql.SQLException
close
public void close()
throws java.sql.SQLException
- Specified by:
close
in interface java.sql.Connection
- Throws:
java.sql.SQLException
commit
public void commit()
throws java.sql.SQLException
- Specified by:
commit
in interface java.sql.Connection
- Throws:
java.sql.SQLException
createStatement
public java.sql.Statement createStatement()
throws java.sql.SQLException
- Specified by:
createStatement
in interface java.sql.Connection
- Throws:
java.sql.SQLException
createStatement
public java.sql.Statement createStatement(int resultSetType,
int resultSetConcurrency)
throws java.sql.SQLException
- Specified by:
createStatement
in interface java.sql.Connection
- Throws:
java.sql.SQLException
getAutoCommit
public boolean getAutoCommit()
throws java.sql.SQLException
- Specified by:
getAutoCommit
in interface java.sql.Connection
- Throws:
java.sql.SQLException
getCatalog
public java.lang.String getCatalog()
throws java.sql.SQLException
- Specified by:
getCatalog
in interface java.sql.Connection
- Throws:
java.sql.SQLException
getMetaData
public java.sql.DatabaseMetaData getMetaData()
throws java.sql.SQLException
- Specified by:
getMetaData
in interface java.sql.Connection
- Throws:
java.sql.SQLException
getTransactionIsolation
public int getTransactionIsolation()
throws java.sql.SQLException
- Specified by:
getTransactionIsolation
in interface java.sql.Connection
- Throws:
java.sql.SQLException
getWarnings
public java.sql.SQLWarning getWarnings()
throws java.sql.SQLException
- Specified by:
getWarnings
in interface java.sql.Connection
- Throws:
java.sql.SQLException
isClosed
public boolean isClosed()
throws java.sql.SQLException
- Specified by:
isClosed
in interface java.sql.Connection
- Throws:
java.sql.SQLException
isReadOnly
public boolean isReadOnly()
throws java.sql.SQLException
- Specified by:
isReadOnly
in interface java.sql.Connection
- Throws:
java.sql.SQLException
nativeSQL
public java.lang.String nativeSQL(java.lang.String sql)
throws java.sql.SQLException
- Specified by:
nativeSQL
in interface java.sql.Connection
- Throws:
java.sql.SQLException
prepareCall
public java.sql.CallableStatement prepareCall(java.lang.String sql)
throws java.sql.SQLException
- Specified by:
prepareCall
in interface java.sql.Connection
- Throws:
java.sql.SQLException
prepareCall
public java.sql.CallableStatement prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency)
throws java.sql.SQLException
- Specified by:
prepareCall
in interface java.sql.Connection
- Throws:
java.sql.SQLException
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql)
throws java.sql.SQLException
- Specified by:
prepareStatement
in interface java.sql.Connection
- Throws:
java.sql.SQLException
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency)
throws java.sql.SQLException
- Specified by:
prepareStatement
in interface java.sql.Connection
- Throws:
java.sql.SQLException
rollback
public void rollback()
throws java.sql.SQLException
- Specified by:
rollback
in interface java.sql.Connection
- Throws:
java.sql.SQLException
setAutoCommit
public void setAutoCommit(boolean autoCommit)
throws java.sql.SQLException
- Specified by:
setAutoCommit
in interface java.sql.Connection
- Throws:
java.sql.SQLException
setCatalog
public void setCatalog(java.lang.String catalog)
throws java.sql.SQLException
- Specified by:
setCatalog
in interface java.sql.Connection
- Throws:
java.sql.SQLException
setReadOnly
public void setReadOnly(boolean readOnly)
throws java.sql.SQLException
- Specified by:
setReadOnly
in interface java.sql.Connection
- Throws:
java.sql.SQLException
setTransactionIsolation
public void setTransactionIsolation(int level)
throws java.sql.SQLException
- Specified by:
setTransactionIsolation
in interface java.sql.Connection
- Throws:
java.sql.SQLException
getTypeMap
public java.util.Map<java.lang.String,java.lang.Class<?>> getTypeMap()
throws java.sql.SQLException
- Specified by:
getTypeMap
in interface java.sql.Connection
- Throws:
java.sql.SQLException
setTypeMap
public void setTypeMap(java.util.Map<java.lang.String,java.lang.Class<?>> map)
throws java.sql.SQLException
- Specified by:
setTypeMap
in interface java.sql.Connection
- Throws:
java.sql.SQLException
setHoldability
public void setHoldability(int holdability)
throws java.sql.SQLException
- Specified by:
setHoldability
in interface java.sql.Connection
- Throws:
java.sql.SQLException
getHoldability
public int getHoldability()
throws java.sql.SQLException
- Specified by:
getHoldability
in interface java.sql.Connection
- Throws:
java.sql.SQLException
setSavepoint
public java.sql.Savepoint setSavepoint()
throws java.sql.SQLException
- Specified by:
setSavepoint
in interface java.sql.Connection
- Throws:
java.sql.SQLException
setSavepoint
public java.sql.Savepoint setSavepoint(java.lang.String name)
throws java.sql.SQLException
- Specified by:
setSavepoint
in interface java.sql.Connection
- Throws:
java.sql.SQLException
rollback
public void rollback(java.sql.Savepoint savepoint)
throws java.sql.SQLException
- Specified by:
rollback
in interface java.sql.Connection
- Throws:
java.sql.SQLException
releaseSavepoint
public void releaseSavepoint(java.sql.Savepoint savepoint)
throws java.sql.SQLException
- Specified by:
releaseSavepoint
in interface java.sql.Connection
- Throws:
java.sql.SQLException
createStatement
public java.sql.Statement createStatement(int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
throws java.sql.SQLException
- Specified by:
createStatement
in interface java.sql.Connection
- 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
- Throws:
java.sql.SQLException
prepareCall
public java.sql.CallableStatement prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
throws java.sql.SQLException
- Specified by:
prepareCall
in interface java.sql.Connection
- Throws:
java.sql.SQLException
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
int autoGeneratedKeys)
throws java.sql.SQLException
- Specified by:
prepareStatement
in interface java.sql.Connection
- Throws:
java.sql.SQLException
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
int[] columnIndexes)
throws java.sql.SQLException
- Specified by:
prepareStatement
in interface java.sql.Connection
- Throws:
java.sql.SQLException
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
java.lang.String[] columnNames)
throws java.sql.SQLException
- Specified by:
prepareStatement
in interface java.sql.Connection
- Throws:
java.sql.SQLException
createArrayOf
public java.sql.Array createArrayOf(java.lang.String arg0,
java.lang.Object[] arg1)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
createBlob
public java.sql.Blob createBlob()
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
createClob
public java.sql.Clob createClob()
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
createStruct
public java.sql.Struct createStruct(java.lang.String arg0,
java.lang.Object[] arg1)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
getClientInfo
public java.util.Properties getClientInfo()
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
getClientInfo
public java.lang.String getClientInfo(java.lang.String arg0)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
isValid
public boolean isValid(int arg0)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
isWrapperFor
public boolean isWrapperFor(java.lang.Class<?> iface)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
unwrap
public <T> T unwrap(java.lang.Class<T> iface)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
createNClob
public NClob createNClob()
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
createSQLXML
public SQLXML createSQLXML()
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.0
setClientInfo
public void setClientInfo(java.util.Properties properties)
throws SQLClientInfoException
- Throws:
SQLClientInfoException
- Since:
- 3.0
setClientInfo
public void setClientInfo(java.lang.String name,
java.lang.String value)
throws SQLClientInfoException
- Throws:
SQLClientInfoException
- Since:
- 3.0
setSchema
public void setSchema(java.lang.String schema)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.1
JDBC 4.1 compatibility under Java 1.5
getSchema
public java.lang.String getSchema()
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.1
JDBC 4.1 compatibility under Java 1.5
abort
public void abort(java.util.concurrent.Executor executor)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.1
JDBC 4.1 compatibility under Java 1.5
setNetworkTimeout
public void setNetworkTimeout(java.util.concurrent.Executor executor,
int milliseconds)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.1
JDBC 4.1 compatibility under Java 1.5
getNetworkTimeout
public int getNetworkTimeout()
throws java.sql.SQLException
- Throws:
java.sql.SQLException
- Since:
- 3.1
JDBC 4.1 compatibility under Java 1.5
Copyright © 2001-2012 Apache Cayenne. All Rights Reserved.