org.apache.derby.client.am

Class ClientConnection

java.lang.Object

org.apache.derby.client.am.ClientConnection

All Implemented Interfaces:

java.lang.AutoCloseable, java.sql.Connection, java.sql.Wrapper, ConnectionCallbackInterface

Direct Known Subclasses:

NetConnection

public abstract class ClientConnection
extends java.lang.Object
implements java.sql.Connection, ConnectionCallbackInterface

Field Summary

Fields

Modifier and Type	Field and Description
Agent	agent_
boolean	autoCommit_
int	commBufferSize_
ClientDatabaseMetaData	databaseMetaData_
java.lang.String	databaseName_
BasicClientDataSource40	dataSource_
int	portNumber_
java.lang.String	productID_
boolean	resetConnectionAtFirstSql_
java.lang.String	serverNameIP_
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_

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Method Summary

Modifier and Type	Method and Description
void	abort(java.util.concurrent.Executor executor)
void	clearWarnings()
void	close()
void	closeResources()
void	commit()
void	completeAbnormalUnitOfWork()
void	completeAbnormalUnitOfWork(UnitOfWorkListener uwl) Rollback the UnitOfWorkListener specifically.
void	completeChainBreakingDisconnect()
void	completeConnect()
void	completeInitialPiggyBackIsolation(int pbIsolation) Sets the default isolation level of the connection upon connection initialization.
void	completeInitialPiggyBackSchema(java.lang.String pbSchema) Sets the current schema upon connection initialization.
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.
void	completeSqlca(Sqlca sqlca)
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)
boolean	flowAutoCommit()
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	getNetworkTimeout()
java.lang.String	getSchema() Get the name of the current schema.
int	getServerVersion()
int	getTransactionID() Returns the ID of the active transaction for this connection.
int	getTransactionIsolation()
int	getTransactionIsolationX()
java.util.Map<java.lang.String,java.lang.Class<?>>	getTypeMap()
java.sql.SQLWarning	getWarnings()
int	getXAState()
boolean	isAborting() Return true if the connection is aborting
boolean	isClosed()
boolean	isClosedX()
boolean	isPhysicalConnClosed() Return true if the physical connection is still open.
boolean	isReadOnly()
boolean	isXAConnection()
void	lightReset()
java.lang.String	nativeSQL(java.lang.String sql)
abstract SectionManager	newSectionManager(Agent agent)
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)
java.sql.PreparedStatement	prepareStatement(java.lang.String sql, java.lang.String[] columnNames)
abstract void	readCommitSubstitute_()
abstract void	readLocalCommit_()
abstract void	readLocalRollback_()
abstract void	readLocalXACommit_()
abstract void	readLocalXARollback_()
abstract void	readLocalXAStart_()
void	readTransactionStart()
void	releaseSavepoint(java.sql.Savepoint savepoint)
void	reset(LogWriter logWriter)
void	rollback()
void	rollback(java.sql.Savepoint savepoint)
void	setAutoCommit(boolean autoCommit)
void	setCatalog(java.lang.String catalog)
void	setHoldability(int holdability)
void	setNetworkTimeout(java.util.concurrent.Executor executor, int milliseconds)
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	setTransactionIsolation(int level)
void	setTypeMap(java.util.Map map)
void	setXAState(int state)
boolean	transactionInProgress() Check if there are uncommitted operations in the current transaction that prevent us from closing the connection.
boolean	willAutoCommitGenerateFlow()
abstract void	writeCommitSubstitute_()
abstract void	writeLocalCommit_()
abstract void	writeLocalRollback_()
abstract void	writeLocalXACommit_()
abstract void	writeLocalXARollback_()
abstract void	writeLocalXAStart_()
void	writeTransactionStart(ClientStatement statement)

Methods inherited from class java.lang.Object

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

agent_

public Agent agent_

databaseMetaData_

public ClientDatabaseMetaData databaseMetaData_

databaseName_

public java.lang.String databaseName_

productID_

public java.lang.String productID_

autoCommit_

public boolean autoCommit_

XA_T0_NOT_ASSOCIATED

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.

See Also:

Constant Field Values

XA_T1_ASSOCIATED

public static final int XA_T1_ASSOCIATED

XA_T1_ASSOCIATED In this state commits will not flow in autocommit mode.

See Also:

Constant Field Values

xaHostVersion_

public int xaHostVersion_

dataSource_

public BasicClientDataSource40 dataSource_

serverNameIP_

public java.lang.String serverNameIP_

portNumber_

public int portNumber_

commBufferSize_

public int commBufferSize_

resetConnectionAtFirstSql_

public boolean resetConnectionAtFirstSql_

Method Detail

createStatement

public java.sql.Statement createStatement()
                                   throws java.sql.SQLException

Specified by:

createStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql)
                                            throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareCall

public java.sql.CallableStatement prepareCall(java.lang.String sql)
                                       throws java.sql.SQLException

Specified by:

prepareCall in interface java.sql.Connection

Throws:

java.sql.SQLException

nativeSQL

public java.lang.String nativeSQL(java.lang.String sql)
                           throws java.sql.SQLException

Specified by:

nativeSQL in interface java.sql.Connection

Throws:

java.sql.SQLException

setAutoCommit

public void setAutoCommit(boolean autoCommit)
                   throws java.sql.SQLException

Specified by:

setAutoCommit in interface java.sql.Connection

Throws:

java.sql.SQLException

getAutoCommit

public boolean getAutoCommit()
                      throws java.sql.SQLException

Specified by:

getAutoCommit in interface java.sql.Connection

Throws:

java.sql.SQLException

commit

public void commit()
            throws java.sql.SQLException

Specified by:

commit in interface java.sql.Connection

Throws:

java.sql.SQLException

flowAutoCommit

public boolean flowAutoCommit()
                       throws SqlException

Throws:

SqlException

willAutoCommitGenerateFlow

public boolean willAutoCommitGenerateFlow()
                                   throws SqlException

Throws:

SqlException

rollback

public void rollback()
              throws java.sql.SQLException

Specified by:

rollback in interface java.sql.Connection

Throws:

java.sql.SQLException

close

public void close()
           throws java.sql.SQLException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.sql.Connection

Throws:

java.sql.SQLException

transactionInProgress

public boolean transactionInProgress()

Check if there are uncommitted operations in the current transaction that prevent us from closing the connection.

Returns:

true if the connection cannot be closed due to uncommitted operations in the transaction

closeResources

public void closeResources()
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

isPhysicalConnClosed

public boolean isPhysicalConnClosed()

Return true if the physical connection is still open. Might be logically closed but available for reuse.

Returns:

true if physical connection still open

isClosed

public boolean isClosed()

Specified by:

isClosed in interface java.sql.Connection

isClosedX

public boolean isClosedX()

setTransactionIsolation

public void setTransactionIsolation(int level)
                             throws java.sql.SQLException

Specified by:

setTransactionIsolation in interface java.sql.Connection

Throws:

java.sql.SQLException

getTransactionIsolation

public int getTransactionIsolation()
                            throws java.sql.SQLException

Specified by:

getTransactionIsolation in interface java.sql.Connection

Throws:

java.sql.SQLException

getTransactionIsolationX

public int getTransactionIsolationX()
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getTransactionID

public int getTransactionID()

Returns the ID of the active transaction for this connection.

Returns:

the ID of the active transaction

getCurrentSchemaName

public java.lang.String getCurrentSchemaName()
                                      throws java.sql.SQLException

Returns the current schema (the schema that would be used for compilation. This is not part of the java.sql.Connection interface, and is only intended for use with statement caching.

Returns:

the name of the current schema

Throws:

java.sql.SQLException

getWarnings

public java.sql.SQLWarning getWarnings()
                                throws java.sql.SQLException

Specified by:

getWarnings in interface java.sql.Connection

Throws:

java.sql.SQLException

clearWarnings

public void clearWarnings()
                   throws java.sql.SQLException

Specified by:

clearWarnings in interface java.sql.Connection

Throws:

java.sql.SQLException

getMetaData

public java.sql.DatabaseMetaData getMetaData()
                                      throws java.sql.SQLException

Specified by:

getMetaData in interface java.sql.Connection

Throws:

java.sql.SQLException

setReadOnly

public void setReadOnly(boolean readOnly)
                 throws java.sql.SQLException

Specified by:

setReadOnly in interface java.sql.Connection

Throws:

java.sql.SQLException

isReadOnly

public boolean isReadOnly()
                   throws java.sql.SQLException

Specified by:

isReadOnly in interface java.sql.Connection

Throws:

java.sql.SQLException

setCatalog

public void setCatalog(java.lang.String catalog)
                throws java.sql.SQLException

Specified by:

setCatalog in interface java.sql.Connection

Throws:

java.sql.SQLException

getCatalog

public java.lang.String getCatalog()
                            throws java.sql.SQLException

Specified by:

getCatalog in interface java.sql.Connection

Throws:

java.sql.SQLException

createStatement

public java.sql.Statement createStatement(int resultSetType,
                                          int resultSetConcurrency)
                                   throws java.sql.SQLException

Specified by:

createStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   int resultSetType,
                                                   int resultSetConcurrency)
                                            throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareCall

public java.sql.CallableStatement prepareCall(java.lang.String sql,
                                              int resultSetType,
                                              int resultSetConcurrency)
                                       throws java.sql.SQLException

Specified by:

prepareCall in interface java.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 interface java.sql.Connection

Throws:

java.sql.SQLException

setTypeMap

public void setTypeMap(java.util.Map map)
                throws java.sql.SQLException

Specified by:

setTypeMap in interface java.sql.Connection

Throws:

java.sql.SQLException

setHoldability

public void setHoldability(int holdability)
                    throws java.sql.SQLException

Specified by:

setHoldability in interface java.sql.Connection

Throws:

java.sql.SQLException

getHoldability

public int getHoldability()
                   throws java.sql.SQLException

Specified by:

getHoldability in interface java.sql.Connection

Throws:

java.sql.SQLException

setSavepoint

public java.sql.Savepoint setSavepoint()
                                throws java.sql.SQLException

Specified by:

setSavepoint in interface java.sql.Connection

Throws:

java.sql.SQLException

setSavepoint

public java.sql.Savepoint setSavepoint(java.lang.String name)
                                throws java.sql.SQLException

Specified by:

setSavepoint in interface java.sql.Connection

Throws:

java.sql.SQLException

rollback

public void rollback(java.sql.Savepoint savepoint)
              throws java.sql.SQLException

Specified by:

rollback in interface java.sql.Connection

Throws:

java.sql.SQLException

releaseSavepoint

public void releaseSavepoint(java.sql.Savepoint savepoint)
                      throws java.sql.SQLException

Specified by:

releaseSavepoint in interface java.sql.Connection

Throws:

java.sql.SQLException

createStatement

public java.sql.Statement createStatement(int resultSetType,
                                          int resultSetConcurrency,
                                          int resultSetHoldability)
                                   throws java.sql.SQLException

Specified by:

createStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   int resultSetType,
                                                   int resultSetConcurrency,
                                                   int resultSetHoldability)
                                            throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareCall

public java.sql.CallableStatement prepareCall(java.lang.String sql,
                                              int resultSetType,
                                              int resultSetConcurrency,
                                              int resultSetHoldability)
                                       throws java.sql.SQLException

Specified by:

prepareCall in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   int autoGeneratedKeys)
                                            throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   int[] columnIndexes)
                                            throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   java.lang.String[] columnNames)
                                            throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

Throws:

java.sql.SQLException

newSectionManager

public abstract SectionManager newSectionManager(Agent agent)

completeConnect

public final void completeConnect()
                           throws SqlException

Throws:

SqlException

writeCommitSubstitute_

public abstract void writeCommitSubstitute_()
                                     throws SqlException

Throws:

SqlException

readCommitSubstitute_

public abstract void readCommitSubstitute_()
                                    throws SqlException

Throws:

SqlException

writeLocalXAStart_

public abstract void writeLocalXAStart_()
                                 throws SqlException

Throws:

SqlException

readLocalXAStart_

public abstract void readLocalXAStart_()
                                throws SqlException

Throws:

SqlException

writeLocalXACommit_

public abstract void writeLocalXACommit_()
                                  throws SqlException

Throws:

SqlException

readLocalXACommit_

public abstract void readLocalXACommit_()
                                 throws SqlException

Throws:

SqlException

writeLocalCommit_

public abstract void writeLocalCommit_()
                                throws SqlException

Throws:

SqlException

readLocalCommit_

public abstract void readLocalCommit_()
                               throws SqlException

Throws:

SqlException

completeLocalCommit

public void completeLocalCommit()

Specified by:

completeLocalCommit in interface ConnectionCallbackInterface

writeLocalRollback_

public abstract void writeLocalRollback_()
                                  throws SqlException

Throws:

SqlException

readLocalRollback_

public abstract void readLocalRollback_()
                                 throws SqlException

Throws:

SqlException

completeLocalRollback

public void completeLocalRollback()

Specified by:

completeLocalRollback in interface ConnectionCallbackInterface

writeLocalXARollback_

public abstract void writeLocalXARollback_()
                                    throws SqlException

Throws:

SqlException

readLocalXARollback_

public abstract void readLocalXARollback_()
                                   throws SqlException

Throws:

SqlException

writeTransactionStart

public void writeTransactionStart(ClientStatement statement)
                           throws SqlException

Throws:

SqlException

readTransactionStart

public void readTransactionStart()
                          throws SqlException

Throws:

SqlException

completeAbnormalUnitOfWork

public void completeAbnormalUnitOfWork()

Specified by:

completeAbnormalUnitOfWork in interface ConnectionCallbackInterface

completeAbnormalUnitOfWork

public void completeAbnormalUnitOfWork(UnitOfWorkListener uwl)

Rollback the UnitOfWorkListener specifically.

Specified by:

completeAbnormalUnitOfWork in interface ConnectionCallbackInterface

Parameters:

uwl - The UnitOfWorkListener to be rolled back.

completeChainBreakingDisconnect

public void completeChainBreakingDisconnect()

Specified by:

completeChainBreakingDisconnect in interface ConnectionCallbackInterface

completeSqlca

public void completeSqlca(Sqlca sqlca)

Specified by:

completeSqlca in interface ConnectionCallbackInterface

completePiggyBackIsolation

public void completePiggyBackIsolation(int pbIsolation)

Description copied from interface: ConnectionCallbackInterface

Completes piggy-backing of the new current isolation level by updating the cached copy in am.Connection.

Specified by:

completePiggyBackIsolation in interface ConnectionCallbackInterface

Parameters:

pbIsolation - new isolation level from the server

completeInitialPiggyBackIsolation

public void completeInitialPiggyBackIsolation(int pbIsolation)

Sets the default isolation level of the connection upon connection initialization.

Note that depending on the server version, the default isolation value may not be piggy-backed on the initialization flow. In that case, the default is assumed / hardcoded to be READ_COMMITTED.

Parameters:

pbIsolation - isolation level as specified by java.sql.Connection

completePiggyBackSchema

public void completePiggyBackSchema(java.lang.String pbSchema)

Description copied from interface: ConnectionCallbackInterface

Completes piggy-backing of the new current schema by updating the cached copy in am.Connection.

Specified by:

completePiggyBackSchema in interface ConnectionCallbackInterface

Parameters:

pbSchema - new current schema from the server

completeInitialPiggyBackSchema

public void completeInitialPiggyBackSchema(java.lang.String pbSchema)

Sets the current schema upon connection initialization.

Parameters:

pbSchema - the schema name

reset

public void reset(LogWriter logWriter)
           throws SqlException

Throws:

SqlException

lightReset

public void lightReset()
                throws SqlException

Throws:

SqlException

isXAConnection

public boolean isXAConnection()

getXAState

public int getXAState()

setXAState

public void setXAState(int state)

getServerVersion

public int getServerVersion()

createClob

public java.sql.Clob createClob()
                         throws java.sql.SQLException

Constructs an object that implements the Clob interface. The object returned initially contains no data.

Specified by:

createClob in interface java.sql.Connection

Returns:

An object that implements the Clob interface

Throws:

java.sql.SQLException - if an object that implements the Clob interface can not be constructed.

createBlob

public java.sql.Blob createBlob()
                         throws java.sql.SQLException

Constructs an object that implements the Blob interface. The object returned initially contains no data.

Specified by:

createBlob in interface java.sql.Connection

Returns:

An object that implements the Blob interface

Throws:

java.sql.SQLException - if an object that implements the Blob interface can not be constructed.

isAborting

public boolean isAborting()

Return true if the connection is aborting

getSchema

public java.lang.String getSchema()
                           throws java.sql.SQLException

Get the name of the current schema.

Specified by:

getSchema in interface java.sql.Connection

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 interface java.sql.Connection

Throws:

java.sql.SQLException

abort

public void abort(java.util.concurrent.Executor executor)
           throws java.sql.SQLException

Specified by:

abort in interface java.sql.Connection

Throws:

java.sql.SQLException

getNetworkTimeout

public int getNetworkTimeout()
                      throws java.sql.SQLException

Specified by:

getNetworkTimeout in interface java.sql.Connection

Throws:

java.sql.SQLException

setNetworkTimeout

public void setNetworkTimeout(java.util.concurrent.Executor executor,
                              int milliseconds)
                       throws java.sql.SQLException

Specified by:

setNetworkTimeout in interface java.sql.Connection

Throws:

java.sql.SQLException