public class ConnectionWrapper extends Object implements Connection
Connection
, used on ArrowFlightJdbcPooledConnection
.TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE
Constructor and Description |
---|
ConnectionWrapper(Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
abort(Executor executor) |
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 resultSetTypeId,
int resultSetConcurrencyId) |
Statement |
createStatement(int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
Struct |
createStruct(String typeName,
Object... attributes) |
boolean |
getAutoCommit() |
String |
getCatalog() |
Properties |
getClientInfo() |
String |
getClientInfo(String propertyName) |
int |
getHoldability() |
DatabaseMetaData |
getMetaData() |
int |
getNetworkTimeout() |
String |
getSchema() |
int |
getTransactionIsolation() |
Map<String,Class<?>> |
getTypeMap() |
SQLWarning |
getWarnings() |
boolean |
isClosed() |
boolean |
isReadOnly() |
boolean |
isValid(int timeout) |
boolean |
isWrapperFor(Class<?> type) |
String |
nativeSQL(String sqlStatement) |
CallableStatement |
prepareCall(String sqlQuery) |
CallableStatement |
prepareCall(String query,
int resultSetTypeId,
int resultSetConcurrencyId) |
CallableStatement |
prepareCall(String sqlQuery,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
PreparedStatement |
prepareStatement(String sqlQuery) |
PreparedStatement |
prepareStatement(String sqlQuery,
int... columnIndices) |
PreparedStatement |
prepareStatement(String sqlQuery,
int autoGeneratedKeysId) |
PreparedStatement |
prepareStatement(String sqlQuery,
int resultSetTypeId,
int resultSetConcurrencyId) |
PreparedStatement |
prepareStatement(String sqlQuery,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
PreparedStatement |
prepareStatement(String sqlQuery,
String... columnNames) |
void |
releaseSavepoint(Savepoint savepoint) |
void |
rollback() |
void |
rollback(Savepoint savepoint) |
void |
setAutoCommit(boolean autoCommit) |
void |
setCatalog(String catalogName) |
void |
setClientInfo(Properties properties) |
void |
setClientInfo(String propertyName,
String propertyValue) |
void |
setHoldability(int holdabilityId) |
void |
setNetworkTimeout(Executor executor,
int timeoutInMillis) |
void |
setReadOnly(boolean readOnly) |
Savepoint |
setSavepoint() |
Savepoint |
setSavepoint(String savepointName) |
void |
setSchema(String schemaName) |
void |
setTransactionIsolation(int transactionIsolationId) |
void |
setTypeMap(Map<String,Class<?>> typeNameToClass) |
<T> T |
unwrap(Class<T> type) |
public ConnectionWrapper(Connection connection)
public boolean isWrapperFor(Class<?> type)
isWrapperFor
in interface Wrapper
public Statement createStatement() throws SQLException
createStatement
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sqlQuery) throws SQLException
prepareStatement
in interface Connection
SQLException
public CallableStatement prepareCall(String sqlQuery) throws SQLException
prepareCall
in interface Connection
SQLException
public String nativeSQL(String sqlStatement) throws SQLException
nativeSQL
in interface Connection
SQLException
public void setAutoCommit(boolean autoCommit) throws SQLException
setAutoCommit
in interface Connection
SQLException
public boolean getAutoCommit() throws SQLException
getAutoCommit
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 boolean isClosed() throws SQLException
isClosed
in interface Connection
SQLException
public DatabaseMetaData getMetaData() throws SQLException
getMetaData
in interface Connection
SQLException
public void setReadOnly(boolean readOnly) throws SQLException
setReadOnly
in interface Connection
SQLException
public boolean isReadOnly() throws SQLException
isReadOnly
in interface Connection
SQLException
public void setCatalog(String catalogName) throws SQLException
setCatalog
in interface Connection
SQLException
public String getCatalog() throws SQLException
getCatalog
in interface Connection
SQLException
public void setTransactionIsolation(int transactionIsolationId) 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 Statement createStatement(int resultSetTypeId, int resultSetConcurrencyId) throws SQLException
createStatement
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sqlQuery, int resultSetTypeId, int resultSetConcurrencyId) throws SQLException
prepareStatement
in interface Connection
SQLException
public CallableStatement prepareCall(String query, int resultSetTypeId, int resultSetConcurrencyId) throws SQLException
prepareCall
in interface Connection
SQLException
public Map<String,Class<?>> getTypeMap() throws SQLException
getTypeMap
in interface Connection
SQLException
public void setTypeMap(Map<String,Class<?>> typeNameToClass) throws SQLException
setTypeMap
in interface Connection
SQLException
public void setHoldability(int holdabilityId) 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 savepointName) throws SQLException
setSavepoint
in interface Connection
SQLException
public void rollback(Savepoint savepoint) throws SQLException
rollback
in interface Connection
SQLException
public void releaseSavepoint(Savepoint savepoint) throws SQLException
releaseSavepoint
in interface Connection
SQLException
public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
createStatement
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sqlQuery, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
prepareStatement
in interface Connection
SQLException
public CallableStatement prepareCall(String sqlQuery, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
prepareCall
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sqlQuery, int autoGeneratedKeysId) throws SQLException
prepareStatement
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sqlQuery, int... columnIndices) throws SQLException
prepareStatement
in interface Connection
SQLException
public PreparedStatement prepareStatement(String sqlQuery, 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 propertyName, String propertyValue) throws SQLClientInfoException
setClientInfo
in interface Connection
SQLClientInfoException
public void setClientInfo(Properties properties) throws SQLClientInfoException
setClientInfo
in interface Connection
SQLClientInfoException
public String getClientInfo(String propertyName) 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 void setSchema(String schemaName) 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 timeoutInMillis) throws SQLException
setNetworkTimeout
in interface Connection
SQLException
public int getNetworkTimeout() throws SQLException
getNetworkTimeout
in interface Connection
SQLException
Copyright © 2023 The Apache Software Foundation. All rights reserved.