public final class SimonConnection extends Object implements Connection
Every method of this connection is implemented as call of real connection method. Several methods have added work with Simons (starting, stopping, etc.) for monitoring purposes.
From all statement-return-methods (createStatement(*),
prepareStatement(*), prepareCall(*)) connection returns own
implementation of statement classes. Those classes are also proxies and provides
additional Simons for monitoring features of JDBC driver.
org.javasimon.jdbc4.conn, stopwatch) - measure connection life and countorg.javasimon.jdbc4.conn.commits, counter) - measure executed commits of all connectionsorg.javasimon.jdbc4.conn.rollbacks, counter) - measure executed rollbacks of all connectionsConnectionTRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE| Constructor and Description |
|---|
SimonConnection(Connection conn,
String prefix)
Class constructor, initializes Simons (lifespan, active, commits
and rollbacks) related to the DB connection.
|
| Modifier and Type | Method and Description |
|---|---|
void |
abort(Executor executor) |
void |
clearWarnings() |
void |
close()
Closes the real connection, stops lifespan Simon and decreases the active Simon.
|
void |
commit()
Commits the real connection and increases the commits Simon.
|
Array |
createArrayOf(String s,
Object[] objects) |
Blob |
createBlob() |
Clob |
createClob() |
NClob |
createNClob() |
SQLXML |
createSQLXML() |
Statement |
createStatement()
Calls the real createStatement and wraps the returned statement by Simon's statement.
|
Statement |
createStatement(int rsType,
int rsConcurrency)
Calls real createStatement and wraps returned statement by Simon's statement.
|
Statement |
createStatement(int rsType,
int rsConcurrency,
int rsHoldability)
Calls real createStatement and wraps returned statement by Simon's statement.
|
Struct |
createStruct(String s,
Object[] objects) |
boolean |
getAutoCommit() |
String |
getCatalog() |
Properties |
getClientInfo() |
String |
getClientInfo(String s) |
int |
getHoldability() |
DatabaseMetaData |
getMetaData() |
int |
getNetworkTimeout() |
String |
getSchema() |
int |
getTransactionIsolation() |
Map<String,Class<?>> |
getTypeMap() |
SQLWarning |
getWarnings() |
boolean |
isClosed() |
boolean |
isReadOnly() |
boolean |
isValid(int i) |
boolean |
isWrapperFor(Class<?> iface) |
String |
nativeSQL(String s) |
CallableStatement |
prepareCall(String sql)
Calls real prepareCall and wraps returned statement by Simon's statement.
|
CallableStatement |
prepareCall(String sql,
int rsType,
int rsConcurrency)
Calls real prepareCall and wraps returned statement by Simon's statement.
|
CallableStatement |
prepareCall(String sql,
int rsType,
int rsConcurrency,
int rsHoldability)
Calls real prepareCall and wraps returned statement by Simon's statement.
|
PreparedStatement |
prepareStatement(String sql)
Calls real prepareStatement and wraps returned statement by Simon's statement.
|
PreparedStatement |
prepareStatement(String sql,
int autoGeneratedKeys)
Calls real prepareStatement and wraps returned statement by Simon's statement.
|
PreparedStatement |
prepareStatement(String sql,
int[] columnIndexes)
Calls real prepareStatement and wraps returned statement by Simon's statement.
|
PreparedStatement |
prepareStatement(String sql,
int rsType,
int rsConcurrency)
Calls real prepareStatement and wraps returned statement by Simon's statement.
|
PreparedStatement |
prepareStatement(String sql,
int rsType,
int rsConcurrency,
int rsHoldability)
Calls real prepareStatement and wraps returned statement by Simon's statement.
|
PreparedStatement |
prepareStatement(String sql,
String[] columnNames)
Calls real prepareStatement and wraps returned statement by Simon's statement.
|
void |
releaseSavepoint(Savepoint savepoint) |
void |
rollback()
Rollback the real connection and increase the rollbacks Simon.
|
void |
rollback(Savepoint savepoint)
Rollbacks the real connection and increases the rollbacks Simon.
|
void |
setAutoCommit(boolean b) |
void |
setCatalog(String s) |
void |
setClientInfo(Properties properties) |
void |
setClientInfo(String s,
String s1) |
void |
setHoldability(int i) |
void |
setNetworkTimeout(Executor executor,
int milliseconds) |
void |
setReadOnly(boolean b) |
Savepoint |
setSavepoint() |
Savepoint |
setSavepoint(String s) |
void |
setSchema(String schema) |
void |
setTransactionIsolation(int i) |
void |
setTypeMap(Map<String,Class<?>> stringClassMap) |
<T> T |
unwrap(Class<T> iface) |
public SimonConnection(Connection conn, String prefix)
conn - real DB connectionprefix - hierarchy prefix for connection Simonspublic void close() throws SQLException
close in interface AutoCloseableclose in interface ConnectionSQLException - if real operation failspublic void commit() throws SQLException
commit in interface ConnectionSQLException - if real commit failspublic void rollback() throws SQLException
rollback in interface ConnectionSQLException - if real operation failspublic void rollback(Savepoint savepoint) throws SQLException
rollback in interface Connectionsavepoint - the Savepoint object to roll back toSQLException - if real operation failspublic Statement createStatement() throws SQLException
createStatement in interface ConnectionSQLException - if real operation failspublic Statement createStatement(int rsType, int rsConcurrency) throws SQLException
createStatement in interface ConnectionrsType - result set typersConcurrency - result set concurrencySQLException - if real operation failspublic Statement createStatement(int rsType, int rsConcurrency, int rsHoldability) throws SQLException
createStatement in interface ConnectionrsType - result set typersConcurrency - result set concurrencyrsHoldability - result set holdabilitySQLException - if real operation failspublic PreparedStatement prepareStatement(String sql) throws SQLException
prepareStatement in interface Connectionsql - SQL statementSQLException - if real operation failspublic PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException
prepareStatement in interface Connectionsql - SQL statementautoGeneratedKeys - auto generated keysSQLException - if real operation failspublic PreparedStatement prepareStatement(String sql, int rsType, int rsConcurrency) throws SQLException
prepareStatement in interface Connectionsql - SQL statementrsType - result set typersConcurrency - result set concurrencySQLException - if real operation failspublic PreparedStatement prepareStatement(String sql, int rsType, int rsConcurrency, int rsHoldability) throws SQLException
prepareStatement in interface Connectionsql - SQL statementrsType - result set typersConcurrency - result set concurrencyrsHoldability - result set holdabilitySQLException - if real operation failspublic PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException
prepareStatement in interface Connectionsql - SQL statementcolumnIndexes - an array of column indexes indicating the columns
that should be returned from the inserted row or rowsSQLException - if real operation failspublic PreparedStatement prepareStatement(String sql, String[] columnNames) throws SQLException
prepareStatement in interface Connectionsql - SQL statementcolumnNames - an array of column names indicating the columns
that should be returned from the inserted row or rowsSQLException - if real operation failspublic CallableStatement prepareCall(String sql) throws SQLException
prepareCall in interface Connectionsql - an SQL statement, typically a JDBC function call escape stringSQLException - if real operation failspublic CallableStatement prepareCall(String sql, int rsType, int rsConcurrency) throws SQLException
prepareCall in interface Connectionsql - an SQL statement, typically a JDBC function call escape stringrsType - result set typersConcurrency - result set concurrencySQLException - if real operation failspublic CallableStatement prepareCall(String sql, int rsType, int rsConcurrency, int rsHoldability) throws SQLException
prepareCall in interface Connectionsql - an SQL statement, typically a JDBC function call escape stringrsType - result set typersConcurrency - result set concurrencyrsHoldability - result set holdabilitySQLException - if real operation failspublic String nativeSQL(String s) throws SQLException
nativeSQL in interface ConnectionSQLExceptionpublic void setAutoCommit(boolean b) throws SQLException
setAutoCommit in interface ConnectionSQLExceptionpublic boolean getAutoCommit() throws SQLException
getAutoCommit in interface ConnectionSQLExceptionpublic boolean isClosed() throws SQLException
isClosed in interface ConnectionSQLExceptionpublic DatabaseMetaData getMetaData() throws SQLException
getMetaData in interface ConnectionSQLExceptionpublic void setReadOnly(boolean b) throws SQLException
setReadOnly in interface ConnectionSQLExceptionpublic boolean isReadOnly() throws SQLException
isReadOnly in interface ConnectionSQLExceptionpublic void setCatalog(String s) throws SQLException
setCatalog in interface ConnectionSQLExceptionpublic String getCatalog() throws SQLException
getCatalog in interface ConnectionSQLExceptionpublic void setTransactionIsolation(int i) throws SQLException
setTransactionIsolation in interface ConnectionSQLExceptionpublic int getTransactionIsolation() throws SQLException
getTransactionIsolation in interface ConnectionSQLExceptionpublic SQLWarning getWarnings() throws SQLException
getWarnings in interface ConnectionSQLExceptionpublic void clearWarnings() throws SQLException
clearWarnings in interface ConnectionSQLExceptionpublic Map<String,Class<?>> getTypeMap() throws SQLException
getTypeMap in interface ConnectionSQLExceptionpublic void setTypeMap(Map<String,Class<?>> stringClassMap) throws SQLException
setTypeMap in interface ConnectionSQLExceptionpublic void setHoldability(int i) throws SQLException
setHoldability in interface ConnectionSQLExceptionpublic int getHoldability() throws SQLException
getHoldability in interface ConnectionSQLExceptionpublic Savepoint setSavepoint() throws SQLException
setSavepoint in interface ConnectionSQLExceptionpublic Savepoint setSavepoint(String s) throws SQLException
setSavepoint in interface ConnectionSQLExceptionpublic void releaseSavepoint(Savepoint savepoint) throws SQLException
releaseSavepoint in interface ConnectionSQLExceptionpublic Clob createClob() throws SQLException
createClob in interface ConnectionSQLExceptionpublic Blob createBlob() throws SQLException
createBlob in interface ConnectionSQLExceptionpublic NClob createNClob() throws SQLException
createNClob in interface ConnectionSQLExceptionpublic SQLXML createSQLXML() throws SQLException
createSQLXML in interface ConnectionSQLExceptionpublic boolean isValid(int i) throws SQLException
isValid in interface ConnectionSQLExceptionpublic void setClientInfo(String s, String s1) throws SQLClientInfoException
setClientInfo in interface ConnectionSQLClientInfoExceptionpublic void setClientInfo(Properties properties) throws SQLClientInfoException
setClientInfo in interface ConnectionSQLClientInfoExceptionpublic String getClientInfo(String s) throws SQLException
getClientInfo in interface ConnectionSQLExceptionpublic Properties getClientInfo() throws SQLException
getClientInfo in interface ConnectionSQLExceptionpublic Array createArrayOf(String s, Object[] objects) throws SQLException
createArrayOf in interface ConnectionSQLExceptionpublic Struct createStruct(String s, Object[] objects) throws SQLException
createStruct in interface ConnectionSQLExceptionpublic void setSchema(String schema) throws SQLException
setSchema in interface ConnectionSQLExceptionpublic String getSchema() throws SQLException
getSchema in interface ConnectionSQLExceptionpublic void abort(Executor executor) throws SQLException
abort in interface ConnectionSQLExceptionpublic void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException
setNetworkTimeout in interface ConnectionSQLExceptionpublic int getNetworkTimeout() throws SQLException
getNetworkTimeout in interface ConnectionSQLExceptionpublic <T> T unwrap(Class<T> iface) throws SQLException
unwrap in interface WrapperSQLExceptionpublic boolean isWrapperFor(Class<?> iface) throws SQLException
isWrapperFor in interface WrapperSQLExceptionCopyright © 2019. All rights reserved.