public class ConnectionSpy extends Object implements Connection, Spy
execTime
,
a long
defining the time elapsed to open the connection in ms.
(see SpyLogDelegator#connectionOpened(Spy, long)
for more details,
and modifications in DriverSpy#connect(String, Properties)
).
close()
in order to compute
execution time to close the connection (see SpyLogDelegator#connectionClosed(Spy, long),
or before an Exception
is thrown if a problem occurs.
)
ConnectionSpy#reportException(String, SQLException, long)
to log execution time before an Exception
is thrown when the connection closing failed.
TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE
Constructor and Description |
---|
ConnectionSpy(Connection realConnection,
long execTime,
SpyLogDelegator logDelegator)
Create a new ConnectionSpy that wraps a given Connection.
|
ConnectionSpy(Connection realConnection,
RdbmsSpecifics rdbmsSpecifics,
long execTime,
SpyLogDelegator logDelegator)
Create a new ConnectionSpy that wraps a given Connection.
|
ConnectionSpy(Connection realConnection,
RdbmsSpecifics rdbmsSpecifics,
SpyLogDelegator logDelegator)
Create a new ConnectionSpy that wraps a given Connection.
|
ConnectionSpy(Connection realConnection,
SpyLogDelegator logDelegator)
Create a new ConnectionSpy that wraps a given Connection.
|
Modifier and Type | Method and Description |
---|---|
void |
clearWarnings() |
void |
close() |
void |
commit() |
Array |
createArrayOf(String typeName,
Object[] elements) |
Blob |
createBlob() |
Clob |
createClob() |
NClob |
createNClob() |
SQLXML |
createSQLXML() |
Statement |
createStatement() |
Statement |
createStatement(int resultSetType,
int resultSetConcurrency) |
Statement |
createStatement(int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
Struct |
createStruct(String typeName,
Object[] attributes) |
boolean |
getAutoCommit() |
String |
getCatalog() |
String |
getClassType()
Get the type of class being spied upon.
|
Properties |
getClientInfo() |
String |
getClientInfo(String name) |
Integer |
getConnectionNumber()
Get the connection number.
|
int |
getHoldability() |
DatabaseMetaData |
getMetaData() |
static String |
getOpenConnectionsDump()
Get a dump of how many connections are open, and which connection numbers
are open.
|
Connection |
getRealConnection()
Get the real underlying Connection that this ConnectionSpy wraps.
|
int |
getTransactionIsolation() |
Map<String,Class<?>> |
getTypeMap() |
SQLWarning |
getWarnings() |
boolean |
isClosed() |
boolean |
isReadOnly() |
boolean |
isValid(int timeout) |
boolean |
isWrapperFor(Class<?> iface) |
String |
nativeSQL(String sql) |
CallableStatement |
prepareCall(String sql) |
CallableStatement |
prepareCall(String sql,
int resultSetType,
int resultSetConcurrency) |
CallableStatement |
prepareCall(String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
PreparedStatement |
prepareStatement(String sql) |
PreparedStatement |
prepareStatement(String sql,
int autoGeneratedKeys) |
PreparedStatement |
prepareStatement(String sql,
int[] columnIndexes) |
PreparedStatement |
prepareStatement(String sql,
int resultSetType,
int resultSetConcurrency) |
PreparedStatement |
prepareStatement(String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
PreparedStatement |
prepareStatement(String sql,
String[] columnNames) |
void |
releaseSavepoint(Savepoint savepoint) |
protected void |
reportAllReturns(String methodCall,
String returnValue) |
protected void |
reportException(String methodCall,
SQLException exception) |
protected void |
reportException(String methodCall,
SQLException exception,
long execTime) |
protected void |
reportException(String methodCall,
SQLException exception,
String sql) |
void |
rollback() |
void |
rollback(Savepoint savepoint) |
void |
setAutoCommit(boolean autoCommit) |
void |
setCatalog(String catalog) |
void |
setClientInfo(Properties properties) |
void |
setClientInfo(String name,
String value) |
void |
setHoldability(int holdability) |
void |
setReadOnly(boolean readOnly) |
Savepoint |
setSavepoint() |
Savepoint |
setSavepoint(String name) |
void |
setTransactionIsolation(int level) |
void |
setTypeMap(Map<String,Class<?>> map) |
<T> T |
unwrap(Class<T> iface) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
abort, getNetworkTimeout, getSchema, setNetworkTimeout, setSchema
public ConnectionSpy(Connection realConnection, SpyLogDelegator logDelegator)
realConnection
- "real" Connection that this ConnectionSpy wraps.logDelegator
- The SpyLogDelegator
used by
this ConnectionSpy
and all resources obtained from it
(StatementSpy
s, ...)public ConnectionSpy(Connection realConnection, long execTime, SpyLogDelegator logDelegator)
realConnection
- "real" Connection that this ConnectionSpy wraps.execTime
- a long
defining the time in ms
taken to open the connection to realConnection
.logDelegator
- The SpyLogDelegator
used by
this ConnectionSpy
and all resources obtained from it
(StatementSpy
s, ...)public ConnectionSpy(Connection realConnection, RdbmsSpecifics rdbmsSpecifics, SpyLogDelegator logDelegator)
realConnection
- "real" Connection that this ConnectionSpy wraps.rdbmsSpecifics
- the RdbmsSpecifics object for formatting logging appropriate for the Rdbms used.logDelegator
- The SpyLogDelegator
used by
this ConnectionSpy
and all resources obtained from it
(StatementSpy
s, ...)public ConnectionSpy(Connection realConnection, RdbmsSpecifics rdbmsSpecifics, long execTime, SpyLogDelegator logDelegator)
realConnection
- "real" Connection that this ConnectionSpy wraps.rdbmsSpecifics
- the RdbmsSpecifics object for formatting logging appropriate for the Rdbms used.execTime
- a long
defining the time in ms
taken to open the connection to realConnection
.
Should be equals to -1 if not used.logDelegator
- The SpyLogDelegator
used by
this ConnectionSpy
and all resources obtained from it
(StatementSpy
s, ...)public Connection getRealConnection()
public static String getOpenConnectionsDump()
public Integer getConnectionNumber()
Spy
getConnectionNumber
in interface Spy
public String getClassType()
Spy
getClassType
in interface Spy
protected void reportException(String methodCall, SQLException exception, String sql)
protected void reportException(String methodCall, SQLException exception)
protected void reportException(String methodCall, SQLException exception, long execTime)
public boolean isClosed() throws SQLException
isClosed
in interface Connection
SQLException
public SQLWarning getWarnings() throws SQLException
getWarnings
in interface Connection
SQLException
public Savepoint setSavepoint() throws SQLException
setSavepoint
in interface Connection
SQLException
public void releaseSavepoint(Savepoint savepoint) throws SQLException
releaseSavepoint
in interface Connection
SQLException
public void rollback(Savepoint savepoint) throws SQLException
rollback
in interface Connection
SQLException
public DatabaseMetaData getMetaData() throws SQLException
getMetaData
in interface Connection
SQLException
public void clearWarnings() throws SQLException
clearWarnings
in interface Connection
SQLException
public Statement createStatement() throws SQLException
createStatement
in interface Connection
SQLException
public Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException
createStatement
in interface Connection
SQLException
public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
createStatement
in interface Connection
SQLException
public void setReadOnly(boolean readOnly) throws SQLException
setReadOnly
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sql) throws SQLException
prepareStatement
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException
prepareStatement
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException
prepareStatement
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
prepareStatement
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException
prepareStatement
in interface Connection
SQLException
public Savepoint setSavepoint(String name) throws SQLException
setSavepoint
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sql, String[] columnNames) throws SQLException
prepareStatement
in interface Connection
SQLException
public Clob createClob() throws SQLException
createClob
in interface Connection
SQLException
public Blob createBlob() throws SQLException
createBlob
in interface Connection
SQLException
public NClob createNClob() throws SQLException
createNClob
in interface Connection
SQLException
public SQLXML createSQLXML() throws SQLException
createSQLXML
in interface Connection
SQLException
public boolean isValid(int timeout) throws SQLException
isValid
in interface Connection
SQLException
public void setClientInfo(String name, String value) throws SQLClientInfoException
setClientInfo
in interface Connection
SQLClientInfoException
public void setClientInfo(Properties properties) throws SQLClientInfoException
setClientInfo
in interface Connection
SQLClientInfoException
public String getClientInfo(String name) throws SQLException
getClientInfo
in interface Connection
SQLException
public Properties getClientInfo() throws SQLException
getClientInfo
in interface Connection
SQLException
public Array createArrayOf(String typeName, Object[] elements) throws SQLException
createArrayOf
in interface Connection
SQLException
public Struct createStruct(String typeName, Object[] attributes) throws SQLException
createStruct
in interface Connection
SQLException
public boolean isReadOnly() throws SQLException
isReadOnly
in interface Connection
SQLException
public void setHoldability(int holdability) throws SQLException
setHoldability
in interface Connection
SQLException
public CallableStatement prepareCall(String sql) throws SQLException
prepareCall
in interface Connection
SQLException
public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency) throws SQLException
prepareCall
in interface Connection
SQLException
public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
prepareCall
in interface Connection
SQLException
public void setCatalog(String catalog) throws SQLException
setCatalog
in interface Connection
SQLException
public String nativeSQL(String sql) throws SQLException
nativeSQL
in interface Connection
SQLException
public Map<String,Class<?>> getTypeMap() throws SQLException
getTypeMap
in interface Connection
SQLException
public void setAutoCommit(boolean autoCommit) throws SQLException
setAutoCommit
in interface Connection
SQLException
public String getCatalog() throws SQLException
getCatalog
in interface Connection
SQLException
public void setTypeMap(Map<String,Class<?>> map) throws SQLException
setTypeMap
in interface Connection
SQLException
public void setTransactionIsolation(int level) throws SQLException
setTransactionIsolation
in interface Connection
SQLException
public boolean getAutoCommit() throws SQLException
getAutoCommit
in interface Connection
SQLException
public int getHoldability() throws SQLException
getHoldability
in interface Connection
SQLException
public int getTransactionIsolation() throws SQLException
getTransactionIsolation
in interface Connection
SQLException
public void commit() throws SQLException
commit
in interface Connection
SQLException
public void rollback() throws SQLException
rollback
in interface Connection
SQLException
public void close() throws SQLException
close
in interface AutoCloseable
close
in interface Connection
SQLException
public <T> T unwrap(Class<T> iface) throws SQLException
unwrap
in interface Wrapper
SQLException
public boolean isWrapperFor(Class<?> iface) throws SQLException
isWrapperFor
in interface Wrapper
SQLException
Copyright © 2013 Bgee - Swiss Institute of Bioinformatics. All Rights Reserved.