Package org.apache.derby.iapi.jdbc
Class BrokeredConnection
- java.lang.Object
-
- org.apache.derby.iapi.jdbc.BrokeredConnection
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,java.sql.Connection
,java.sql.Wrapper
,EngineConnection
- Direct Known Subclasses:
BrokeredConnection42
public class BrokeredConnection extends java.lang.Object implements EngineConnection
This is a rudimentary connection that delegates EVERYTHING to Connection.
-
-
Field Summary
Fields Modifier and Type Field Description private java.lang.String
connString
(package private) BrokeredConnectionControl
control
protected boolean
isClosed
private boolean
stateAutoCommit
(package private) int
stateHoldability
private int
stateIsolationLevel
Maintain state as seen by this Connection handle, not the state of the underlying Connection it is attached to.private boolean
stateReadOnly
-
Constructor Summary
Constructors Constructor Description BrokeredConnection(BrokeredConnectionControl control)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
abort(java.util.concurrent.Executor executor)
void
addWarning(java.sql.SQLWarning w)
Add a SQLWarning to this Connection object.void
clearWarnings()
void
close()
void
commit()
java.sql.Array
createArrayOf(java.lang.String typeName, java.lang.Object[] elements)
java.sql.Blob
createBlob()
Constructs an object that implements theBlob
interface.java.sql.Clob
createClob()
Constructs an object that implements theClob
interface.java.sql.NClob
createNClob()
java.sql.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 typeName, java.lang.Object[] attributes)
boolean
getAutoCommit()
java.lang.String
getCatalog()
java.util.Properties
getClientInfo()
getClientInfo
forwards to the real connection.java.lang.String
getClientInfo(java.lang.String name)
getClientInfo
forwards to the real connection.java.lang.String
getCurrentSchemaName()
Obtain the name of the current schema.int
getHoldability()
Get the holdability for statements created by this connection when holdability is not passed in.void
getIsolationUptoDate()
Isolation level state in BrokeredConnection can get out of sync if the isolation is set using SQL rather than JDBC.java.lang.Object
getLOBMapping(int key)
Get the LOB reference corresponding to the locator.java.sql.DatabaseMetaData
getMetaData()
int
getNetworkTimeout()
int
getPrepareIsolation()
get the isolation level that is currently being used to prepare statements (used for network server)(package private) EngineConnection
getRealConnection()
A little indirection for getting the real connection.java.lang.String
getSchema()
Get the name of the current schema.int
getTransactionIsolation()
java.util.Map<java.lang.String,java.lang.Class<?>>
getTypeMap()
java.sql.SQLWarning
getWarnings()
boolean
isClosed()
boolean
isInGlobalTransaction()
Is this a global transactionboolean
isReadOnly()
boolean
isValid(int timeout)
Checks if the connection has not been closed and is still valid.boolean
isWrapperFor(java.lang.Class<?> iface)
Returns false unlessiface
is implemented.java.lang.String
nativeSQL(java.lang.String sql)
BrokeredStatement
newBrokeredStatement(BrokeredStatementControl statementControl)
BrokeredCallableStatement
newBrokeredStatement(BrokeredStatementControl statementControl, java.lang.String sql)
BrokeredPreparedStatement
newBrokeredStatement(BrokeredStatementControl statementControl, java.lang.String sql, java.lang.Object generatedKeys)
(package private) java.sql.SQLException
noCurrentConnection()
Generate an exception reporting that there is no current connection.(package private) void
notifyException(java.sql.SQLException sqle)
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)
Prepare statement with explicit holdability.java.sql.PreparedStatement
prepareStatement(java.lang.String sql, java.lang.String[] columnNames)
void
releaseSavepoint(java.sql.Savepoint savepoint)
void
resetFromPool()
Resets the connection before it is returned from a PooledConnection to a new application request (wrapped by a BrokeredConnection).void
rollback()
void
rollback(java.sql.Savepoint savepoint)
void
setAutoCommit(boolean autoCommit)
void
setCatalog(java.lang.String catalog)
void
setClientInfo(java.lang.String name, java.lang.String value)
setClientInfo
forwards to the real connection.void
setClientInfo(java.util.Properties properties)
setClientInfo
forwards to the real connection.void
setDrdaID(java.lang.String drdaID)
set the DrdaId for this connection.void
setHoldability(int holdability)
void
setNetworkTimeout(java.util.concurrent.Executor executor, int milliseconds)
void
setPrepareIsolation(int level)
Set the internal isolation level to use for preparing statements.void
setReadOnly(boolean readOnly)
java.sql.Savepoint
setSavepoint()
java.sql.Savepoint
setSavepoint(java.lang.String name)
void
setSchema(java.lang.String schemaName)
Set the default schema for the Connection.void
setState(boolean complete)
Set the state of the underlying connection according to the state of this connection's view of state.void
setTransactionIsolation(int level)
void
setTypeMap(java.util.Map<java.lang.String,java.lang.Class<?>> map)
(package private) int
statementHoldabilityCheck(int resultSetHoldability)
Check the result set holdability when creating a statement object.void
syncState()
Sync up the state of the underlying connection with the state of this new handle.java.lang.String
toString()
Get the string representation for this connection.<T> T
unwrap(java.lang.Class<T> iface)
Returnsthis
if this class implements the interface.
-
-
-
Field Detail
-
stateHoldability
int stateHoldability
-
control
final BrokeredConnectionControl control
-
isClosed
protected boolean isClosed
-
connString
private java.lang.String connString
-
stateIsolationLevel
private int stateIsolationLevel
Maintain state as seen by this Connection handle, not the state of the underlying Connection it is attached to.
-
stateReadOnly
private boolean stateReadOnly
-
stateAutoCommit
private boolean stateAutoCommit
-
-
Constructor Detail
-
BrokeredConnection
public BrokeredConnection(BrokeredConnectionControl control) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
-
Method Detail
-
setAutoCommit
public final void setAutoCommit(boolean autoCommit) throws java.sql.SQLException
- Specified by:
setAutoCommit
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
getAutoCommit
public final boolean getAutoCommit() throws java.sql.SQLException
- Specified by:
getAutoCommit
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
createStatement
public final java.sql.Statement createStatement() throws java.sql.SQLException
- Specified by:
createStatement
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
prepareStatement
public final java.sql.PreparedStatement prepareStatement(java.lang.String sql) throws java.sql.SQLException
- Specified by:
prepareStatement
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
prepareCall
public final java.sql.CallableStatement prepareCall(java.lang.String sql) throws java.sql.SQLException
- Specified by:
prepareCall
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
nativeSQL
public final java.lang.String nativeSQL(java.lang.String sql) throws java.sql.SQLException
- Specified by:
nativeSQL
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
commit
public final void commit() throws java.sql.SQLException
- Specified by:
commit
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
rollback
public final void rollback() throws java.sql.SQLException
- Specified by:
rollback
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
close
public final void close() throws java.sql.SQLException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
isClosed
public final boolean isClosed() throws java.sql.SQLException
- Specified by:
isClosed
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
getWarnings
public final java.sql.SQLWarning getWarnings() throws java.sql.SQLException
- Specified by:
getWarnings
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
clearWarnings
public final void clearWarnings() throws java.sql.SQLException
- Specified by:
clearWarnings
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
getMetaData
public final java.sql.DatabaseMetaData getMetaData() throws java.sql.SQLException
- Specified by:
getMetaData
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
setReadOnly
public final void setReadOnly(boolean readOnly) throws java.sql.SQLException
- Specified by:
setReadOnly
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
isReadOnly
public final boolean isReadOnly() throws java.sql.SQLException
- Specified by:
isReadOnly
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
setCatalog
public final void setCatalog(java.lang.String catalog) throws java.sql.SQLException
- Specified by:
setCatalog
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
getCatalog
public final java.lang.String getCatalog() throws java.sql.SQLException
- Specified by:
getCatalog
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
setTransactionIsolation
public final void setTransactionIsolation(int level) throws java.sql.SQLException
- Specified by:
setTransactionIsolation
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
getTransactionIsolation
public final int getTransactionIsolation() throws java.sql.SQLException
- Specified by:
getTransactionIsolation
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
createStatement
public final java.sql.Statement createStatement(int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
- Specified by:
createStatement
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
prepareStatement
public final java.sql.PreparedStatement prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
- Specified by:
prepareStatement
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
prepareCall
public final java.sql.CallableStatement prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
- Specified by:
prepareCall
in interfacejava.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 interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
setTypeMap
public final void setTypeMap(java.util.Map<java.lang.String,java.lang.Class<?>> map) throws java.sql.SQLException
- Specified by:
setTypeMap
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
createStatement
public final java.sql.Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws java.sql.SQLException
- Specified by:
createStatement
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
prepareCall
public final java.sql.CallableStatement prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws java.sql.SQLException
- Specified by:
prepareCall
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
setSavepoint
public final java.sql.Savepoint setSavepoint() throws java.sql.SQLException
- Specified by:
setSavepoint
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
setSavepoint
public final java.sql.Savepoint setSavepoint(java.lang.String name) throws java.sql.SQLException
- Specified by:
setSavepoint
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
rollback
public final void rollback(java.sql.Savepoint savepoint) throws java.sql.SQLException
- Specified by:
rollback
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
releaseSavepoint
public final void releaseSavepoint(java.sql.Savepoint savepoint) throws java.sql.SQLException
- Specified by:
releaseSavepoint
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
setHoldability
public final void setHoldability(int holdability) throws java.sql.SQLException
- Specified by:
setHoldability
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
prepareStatement
public final java.sql.PreparedStatement prepareStatement(java.lang.String sql, int autoGeneratedKeys) throws java.sql.SQLException
- Specified by:
prepareStatement
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
prepareStatement
public final java.sql.PreparedStatement prepareStatement(java.lang.String sql, int[] columnIndexes) throws java.sql.SQLException
- Specified by:
prepareStatement
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
prepareStatement
public final java.sql.PreparedStatement prepareStatement(java.lang.String sql, java.lang.String[] columnNames) throws java.sql.SQLException
- Specified by:
prepareStatement
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
noCurrentConnection
final java.sql.SQLException noCurrentConnection()
Generate an exception reporting that there is no current connection.- Returns:
- a no-current-connection exception
-
getRealConnection
final EngineConnection getRealConnection() throws java.sql.SQLException
A little indirection for getting the real connection.- Returns:
- the current connection
- Throws:
java.sql.SQLException
-
notifyException
final void notifyException(java.sql.SQLException sqle)
-
syncState
public void syncState() throws java.sql.SQLException
Sync up the state of the underlying connection with the state of this new handle.- Throws:
java.sql.SQLException
-
getIsolationUptoDate
public void getIsolationUptoDate() throws java.sql.SQLException
Isolation level state in BrokeredConnection can get out of sync if the isolation is set using SQL rather than JDBC. In order to ensure correct state level information, this method is called at the start and end of a global transaction.- Throws:
java.sql.SQLException
-
setState
public void setState(boolean complete) throws java.sql.SQLException
Set the state of the underlying connection according to the state of this connection's view of state.- Parameters:
complete
- If true set the complete state of the underlying Connection, otherwise set only the Connection related state (ie. the non-transaction specific state).- Throws:
java.sql.SQLException
-
newBrokeredStatement
public final BrokeredStatement newBrokeredStatement(BrokeredStatementControl statementControl) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
newBrokeredStatement
public BrokeredPreparedStatement newBrokeredStatement(BrokeredStatementControl statementControl, java.lang.String sql, java.lang.Object generatedKeys) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
newBrokeredStatement
public BrokeredCallableStatement newBrokeredStatement(BrokeredStatementControl statementControl, java.lang.String sql) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
setDrdaID
public final void setDrdaID(java.lang.String drdaID)
set the DrdaId for this connection. The drdaID prints with the statement text to the errror log- Specified by:
setDrdaID
in interfaceEngineConnection
- Parameters:
drdaID
- drdaID to be used for this connection
-
isInGlobalTransaction
public boolean isInGlobalTransaction()
Description copied from interface:EngineConnection
Is this a global transaction- Specified by:
isInGlobalTransaction
in interfaceEngineConnection
- Returns:
- true if this is a global XA transaction
- See Also:
EngineConnection.isInGlobalTransaction()
-
setPrepareIsolation
public final void setPrepareIsolation(int level) throws java.sql.SQLException
Set the internal isolation level to use for preparing statements. Subsequent prepares will use this isoalation level- Specified by:
setPrepareIsolation
in interfaceEngineConnection
- Parameters:
level
- - internal isolation level- Throws:
java.sql.SQLException
- See EmbedConnection#setPrepareIsolation
-
getPrepareIsolation
public final int getPrepareIsolation() throws java.sql.SQLException
get the isolation level that is currently being used to prepare statements (used for network server)- Specified by:
getPrepareIsolation
in interfaceEngineConnection
- Returns:
- current prepare isolation level See EmbedConnection#getPrepareIsolation
- Throws:
java.sql.SQLException
-
addWarning
public final void addWarning(java.sql.SQLWarning w) throws java.sql.SQLException
Add a SQLWarning to this Connection object.- Specified by:
addWarning
in interfaceEngineConnection
- Parameters:
w
- Warning to be added, will be chained to any existing warnings.- Throws:
java.sql.SQLException
-
toString
public java.lang.String toString()
Get the string representation for this connection. Return the class name/hash code and various debug information.- Overrides:
toString
in classjava.lang.Object
- Returns:
- unique string representation for this connection
-
prepareStatement
public final java.sql.PreparedStatement prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws java.sql.SQLException
Prepare statement with explicit holdability.- Specified by:
prepareStatement
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
getHoldability
public final int getHoldability() throws java.sql.SQLException
Get the holdability for statements created by this connection when holdability is not passed in.- Specified by:
getHoldability
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
createArrayOf
public final java.sql.Array createArrayOf(java.lang.String typeName, java.lang.Object[] elements) throws java.sql.SQLException
- Specified by:
createArrayOf
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
createBlob
public final java.sql.Blob createBlob() throws java.sql.SQLException
Constructs an object that implements theBlob
interface. The object returned initially contains no data. ThesetBinaryStream
andsetBytes
methods of theBlob
interface may be used to add data to theBlob
.- Specified by:
createBlob
in interfacejava.sql.Connection
- Returns:
- An object that implements the
Blob
interface - Throws:
java.sql.SQLException
- if an object that implements theBlob
interface can not be constructed, this method is called on a closed connection or a database access error occurs.
-
createClob
public final java.sql.Clob createClob() throws java.sql.SQLException
Constructs an object that implements theClob
interface. The object returned initially contains no data. ThesetAsciiStream
,setCharacterStream
andsetString
methods of theClob
interface may be used to add data to theClob
.- Specified by:
createClob
in interfacejava.sql.Connection
- Returns:
- An object that implements the
Clob
interface - Throws:
java.sql.SQLException
- if an object that implements theClob
interface can not be constructed, this method is called on a closed connection or a database access error occurs.
-
createNClob
public final java.sql.NClob createNClob() throws java.sql.SQLException
- Specified by:
createNClob
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
createSQLXML
public final java.sql.SQLXML createSQLXML() throws java.sql.SQLException
- Specified by:
createSQLXML
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
createStruct
public final java.sql.Struct createStruct(java.lang.String typeName, java.lang.Object[] attributes) throws java.sql.SQLException
- Specified by:
createStruct
in interfacejava.sql.Connection
- Throws:
java.sql.SQLException
-
isValid
public final boolean isValid(int timeout) throws java.sql.SQLException
Checks if the connection has not been closed and is still valid. The validity is checked by running a simple query against the database.- Specified by:
isValid
in interfacejava.sql.Connection
- Parameters:
timeout
- The time in seconds to wait for the database operation used to validate the connection to complete. If the timeout period expires before the operation completes, this method returns false. A value of 0 indicates a timeout is not applied to the database operation.- Returns:
- true if the connection is valid, false otherwise
- Throws:
java.sql.SQLException
- if the call on the physical connection throws an exception.
-
setClientInfo
public final void setClientInfo(java.lang.String name, java.lang.String value) throws java.sql.SQLClientInfoException
setClientInfo
forwards to the real connection.- Specified by:
setClientInfo
in interfacejava.sql.Connection
- Parameters:
name
- the property keyString
value
- the property valueString
- Throws:
java.sql.SQLClientInfoException
- if the property is not supported or the real connection could not be obtained.
-
setClientInfo
public final void setClientInfo(java.util.Properties properties) throws java.sql.SQLClientInfoException
setClientInfo
forwards to the real connection. If the call togetRealConnection
fails the resultingSQLException
is wrapped in aSQLClientInfoException
to satisfy the specified signature.- Specified by:
setClientInfo
in interfacejava.sql.Connection
- Parameters:
properties
- aProperties
object with the properties to set.- Throws:
java.sql.SQLClientInfoException
- if the properties are not supported or the real connection could not be obtained.
-
getClientInfo
public final java.lang.String getClientInfo(java.lang.String name) throws java.sql.SQLException
getClientInfo
forwards to the real connection.- Specified by:
getClientInfo
in interfacejava.sql.Connection
- Parameters:
name
- aString
that is the property key to get.- Returns:
- a
String
that is returned from the real connection. - Throws:
java.sql.SQLException
- if a database access error occurs.
-
getClientInfo
public final java.util.Properties getClientInfo() throws java.sql.SQLException
getClientInfo
forwards to the real connection.- Specified by:
getClientInfo
in interfacejava.sql.Connection
- Returns:
- a
Properties
object from the real connection. - Throws:
java.sql.SQLException
- if a database access error occurs.
-
isWrapperFor
public final boolean isWrapperFor(java.lang.Class<?> iface) throws java.sql.SQLException
Returns false unlessiface
is implemented.- Specified by:
isWrapperFor
in interfacejava.sql.Wrapper
- Parameters:
iface
- a Class defining an interface.- Returns:
- true if this implements the interface or directly or indirectly wraps an object that does.
- Throws:
java.sql.SQLException
- if an error occurs while determining whether this is a wrapper for an object with the given interface.
-
unwrap
public final <T> T unwrap(java.lang.Class<T> iface) throws java.sql.SQLException
Returnsthis
if this class implements the interface.- Specified by:
unwrap
in interfacejava.sql.Wrapper
- Parameters:
iface
- a Class defining an interface- Returns:
- an object that implements the interface
- Throws:
java.sql.SQLException
- if no object if found that implements the interface
-
statementHoldabilityCheck
final int statementHoldabilityCheck(int resultSetHoldability) throws java.sql.SQLException
Check the result set holdability when creating a statement object. Section 16.1.3.1 of JDBC 4.0 (proposed final draft) says the driver may change the holdabilty and add a SQLWarning to the Connection object. This work-in-progress implementation throws an exception to match the old behaviour just as part of incremental development.- Throws:
java.sql.SQLException
-
getLOBMapping
public java.lang.Object getLOBMapping(int key) throws java.sql.SQLException
Get the LOB reference corresponding to the locator.- Specified by:
getLOBMapping
in interfaceEngineConnection
- Parameters:
key
- the integer that represents the LOB locator value.- Returns:
- the LOB Object corresponding to this locator.
- Throws:
java.sql.SQLException
-
getCurrentSchemaName
public java.lang.String getCurrentSchemaName() throws java.sql.SQLException
Obtain the name of the current schema. Not part of the java.sql.Connection interface, but is accessible through the EngineConnection interface, so that the NetworkServer can get at the current schema for piggy-backing- Specified by:
getCurrentSchemaName
in interfaceEngineConnection
- Returns:
- the current schema name
- Throws:
java.sql.SQLException
-
resetFromPool
public void resetFromPool() throws java.sql.SQLException
Description copied from interface:EngineConnection
Resets the connection before it is returned from a PooledConnection to a new application request (wrapped by a BrokeredConnection).Note that resetting the transaction isolation level is not performed as part of this method. Temporary tables, IDENTITY_VAL_LOCAL and current schema are reset.
- Specified by:
resetFromPool
in interfaceEngineConnection
- Throws:
java.sql.SQLException
- See Also:
EngineConnection
-
getSchema
public java.lang.String getSchema() throws java.sql.SQLException
Get the name of the current schema.- Specified by:
getSchema
in interfacejava.sql.Connection
- Specified by:
getSchema
in interfaceEngineConnection
- Throws:
java.sql.SQLException
-
setSchema
public void setSchema(java.lang.String schemaName) throws java.sql.SQLException
Set the default schema for the Connection.- Specified by:
setSchema
in interfacejava.sql.Connection
- Specified by:
setSchema
in interfaceEngineConnection
- Throws:
java.sql.SQLException
-
abort
public void abort(java.util.concurrent.Executor executor) throws java.sql.SQLException
- Specified by:
abort
in interfacejava.sql.Connection
- Specified by:
abort
in interfaceEngineConnection
- Throws:
java.sql.SQLException
-
getNetworkTimeout
public int getNetworkTimeout() throws java.sql.SQLException
- Specified by:
getNetworkTimeout
in interfacejava.sql.Connection
- Specified by:
getNetworkTimeout
in interfaceEngineConnection
- Throws:
java.sql.SQLException
-
setNetworkTimeout
public void setNetworkTimeout(java.util.concurrent.Executor executor, int milliseconds) throws java.sql.SQLException
- Specified by:
setNetworkTimeout
in interfacejava.sql.Connection
- Specified by:
setNetworkTimeout
in interfaceEngineConnection
- Throws:
java.sql.SQLException
-
-