|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.derby.client.am.Connection
public abstract class Connection
Field Summary | |
---|---|
private boolean |
accumulated440ForMessageProcFailure_
|
private boolean |
accumulated444ForMessageProcFailure_
|
Agent |
agent_
|
boolean |
autoCommit_
|
private boolean |
availableForReuse_
|
(package private) java.util.Hashtable |
clientCursorNameCache_
|
int |
clientSSLMode_
|
int |
commBufferSize_
|
(package private) java.util.WeakHashMap |
CommitAndRollbackListeners_
|
private java.lang.String |
currentSchemaName_
Cached copy of the schema name. |
DatabaseMetaData |
databaseMetaData_
|
java.lang.String |
databaseName_
|
ClientBaseDataSource |
dataSource_
|
private static java.lang.String |
DERBY_TRANSACTION_READ_COMMITTED
|
private static java.lang.String |
DERBY_TRANSACTION_READ_UNCOMMITTED
|
private static java.lang.String |
DERBY_TRANSACTION_REPEATABLE_READ
|
private static java.lang.String |
DERBY_TRANSACTION_SERIALIZABLE
|
int |
dncGeneratedSavepointId_
|
static java.lang.String |
dncGeneratedSavepointNamePrefix__
|
protected EncryptionManager |
encryptionManager_
|
private Statement |
getTransactionIsolationStmt
|
private int |
holdability
Holdabilty for created statements. |
protected boolean |
inUnitOfWork_
|
private static int |
INVALID_LOCATOR
|
private int |
isolation_
Cached copy of the isolation level. |
protected boolean |
isXAConnection_
|
protected boolean |
jdbcReadOnly_
|
private CallableLocatorProcedures |
lobProcs
Reference to object with prepared statements for calling the locator procedures. |
int |
loginTimeout_
|
protected boolean |
open_
|
(package private) java.util.WeakHashMap |
openStatements_
|
int |
portNumber_
|
java.lang.String |
productID_
|
boolean |
resetConnectionAtFirstSql_
|
boolean |
retrieveMessageText_
|
java.lang.String |
serverNameIP_
|
private Statement |
setTransactionIsolationStmt
|
private static int |
TRANSACTION_UNKNOWN
Constant indicating that isolation_ has not been updated through piggy-backing, (or that the previously stored value was invalidated, e.g. by an XA state change). |
private int |
transactionID_
|
protected java.lang.String |
user_
|
private SqlWarning |
warnings_
|
static int |
XA_T0_NOT_ASSOCIATED
XA_T0_NOT_ASSOCIATED
This connection is not currently associated with an XA transaction
In this state commits will flow in autocommit mode. |
static int |
XA_T1_ASSOCIATED
XA_T1_ASSOCIATED
In this state commits will not flow in autocommit mode. |
int |
xaHostVersion_
|
private int |
xaState_
|
Fields inherited from interface java.sql.Connection |
---|
TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE |
Constructor Summary | |
---|---|
protected |
Connection(LogWriter logWriter,
boolean isXAConn,
ClientBaseDataSource dataSource)
|
protected |
Connection(LogWriter logWriter,
int driverManagerLoginTimeout,
java.lang.String serverName,
int portNumber,
java.lang.String databaseName,
java.util.Properties properties)
|
protected |
Connection(LogWriter logWriter,
java.lang.String user,
java.lang.String password,
boolean isXAConn,
ClientBaseDataSource dataSource)
|
protected |
Connection(LogWriter logWriter,
java.lang.String user,
java.lang.String password,
ClientBaseDataSource dataSource)
|
Method Summary | |
---|---|
void |
accumulate440WarningForMessageProcFailure(SqlWarning e)
|
void |
accumulate444WarningForMessageProcFailure(SqlWarning e)
|
void |
accumulateWarning(SqlWarning e)
|
abstract void |
addSpecialRegisters(java.lang.String s)
|
protected abstract boolean |
allowCloseInUOW_()
|
protected abstract boolean |
allowLocalCommitRollback_()
|
protected void |
checkForClosedConnection()
|
private void |
checkForInvalidXAStateOnCommitOrRollback()
|
(package private) void |
checkForTransactionInProgress()
Check if the transaction is in progress and the connection cannot be closed. |
void |
clearWarnings()
|
void |
clearWarningsX()
|
void |
close()
|
void |
closeForReuse(boolean statementPooling)
|
void |
closeResources()
|
private void |
closeResourcesX()
|
void |
closeX()
|
void |
commit()
|
void |
completeAbnormalUnitOfWork()
|
void |
completeAbnormalUnitOfWork(UnitOfWorkListener uwl)
Rollback the UnitOfWorkListener specifically. |
void |
completeChainBreakingDisconnect()
|
void |
completeConnect()
|
void |
completeLocalCommit()
|
void |
completeLocalRollback()
|
void |
completePiggyBackIsolation(int pbIsolation)
Completes piggy-backing of the new current isolation level by updating the cached copy in am.Connection. |
void |
completePiggyBackSchema(java.lang.String pbSchema)
Completes piggy-backing of the new current schema by updating the cached copy in am.Connection. |
protected void |
completeReset(boolean isDeferredReset,
boolean closeStatementsOnClose)
NOTE:The following comments are valid for the changes done as part of implementing statement caching only (see DERBY-3313 and linked issues). |
void |
completeSpecificRollback(UnitOfWorkListener uwl)
Rollback the specific UnitOfWorkListener. |
void |
completeSqlca(Sqlca sqlca)
|
(package private) void |
completeTransactionStart()
|
java.sql.Blob |
createBlob()
Constructs an object that implements the Blob interface. |
java.sql.Clob |
createClob()
Constructs an object that implements the Clob interface. |
java.sql.Statement |
createStatement()
|
java.sql.Statement |
createStatement(int resultSetType,
int resultSetConcurrency)
|
java.sql.Statement |
createStatement(int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
private Statement |
createStatementX(int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
protected abstract boolean |
doCloseStatementsOnClose_()
|
private int |
downgradeResultSetType(int resultSetType)
|
protected void |
finalize()
|
boolean |
flowAutoCommit()
|
private void |
flowClose()
|
void |
flowCommit()
|
protected void |
flowRollback()
|
boolean |
getAutoCommit()
|
java.lang.String |
getCatalog()
|
java.lang.String |
getCurrentSchemaName()
Returns the current schema (the schema that would be used for compilation. |
int |
getHoldability()
|
java.sql.DatabaseMetaData |
getMetaData()
|
int |
getServerVersion()
|
int |
getTransactionID()
Returns the ID of the active transaction for this connection. |
int |
getTransactionIsolation()
|
java.util.Map |
getTypeMap()
|
java.sql.SQLWarning |
getWarnings()
|
int |
getXAState()
|
(package private) int |
holdability()
Return the holdabilty for the Connection. |
protected void |
initConnection(LogWriter logWriter,
ClientBaseDataSource dataSource)
|
boolean |
isClosed()
|
boolean |
isClosedX()
|
protected abstract boolean |
isGlobalPending_()
|
boolean |
isPhysicalConnClosed()
Return true if the physical connection is still open. |
boolean |
isReadOnly()
|
boolean |
isXAConnection()
|
void |
lightReset()
|
(package private) CallableLocatorProcedures |
locatorProcedureCall()
Get handle to the object that contains prepared statements for calling locator procedures for this connection. |
protected abstract void |
markClosed_()
|
void |
markClosed(boolean statementPooling)
|
private void |
markClosedForReuse(boolean statementPooling)
|
private void |
markStatementsClosed()
|
java.lang.String |
nativeSQL(java.lang.String sql)
|
java.lang.String |
nativeSQLX(java.lang.String sql)
|
protected abstract Agent |
newAgent_(LogWriter logWriter,
int loginTimeout,
java.lang.String serverName,
int portNumber,
int clientSSLMode)
|
protected abstract CallableStatement |
newCallableStatement_(java.lang.String sql,
int type,
int concurrency,
int holdability)
|
protected abstract DatabaseMetaData |
newDatabaseMetaData_()
|
protected abstract PreparedStatement |
newPositionedUpdatePreparedStatement_(java.lang.String sql,
Section section)
|
protected abstract PreparedStatement |
newPreparedStatement_(java.lang.String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
java.lang.String[] columnNames,
int[] columnIndexes)
|
abstract SectionManager |
newSectionManager(java.lang.String collection,
Agent agent,
java.lang.String databaseName)
|
protected abstract Statement |
newStatement_(int type,
int concurrency,
int holdability)
|
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)
|
(package private) CallableStatement |
prepareCallX(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
(package private) PreparedStatement |
prepareDynamicCatalogQuery(java.lang.String sql)
|
CallableStatement |
prepareMessageProc(java.lang.String sql)
|
PreparedStatement |
preparePositionedUpdateStatement(java.lang.String sql,
Section querySection)
|
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)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
java.lang.String[] columnNames)
|
(package private) PreparedStatement |
prepareStatementX(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability,
int autoGeneratedKeys,
java.lang.String[] columnNames,
int[] columnIndexes)
|
(package private) void |
readAutoCommit()
|
private void |
readCloseStatements()
|
void |
readCommit()
|
abstract void |
readCommitSubstitute_()
|
abstract void |
readLocalCommit_()
|
abstract void |
readLocalRollback_()
|
abstract void |
readLocalXACommit_()
|
abstract void |
readLocalXARollback_()
|
abstract void |
readLocalXAStart_()
|
void |
readRollback()
|
void |
readTransactionStart()
|
protected abstract void |
readXACommit_()
|
protected abstract void |
readXARollback_()
|
void |
releaseSavepoint(java.sql.Savepoint savepoint)
|
protected abstract void |
reset_(LogWriter logWriter)
|
void |
reset(LogWriter logWriter)
|
protected abstract void |
resetCallableStatement_(CallableStatement cs,
java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
protected void |
resetConnection(LogWriter logWriter)
|
protected void |
resetPrepareCall(CallableStatement cs)
|
protected abstract void |
resetPreparedStatement_(PreparedStatement ps,
java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability,
int autoGeneratedKeys,
java.lang.String[] columnNames,
int[] columnIndexes)
|
protected void |
resetPrepareStatement(PreparedStatement ps)
|
protected abstract void |
resetStatement_(Statement statement,
int type,
int concurrency,
int holdability)
|
protected void |
resetStatement(Statement s)
|
void |
rollback()
|
void |
rollback(java.sql.Savepoint savepoint)
|
protected abstract boolean |
serverSupportsLocators()
Checks whether the server supports locators for large objects. |
protected abstract boolean |
serverSupportsTimestampNanoseconds()
Return true if the server supports nanoseconds in timestamps |
void |
setAutoCommit(boolean autoCommit)
|
void |
setCatalog(java.lang.String catalog)
|
void |
setHoldability(int holdability)
|
void |
setInUnitOfWork(boolean inUnitOfWork)
|
void |
setReadOnly(boolean readOnly)
|
java.sql.Savepoint |
setSavepoint()
|
java.sql.Savepoint |
setSavepoint(java.lang.String name)
|
private Savepoint |
setSavepointX(Savepoint savepoint)
|
void |
setTransactionIsolation(int level)
|
private void |
setTransactionIsolationX(int level)
Set the transaction isolation level as specified. |
void |
setTypeMap(java.util.Map map)
|
void |
setXAState(int state)
|
protected abstract boolean |
supportsSessionDataCaching()
Finds out if the underlaying database connection supports session data caching. |
boolean |
transactionInProgress()
Check if there are uncommitted operations in the current transaction that prevent us from closing the connection. |
private int |
translateIsolation(java.lang.String isolationStr)
Translates the isolation level from a SQL string to the JDBC int value |
boolean |
willAutoCommitGenerateFlow()
|
(package private) void |
writeAutoCommit()
|
private void |
writeCloseStatements()
|
void |
writeCommit()
|
abstract void |
writeCommitSubstitute_()
|
abstract void |
writeLocalCommit_()
|
abstract void |
writeLocalRollback_()
|
abstract void |
writeLocalXACommit_()
|
abstract void |
writeLocalXARollback_()
|
abstract void |
writeLocalXAStart_()
|
void |
writeRollback()
|
void |
writeTransactionStart(Statement statement)
|
protected abstract void |
writeXACommit_()
|
protected abstract void |
writeXARollback_()
|
protected abstract void |
writeXATransactionStart(Statement statement)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface java.sql.Connection |
---|
createArrayOf, createNClob, createSQLXML, createStruct, getClientInfo, getClientInfo, isValid, setClientInfo, setClientInfo |
Methods inherited from interface java.sql.Wrapper |
---|
isWrapperFor, unwrap |
Field Detail |
---|
public Agent agent_
public DatabaseMetaData databaseMetaData_
final java.util.WeakHashMap openStatements_
final java.util.WeakHashMap CommitAndRollbackListeners_
private SqlWarning warnings_
private static final int INVALID_LOCATOR
protected final java.lang.String user_
public boolean retrieveMessageText_
protected boolean jdbcReadOnly_
private int holdability
public java.lang.String databaseName_
public java.lang.String productID_
protected EncryptionManager encryptionManager_
private Statement setTransactionIsolationStmt
private Statement getTransactionIsolationStmt
protected boolean open_
private boolean availableForReuse_
private static final int TRANSACTION_UNKNOWN
private int isolation_
private java.lang.String currentSchemaName_
public boolean autoCommit_
protected boolean inUnitOfWork_
private boolean accumulated440ForMessageProcFailure_
private boolean accumulated444ForMessageProcFailure_
private int transactionID_
protected boolean isXAConnection_
public static final int XA_T0_NOT_ASSOCIATED
XA_T0_NOT_ASSOCIATED
This connection is not currently associated with an XA transaction
In this state commits will flow in autocommit mode.
public static final int XA_T1_ASSOCIATED
XA_T1_ASSOCIATED
In this state commits will not flow in autocommit mode.
private int xaState_
public int xaHostVersion_
public int loginTimeout_
public ClientBaseDataSource dataSource_
public java.lang.String serverNameIP_
public int portNumber_
public int clientSSLMode_
java.util.Hashtable clientCursorNameCache_
public int commBufferSize_
public boolean resetConnectionAtFirstSql_
private static java.lang.String DERBY_TRANSACTION_REPEATABLE_READ
private static java.lang.String DERBY_TRANSACTION_SERIALIZABLE
private static java.lang.String DERBY_TRANSACTION_READ_COMMITTED
private static java.lang.String DERBY_TRANSACTION_READ_UNCOMMITTED
public int dncGeneratedSavepointId_
public static final java.lang.String dncGeneratedSavepointNamePrefix__
private CallableLocatorProcedures lobProcs
Constructor Detail |
---|
protected Connection(LogWriter logWriter, java.lang.String user, java.lang.String password, ClientBaseDataSource dataSource) throws SqlException
SqlException
protected Connection(LogWriter logWriter, java.lang.String user, java.lang.String password, boolean isXAConn, ClientBaseDataSource dataSource) throws SqlException
SqlException
protected Connection(LogWriter logWriter, boolean isXAConn, ClientBaseDataSource dataSource) throws SqlException
SqlException
protected Connection(LogWriter logWriter, int driverManagerLoginTimeout, java.lang.String serverName, int portNumber, java.lang.String databaseName, java.util.Properties properties) throws SqlException
SqlException
Method Detail |
---|
protected void initConnection(LogWriter logWriter, ClientBaseDataSource dataSource) throws SqlException
SqlException
protected void resetConnection(LogWriter logWriter) throws SqlException
SqlException
protected void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable
public java.sql.Statement createStatement() throws java.sql.SQLException
createStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
public PreparedStatement preparePositionedUpdateStatement(java.lang.String sql, Section querySection) throws SqlException
SqlException
public java.sql.CallableStatement prepareCall(java.lang.String sql) throws java.sql.SQLException
prepareCall
in interface java.sql.Connection
java.sql.SQLException
PreparedStatement prepareDynamicCatalogQuery(java.lang.String sql) throws SqlException
SqlException
public java.lang.String nativeSQL(java.lang.String sql) throws java.sql.SQLException
nativeSQL
in interface java.sql.Connection
java.sql.SQLException
public java.lang.String nativeSQLX(java.lang.String sql) throws SqlException
SqlException
protected abstract boolean allowLocalCommitRollback_() throws SqlException
SqlException
public void setAutoCommit(boolean autoCommit) throws java.sql.SQLException
setAutoCommit
in interface java.sql.Connection
java.sql.SQLException
public boolean getAutoCommit() throws java.sql.SQLException
getAutoCommit
in interface java.sql.Connection
java.sql.SQLException
public void commit() throws java.sql.SQLException
commit
in interface java.sql.Connection
java.sql.SQLException
private void checkForInvalidXAStateOnCommitOrRollback() throws SqlException
SqlException
public void flowCommit() throws SqlException
SqlException
public boolean flowAutoCommit() throws SqlException
SqlException
public boolean willAutoCommitGenerateFlow() throws SqlException
SqlException
void writeAutoCommit() throws SqlException
SqlException
public void writeCommit() throws SqlException
SqlException
void readAutoCommit() throws SqlException
SqlException
public void readCommit() throws SqlException
SqlException
public void rollback() throws java.sql.SQLException
rollback
in interface java.sql.Connection
java.sql.SQLException
protected void flowRollback() throws SqlException
SqlException
public void writeRollback() throws SqlException
SqlException
public void readRollback() throws SqlException
SqlException
public void close() throws java.sql.SQLException
close
in interface java.sql.Connection
java.sql.SQLException
void checkForTransactionInProgress() throws SqlException
SqlException
- if the connection cannot be closed because the
transaction is activepublic boolean transactionInProgress()
true
if the connection cannot be closed due to
uncommitted operations in the transactionpublic void closeX() throws java.sql.SQLException
java.sql.SQLException
public void closeResources() throws java.sql.SQLException
java.sql.SQLException
private void closeResourcesX() throws java.sql.SQLException
java.sql.SQLException
protected abstract boolean isGlobalPending_()
public void closeForReuse(boolean statementPooling) throws SqlException
SqlException
private void flowClose() throws SqlException
SqlException
protected abstract void markClosed_()
public void markClosed(boolean statementPooling)
private void markClosedForReuse(boolean statementPooling)
private void markStatementsClosed()
private void writeCloseStatements() throws SqlException
SqlException
private void readCloseStatements() throws SqlException
SqlException
public boolean isPhysicalConnClosed()
public boolean isClosed()
isClosed
in interface java.sql.Connection
public boolean isClosedX()
public void setTransactionIsolation(int level) throws java.sql.SQLException
setTransactionIsolation
in interface java.sql.Connection
java.sql.SQLException
private void setTransactionIsolationX(int level) throws SqlException
If this method is called during a transaction, the result is implementation-defined.
Information about Derby specific isolation level handling:
SqlException
protected abstract boolean supportsSessionDataCaching()
protected abstract boolean serverSupportsLocators()
true
if LOB locators are supported.protected abstract boolean serverSupportsTimestampNanoseconds()
public int getTransactionIsolation() throws java.sql.SQLException
getTransactionIsolation
in interface java.sql.Connection
java.sql.SQLException
public int getTransactionID()
public java.lang.String getCurrentSchemaName() throws java.sql.SQLException
java.sql.SQLException
private int translateIsolation(java.lang.String isolationStr)
isolationStr
- SQL isolation string
public java.sql.SQLWarning getWarnings() throws java.sql.SQLException
getWarnings
in interface java.sql.Connection
java.sql.SQLException
public void clearWarnings() throws java.sql.SQLException
clearWarnings
in interface java.sql.Connection
java.sql.SQLException
public void clearWarningsX() throws SqlException
SqlException
public java.sql.DatabaseMetaData getMetaData() throws java.sql.SQLException
getMetaData
in interface java.sql.Connection
java.sql.SQLException
public void setReadOnly(boolean readOnly) throws java.sql.SQLException
setReadOnly
in interface java.sql.Connection
java.sql.SQLException
public boolean isReadOnly() throws java.sql.SQLException
isReadOnly
in interface java.sql.Connection
java.sql.SQLException
public void setCatalog(java.lang.String catalog) throws java.sql.SQLException
setCatalog
in interface java.sql.Connection
java.sql.SQLException
public java.lang.String getCatalog() throws java.sql.SQLException
getCatalog
in interface java.sql.Connection
java.sql.SQLException
public java.sql.Statement createStatement(int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
createStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.CallableStatement prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
prepareCall
in interface java.sql.Connection
java.sql.SQLException
public CallableStatement prepareMessageProc(java.lang.String sql) throws SqlException
SqlException
private int downgradeResultSetType(int resultSetType)
public java.util.Map getTypeMap() throws java.sql.SQLException
getTypeMap
in interface java.sql.Connection
java.sql.SQLException
public void setTypeMap(java.util.Map map) throws java.sql.SQLException
setTypeMap
in interface java.sql.Connection
java.sql.SQLException
public void setHoldability(int holdability) throws java.sql.SQLException
setHoldability
in interface java.sql.Connection
java.sql.SQLException
public int getHoldability() throws java.sql.SQLException
getHoldability
in interface java.sql.Connection
java.sql.SQLException
public java.sql.Savepoint setSavepoint() throws java.sql.SQLException
setSavepoint
in interface java.sql.Connection
java.sql.SQLException
public java.sql.Savepoint setSavepoint(java.lang.String name) throws java.sql.SQLException
setSavepoint
in interface java.sql.Connection
java.sql.SQLException
private Savepoint setSavepointX(Savepoint savepoint) throws java.sql.SQLException
java.sql.SQLException
public void rollback(java.sql.Savepoint savepoint) throws java.sql.SQLException
rollback
in interface java.sql.Connection
java.sql.SQLException
public void releaseSavepoint(java.sql.Savepoint savepoint) throws java.sql.SQLException
releaseSavepoint
in interface java.sql.Connection
java.sql.SQLException
public java.sql.Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws java.sql.SQLException
createStatement
in interface java.sql.Connection
java.sql.SQLException
private Statement createStatementX(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SqlException
SqlException
protected void resetStatement(Statement s) throws SqlException
SqlException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
PreparedStatement prepareStatementX(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability, int autoGeneratedKeys, java.lang.String[] columnNames, int[] columnIndexes) throws SqlException
SqlException
protected void resetPrepareStatement(PreparedStatement ps) throws SqlException
SqlException
public java.sql.CallableStatement prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws java.sql.SQLException
prepareCall
in interface java.sql.Connection
java.sql.SQLException
CallableStatement prepareCallX(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SqlException
SqlException
protected void resetPrepareCall(CallableStatement cs) throws SqlException
SqlException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int autoGeneratedKeys) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int[] columnIndexes) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, java.lang.String[] columnNames) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
protected abstract boolean allowCloseInUOW_()
protected abstract boolean doCloseStatementsOnClose_()
public abstract SectionManager newSectionManager(java.lang.String collection, Agent agent, java.lang.String databaseName)
protected abstract Agent newAgent_(LogWriter logWriter, int loginTimeout, java.lang.String serverName, int portNumber, int clientSSLMode) throws SqlException
SqlException
protected abstract DatabaseMetaData newDatabaseMetaData_()
protected abstract Statement newStatement_(int type, int concurrency, int holdability) throws SqlException
SqlException
protected abstract void resetStatement_(Statement statement, int type, int concurrency, int holdability) throws SqlException
SqlException
protected abstract PreparedStatement newPositionedUpdatePreparedStatement_(java.lang.String sql, Section section) throws SqlException
SqlException
protected abstract PreparedStatement newPreparedStatement_(java.lang.String sql, int type, int concurrency, int holdability, int autoGeneratedKeys, java.lang.String[] columnNames, int[] columnIndexes) throws SqlException
SqlException
protected abstract void resetPreparedStatement_(PreparedStatement ps, java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability, int autoGeneratedKeys, java.lang.String[] columnNames, int[] columnIndexes) throws SqlException
SqlException
protected abstract CallableStatement newCallableStatement_(java.lang.String sql, int type, int concurrency, int holdability) throws SqlException
SqlException
protected abstract void resetCallableStatement_(CallableStatement cs, java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SqlException
SqlException
public void completeConnect() throws SqlException
SqlException
public abstract void writeCommitSubstitute_() throws SqlException
SqlException
public abstract void readCommitSubstitute_() throws SqlException
SqlException
public abstract void writeLocalXAStart_() throws SqlException
SqlException
public abstract void readLocalXAStart_() throws SqlException
SqlException
public abstract void writeLocalXACommit_() throws SqlException
SqlException
protected abstract void writeXACommit_() throws SqlException
SqlException
public abstract void readLocalXACommit_() throws SqlException
SqlException
protected abstract void readXACommit_() throws SqlException
SqlException
public abstract void writeLocalCommit_() throws SqlException
SqlException
public abstract void readLocalCommit_() throws SqlException
SqlException
protected abstract void writeXATransactionStart(Statement statement) throws SqlException
SqlException
public void completeLocalCommit()
completeLocalCommit
in interface ConnectionCallbackInterface
public abstract void writeLocalRollback_() throws SqlException
SqlException
public abstract void readLocalRollback_() throws SqlException
SqlException
public void completeLocalRollback()
completeLocalRollback
in interface ConnectionCallbackInterface
public void completeSpecificRollback(UnitOfWorkListener uwl)
uwl
- The UnitOfWorkLitener to be rolled backpublic abstract void writeLocalXARollback_() throws SqlException
SqlException
protected abstract void writeXARollback_() throws SqlException
SqlException
public abstract void readLocalXARollback_() throws SqlException
SqlException
protected abstract void readXARollback_() throws SqlException
SqlException
public void writeTransactionStart(Statement statement) throws SqlException
SqlException
public void readTransactionStart() throws SqlException
SqlException
void completeTransactionStart()
public void completeAbnormalUnitOfWork()
completeAbnormalUnitOfWork
in interface ConnectionCallbackInterface
public void completeAbnormalUnitOfWork(UnitOfWorkListener uwl)
completeAbnormalUnitOfWork
in interface ConnectionCallbackInterface
uwl
- The UnitOfWorkListener to be rolled back.public void completeChainBreakingDisconnect()
completeChainBreakingDisconnect
in interface ConnectionCallbackInterface
public void completeSqlca(Sqlca sqlca)
completeSqlca
in interface ConnectionCallbackInterface
public void completePiggyBackIsolation(int pbIsolation)
ConnectionCallbackInterface
completePiggyBackIsolation
in interface ConnectionCallbackInterface
pbIsolation
- new isolation level from the serverpublic void completePiggyBackSchema(java.lang.String pbSchema)
ConnectionCallbackInterface
completePiggyBackSchema
in interface ConnectionCallbackInterface
pbSchema
- new current schema from the serverpublic abstract void addSpecialRegisters(java.lang.String s)
public void reset(LogWriter logWriter) throws SqlException
SqlException
public void lightReset() throws SqlException
SqlException
protected abstract void reset_(LogWriter logWriter) throws SqlException
SqlException
protected void completeReset(boolean isDeferredReset, boolean closeStatementsOnClose) throws SqlException
We don't reset the isolation level to unknown unconditionally, as this forces us to go to the server all the time. Since the value should now be valid (DERBY-3192), we check if it has been changed from the default.
closeStatementsOnClose
- is used to differentiate between
cases where statement pooling is enabled or not. If true
, it
means statement pooling is disabled and the statements are fully
reset, which includes a re-prepare. If false
, statement
pooling is enabled, and a more lightweight reset procedure is used.
SqlException
CallableLocatorProcedures locatorProcedureCall()
connection.locatorProcedureCall().blobReleaseLocator(locator);
protected void checkForClosedConnection() throws SqlException
SqlException
public boolean isXAConnection()
public int getXAState()
public void setXAState(int state)
public void accumulateWarning(SqlWarning e)
public void accumulate440WarningForMessageProcFailure(SqlWarning e)
public void accumulate444WarningForMessageProcFailure(SqlWarning e)
public int getServerVersion()
public void setInUnitOfWork(boolean inUnitOfWork)
final int holdability()
public java.sql.Clob createClob() throws java.sql.SQLException
Clob
interface.
The object returned initially contains no data.
createClob
in interface java.sql.Connection
Clob
interface
java.sql.SQLException
- if an object that implements the
Clob
interface can not be constructed.public java.sql.Blob createBlob() throws java.sql.SQLException
Blob
interface.
The object returned initially contains no data.
createBlob
in interface java.sql.Connection
Blob
interface
java.sql.SQLException
- if an object that implements the
Blob interface can not be constructed.
|
Built on Thu 2010-12-23 20:49:13+0000, from revision ??? | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |