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 connectionsConnection
TRANSACTION_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 AutoCloseable
close
in interface Connection
SQLException
- if real operation failspublic void commit() throws SQLException
commit
in interface Connection
SQLException
- if real commit failspublic void rollback() throws SQLException
rollback
in interface Connection
SQLException
- if real operation failspublic void rollback(Savepoint savepoint) throws SQLException
rollback
in interface Connection
savepoint
- the Savepoint
object to roll back toSQLException
- if real operation failspublic Statement createStatement() throws SQLException
createStatement
in interface Connection
SQLException
- if real operation failspublic Statement createStatement(int rsType, int rsConcurrency) throws SQLException
createStatement
in interface Connection
rsType
- result set typersConcurrency
- result set concurrencySQLException
- if real operation failspublic Statement createStatement(int rsType, int rsConcurrency, int rsHoldability) throws SQLException
createStatement
in interface Connection
rsType
- result set typersConcurrency
- result set concurrencyrsHoldability
- result set holdabilitySQLException
- if real operation failspublic PreparedStatement prepareStatement(String sql) throws SQLException
prepareStatement
in interface Connection
sql
- SQL statementSQLException
- if real operation failspublic PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException
prepareStatement
in interface Connection
sql
- SQL statementautoGeneratedKeys
- auto generated keysSQLException
- if real operation failspublic PreparedStatement prepareStatement(String sql, int rsType, int rsConcurrency) throws SQLException
prepareStatement
in interface Connection
sql
- 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 Connection
sql
- 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 Connection
sql
- 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 Connection
sql
- 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 Connection
sql
- 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 Connection
sql
- 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 Connection
sql
- 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 Connection
SQLException
public void setAutoCommit(boolean b) throws SQLException
setAutoCommit
in interface Connection
SQLException
public boolean getAutoCommit() throws SQLException
getAutoCommit
in interface Connection
SQLException
public boolean isClosed() throws SQLException
isClosed
in interface Connection
SQLException
public DatabaseMetaData getMetaData() throws SQLException
getMetaData
in interface Connection
SQLException
public void setReadOnly(boolean b) throws SQLException
setReadOnly
in interface Connection
SQLException
public boolean isReadOnly() throws SQLException
isReadOnly
in interface Connection
SQLException
public void setCatalog(String s) throws SQLException
setCatalog
in interface Connection
SQLException
public String getCatalog() throws SQLException
getCatalog
in interface Connection
SQLException
public void setTransactionIsolation(int i) throws SQLException
setTransactionIsolation
in interface Connection
SQLException
public int getTransactionIsolation() throws SQLException
getTransactionIsolation
in interface Connection
SQLException
public SQLWarning getWarnings() throws SQLException
getWarnings
in interface Connection
SQLException
public void clearWarnings() throws SQLException
clearWarnings
in interface Connection
SQLException
public Map<String,Class<?>> getTypeMap() throws SQLException
getTypeMap
in interface Connection
SQLException
public void setTypeMap(Map<String,Class<?>> stringClassMap) throws SQLException
setTypeMap
in interface Connection
SQLException
public void setHoldability(int i) throws SQLException
setHoldability
in interface Connection
SQLException
public int getHoldability() throws SQLException
getHoldability
in interface Connection
SQLException
public Savepoint setSavepoint() throws SQLException
setSavepoint
in interface Connection
SQLException
public Savepoint setSavepoint(String s) throws SQLException
setSavepoint
in interface Connection
SQLException
public void releaseSavepoint(Savepoint savepoint) throws SQLException
releaseSavepoint
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 i) throws SQLException
isValid
in interface Connection
SQLException
public void setClientInfo(String s, String s1) throws SQLClientInfoException
setClientInfo
in interface Connection
SQLClientInfoException
public void setClientInfo(Properties properties) throws SQLClientInfoException
setClientInfo
in interface Connection
SQLClientInfoException
public String getClientInfo(String s) throws SQLException
getClientInfo
in interface Connection
SQLException
public Properties getClientInfo() throws SQLException
getClientInfo
in interface Connection
SQLException
public Array createArrayOf(String s, Object[] objects) throws SQLException
createArrayOf
in interface Connection
SQLException
public Struct createStruct(String s, Object[] objects) throws SQLException
createStruct
in interface Connection
SQLException
public void setSchema(String schema) throws SQLException
setSchema
in interface Connection
SQLException
public String getSchema() throws SQLException
getSchema
in interface Connection
SQLException
public void abort(Executor executor) throws SQLException
abort
in interface Connection
SQLException
public void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException
setNetworkTimeout
in interface Connection
SQLException
public int getNetworkTimeout() throws SQLException
getNetworkTimeout
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 © 2019. All rights reserved.