Class NetConnection

java.lang.Object

org.apache.derby.client.am.ClientConnection

org.apache.derby.client.net.NetConnection

All Implemented Interfaces:

AutoCloseable, Connection, Wrapper, ConnectionCallbackInterface

public class NetConnection
extends ClientConnection

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	closeStatementsOnClose
private boolean	connectionNull
(package private) byte[]	crrtkn_
protected int	currXACallInfoOffset_
private char[]	deferredResetPassword_
private String	extnam_
private List<Xid>	indoubtTransactions_
private PreparedStatement	isValidStmt	Prepared statement that is used each time isValid() is called on this connection.
private static final MessageUtil	msgutil
protected NetAgent	netAgent_
private final ClientPooledConnection	pooledConnection_
private ByteBuffer	prddta_
private byte[]	publicKey_
private int	securityMechanism_
private byte[]	sourceSeed_
protected int	targetAgent_
protected int	targetCmnappc_
protected int	targetCmntcpip_
private byte[]	targetPublicKey_
protected int	targetRdb_
protected int	targetRsyncmgr_
private int	targetSecmec_
(package private) int	targetSecmgr_
private byte[]	targetSeed_
(package private) String	targetSrvclsnm_
(package private) String	targetSrvrlslv_
protected int	targetSyncptmgr_
protected int	targetUnicodemgr_
protected int	targetXamgr_
protected NetXAResource	xares_

Fields inherited from class ClientConnection

agent_, autoCommit_, commBufferSize_, databaseMetaData_, databaseName_, dataSource_, encryptionManager_, inUnitOfWork_, isXAConnection_, open_, portNumber_, productID_, resetConnectionAtFirstSql_, serverNameIP_, user_, XA_T0_NOT_ASSOCIATED, XA_T1_ASSOCIATED, xaHostVersion_

Fields inherited from interface Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors

Constructor	Description
NetConnection(LogWriter logWriter, int driverManagerLoginTimeout, String serverName, int portNumber, String databaseName, Properties properties)
NetConnection(LogWriter logWriter, String user, String password, BasicClientDataSource40 dataSource, int rmId, boolean isXAConn)
NetConnection(LogWriter logWriter, String user, String password, BasicClientDataSource40 dataSource, int rmId, boolean isXAConn, ClientPooledConnection cpc)	This constructor is called from the ClientPooledConnection object to enable the NetConnection to pass this on to the associated prepared statement object thus enabling the prepared statement object to in turn raise the statement events to the ClientPooledConnection object

Method Summary

Modifier and Type	Method	Description
protected boolean	allowCloseInUOW_()	Check if the connection can be closed when there are uncommitted operations.
protected boolean	allowLocalCommitRollback_()
private void	checkDatabaseName()
private void	checkPasswordLength(String password)
private void	checkSecmgrForSecmecSupport(int securityMechanism)
private void	checkUser(String user)
private void	checkUserLength(String user)
private void	checkUserPassword(String user, String password)
void	close()	Close the connection and release its resources.
private void	completeReset(boolean isDeferredReset)
protected void	constructCrrtkn()
private void	constructExtnam()
private void	constructPrddta()
Array	createArrayOf(String typeName, Object[] elements)
NClob	createNClob()
SQLXML	createSQLXML()
Struct	createStruct(String typeName, Object[] attributes)
protected boolean	doCloseStatementsOnClose_()
private byte[]	encryptedPasswordForEUSRIDPWD(String password)
private byte[]	encryptedPasswordForUSRENCPWD(String password)
private byte[]	encryptedUseridForEUSRIDPWD()
private char[]	flipBits(char[] array)
private void	flowConnect(String password, int securityMechanism)
private void	flowEUSRIDDTAconnect()
private void	flowEUSRIDPWDconnect(String password)
private void	flowEUSRPWDDTAconnect(String password)
private void	flowKeyExchange(int securityMechanism, byte[] publicKey)
private boolean	flowReconnect(String password, int securityMechanism)
private void	flowSecurityCheckAndAccessRdb(int securityMechanism, String user, String password, byte[] encryptedUserid, byte[] encryptedPassword)
private void	flowSeedExchange(int securityMechanism, byte[] sourceSeed)
private void	flowServerAttributes()
private void	flowServerAttributesAndKeyExchange(int securityMechanism, byte[] publicKey)
private void	flowSimpleConnect()
private void	flowUSRENCPWDconnect(String password)
private void	flowUSRIDONLconnect()
private void	flowUSRIDPWDconnect(String password)
private void	flowUSRSSBPWDconnect(String password)	The User ID and Strong Password Substitute mechanism (USRSSBPWD) authenticates the user like the user ID and password mechanism, but the password does not flow.
int	getAGENT()
Properties	getClientInfo()	getClientInfo always returns an empty Properties object since Derby doesn't support ClientInfoProperties.
String	getClientInfo(String name)	getClientInfo always returns a null String since Derby doesn't support ClientInfoProperties.
int	getCMNTCPIP()
private String	getDeferredResetPassword()
EncryptionManager	getEncryptionManager()
(package private) Xid[]	getIndoubtTransactionIds()
InputStream	getInputStream()
OutputStream	getOutputStream()
String	getProductID()
int	getRDB()
int	getRSYNCMGR()
int	getSECMGR()
int	getSecurityMechanism()
int	getSQLAM()
int	getSYNCPTMGR()
byte[]	getTargetPublicKey()
int	getXAMGR()
private void	handleLoginTimeout(Throwable original)	Handle socket timeouts during connection attempts
private void	initialize(String password, BasicClientDataSource40 dataSource, boolean isXAConn)
private void	initializeClientSeed()
private void	initializePublicKeyForEncryption()
final boolean	isConnectionNull()
protected boolean	isGlobalPending_()
boolean	isOpen()	Returns if a transaction is in process
boolean	isValid(int timeout)	Checks if the connection has not been closed and is still valid.
boolean	isWrapperFor(Class<?> interfaces)	Returns false unless interfaces is implemented
private SqlException	mapSecchkcd(int secchkcd)
protected void	markClosed_()
protected Agent	newAgent_(LogWriter logWriter, int loginTimeout, String serverName, int portNumber, int clientSSLMode)
protected ClientCallableStatement	newCallableStatement_(String sql, int type, int concurrency, int holdability)
protected ClientDatabaseMetaData	newDatabaseMetaData_()
protected ClientPreparedStatement	newPositionedUpdatePreparedStatement_(String sql, Section section)
protected ClientPreparedStatement	newPreparedStatement_(String sql, int type, int concurrency, int holdability, int autoGeneratedKeys, String[] columnNames, int[] columnIndexes)
SectionManager	newSectionManager(Agent agent)
protected ClientStatement	newStatement_(int type, int concurrency, int holdability)
private byte[]	passwordSubstituteForUSRSSBPWD(String password)
(package private) void	rdbAccessed(int svrcod, String prdid, boolean crrtknReceived, byte[] crrtkn)
private void	readAllConnectCommandsChained(int securityMechanism)
void	readCommitSubstitute_()
(package private) void	readDeferredReset()
void	readLocalCommit_()
void	readLocalRollback_()
void	readLocalXACommit_()
void	readLocalXARollback_()
void	readLocalXAStart_()
private void	readSecurityCheckAndAccessRdb()
private void	readServerAttributesAndKeyExchange(int securityMechanism)
void	readTransactionStart()
protected void	readXACommit_()	Invokes readCommit on NetXAConnection
protected void	readXARollback_()	Invokes writeRollback on NetXAConnection
protected void	reset_(LogWriter logWriter)
protected void	resetCallableStatement_(ClientCallableStatement cs, String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
private void	resetNetConnection(LogWriter logWriter)
protected void	resetPreparedStatement_(ClientPreparedStatement ps, String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability, int autoGeneratedKeys, String[] columnNames, int[] columnIndexes)
protected void	resetStatement_(ClientStatement statement, int type, int concurrency, int holdability)
(package private) void	securityCheckComplete(int svrcod, int secchkcd)
final boolean	serverSupportLongRDBNAM()
protected final boolean	serverSupportsEXTDTAAbort()
final boolean	serverSupportsLayerBStreaming()
protected final boolean	serverSupportsLocators()	Checks whether the server supports locators for large objects.
(package private) final boolean	serverSupportsQryclsimp()	Check whether the server has full support for the QRYCLSIMP parameter in OPNQRY.
protected final boolean	serverSupportsTimestampNanoseconds()	Return true if the server supports nanoseconds in timestamps
protected final boolean	serverSupportsUDTs()	Check whether the server supports UDTs
protected final boolean	serverSupportsUtf8Ccsid()	Check whether the server supports the UTF-8 Ccsid Manager
(package private) void	setAccessSecurityData(int secchkcd, int desiredSecmec, int[] secmecList, boolean sectknReceived, byte[] sectkn)
void	setClientInfo(String name, String value)	setClientInfo will always throw a SQLClientInfoException since Derby does not support any properties.
void	setClientInfo(Properties properties)	setClientInfo will throw a SQLClientInfoException unless the properties parameter is empty, since Derby does not support any properties.
void	setConnectionNull(boolean connectionNull)
private void	setDeferredResetPassword(String password)
void	setIndoubtTransactions(List<Xid> indoubtTransactions)
void	setInputStream(InputStream inputStream)
void	setOutputStream(OutputStream outputStream)
(package private) void	setServerAttributeData(String srvclsnm, String srvrlslv)
protected final boolean	supportsSessionDataCaching()	Check whether the server supports session data caching
<T> T	unwrap(Class<T> interfaces)	Returns this if this class implements the interface
boolean	willAutoCommitGenerateFlow()
private void	writeAllConnectCommandsChained(int securityMechanism, String user, String password)
void	writeCommitSubstitute_()
(package private) void	writeDeferredReset()
void	writeLocalCommit_()
void	writeLocalRollback_()
void	writeLocalXACommit_()
void	writeLocalXARollback_()
void	writeLocalXAStart_()
private void	writeSecurityCheckAndAccessRdb(int securityMechanism, String user, String password, byte[] encryptedUserid, byte[] encryptedPassword)
private void	writeServerAttributesAndKeyExchange(int securityMechanism, byte[] publicKey)
void	writeTransactionStart(ClientStatement statement)
protected void	writeXACommit_()	Invokes write commit on NetXAConnection
protected void	writeXARollback_()	Invokes writeRollback on NetXAConnection
protected void	writeXATransactionStart(ClientStatement statement)

Methods inherited from class ClientConnection

abort, beginAborting, checkForClosedConnection, clearWarnings, closeResources, commit, completeAbnormalUnitOfWork, completeAbnormalUnitOfWork, completeChainBreakingDisconnect, completeConnect, completeInitialPiggyBackIsolation, completeInitialPiggyBackSchema, completeLocalCommit, completeLocalRollback, completePiggyBackIsolation, completePiggyBackSchema, completeReset, completeSqlca, createBlob, createClob, createStatement, createStatement, createStatement, finalize, flowAutoCommit, flowRollback, getAutoCommit, getCatalog, getCurrentSchemaName, getHoldability, getMetaData, getNetworkTimeout, getSchema, getServerVersion, getTransactionID, getTransactionIsolation, getTransactionIsolationX, getTypeMap, getWarnings, getXAState, isAborting, isClosed, isClosedX, isPhysicalConnClosed, isReadOnly, isXAConnection, lightReset, nativeSQL, prepareCall, prepareCall, prepareCall, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, releaseSavepoint, reset, resetConnection, resetPrepareCall, resetPrepareStatement, resetStatement, rollback, rollback, setAutoCommit, setCatalog, setHoldability, setNetworkTimeout, setReadOnly, setSavepoint, setSavepoint, setSchema, setTransactionIsolation, setTypeMap, setXAState, transactionInProgress

Methods inherited from class Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Connection

beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid

Field Details

msgutil

private static final MessageUtil msgutil

netAgent_

protected NetAgent netAgent_

pooledConnection_

private final ClientPooledConnection pooledConnection_

closeStatementsOnClose

private final boolean closeStatementsOnClose

targetAgent_

protected int targetAgent_

targetCmntcpip_

protected int targetCmntcpip_

targetRdb_

protected int targetRdb_

targetSecmgr_

int targetSecmgr_

targetCmnappc_

protected int targetCmnappc_

targetXamgr_

protected int targetXamgr_

targetSyncptmgr_

protected int targetSyncptmgr_

targetRsyncmgr_

protected int targetRsyncmgr_

targetUnicodemgr_

protected int targetUnicodemgr_

extnam_

private String extnam_

targetSrvclsnm_

String targetSrvclsnm_

targetSrvrlslv_

String targetSrvrlslv_

publicKey_

private transient byte[] publicKey_

targetPublicKey_

private transient byte[] targetPublicKey_

sourceSeed_

private transient byte[] sourceSeed_

targetSeed_

private transient byte[] targetSeed_

prddta_

private ByteBuffer prddta_

crrtkn_

byte[] crrtkn_

targetSecmec_

private int targetSecmec_

securityMechanism_

private int securityMechanism_

deferredResetPassword_

private transient char[] deferredResetPassword_

connectionNull

private boolean connectionNull

xares_

protected NetXAResource xares_

indoubtTransactions_

private List<Xid> indoubtTransactions_

currXACallInfoOffset_

protected int currXACallInfoOffset_

isValidStmt

private PreparedStatement isValidStmt

Prepared statement that is used each time isValid() is called on this connection. The statement is created the first time isValid is called and closed when the connection is closed (by the close call).

Constructor Details

NetConnection

NetConnection(LogWriter logWriter,
 int driverManagerLoginTimeout,
 String serverName,
 int portNumber,
 String databaseName,
 Properties properties)
       throws SqlException

Throws:

SqlException

NetConnection

NetConnection(LogWriter logWriter,
 String user,
 String password,
 BasicClientDataSource40 dataSource,
 int rmId,
 boolean isXAConn)
       throws SqlException

Throws:

SqlException

NetConnection

NetConnection(LogWriter logWriter,
 String user,
 String password,
 BasicClientDataSource40 dataSource,
 int rmId,
 boolean isXAConn,
 ClientPooledConnection cpc)
       throws SqlException

This constructor is called from the ClientPooledConnection object to enable the NetConnection to pass this on to the associated prepared statement object thus enabling the prepared statement object to in turn raise the statement events to the ClientPooledConnection object

Parameters:

logWriter - LogWriter object associated with this connection

user - user id for this connection

password - password for this connection

dataSource - The DataSource object passed from the PooledConnection object from which this constructor was called

rmId - The Resource manager ID for XA Connections

isXAConn - true if this is a XA connection

cpc - The ClientPooledConnection object from which this NetConnection constructor was called. This is used to pass StatementEvents back to the pooledConnection object

Throws:

SqlException

Method Details

setDeferredResetPassword

private void setDeferredResetPassword(String password)

getDeferredResetPassword

private String getDeferredResetPassword()

initialize

private void initialize(String password,
 BasicClientDataSource40 dataSource,
 boolean isXAConn)
                 throws SqlException

Throws:

SqlException

resetNetConnection

private void resetNetConnection(LogWriter logWriter)
                         throws SqlException

Throws:

SqlException

reset_

protected void reset_(LogWriter logWriter)
               throws SqlException

Specified by:

reset_ in class ClientConnection

Throws:

SqlException

completeReset

private void completeReset(boolean isDeferredReset)
                    throws SqlException

Throws:

SqlException

flowConnect

private void flowConnect(String password,
 int securityMechanism)
                  throws SqlException

Throws:

SqlException

flowSimpleConnect

private void flowSimpleConnect()
                        throws SqlException

Throws:

SqlException

handleLoginTimeout

private void handleLoginTimeout(Throwable original)
                         throws SqlException

Handle socket timeouts during connection attempts

Throws:

SqlException

flowReconnect

private boolean flowReconnect(String password,
 int securityMechanism)
                       throws SqlException

Throws:

SqlException

flowUSRIDPWDconnect

private void flowUSRIDPWDconnect(String password)
                          throws SqlException

Throws:

SqlException

flowUSRIDONLconnect

private void flowUSRIDONLconnect()
                          throws SqlException

Throws:

SqlException

flowUSRENCPWDconnect

private void flowUSRENCPWDconnect(String password)
                           throws SqlException

Throws:

SqlException

flowEUSRIDPWDconnect

private void flowEUSRIDPWDconnect(String password)
                           throws SqlException

Throws:

SqlException

flowEUSRIDDTAconnect

private void flowEUSRIDDTAconnect()
                           throws SqlException

Throws:

SqlException

flowEUSRPWDDTAconnect

private void flowEUSRPWDDTAconnect(String password)
                            throws SqlException

Throws:

SqlException

flowUSRSSBPWDconnect

private void flowUSRSSBPWDconnect(String password)
                           throws SqlException

The User ID and Strong Password Substitute mechanism (USRSSBPWD) authenticates the user like the user ID and password mechanism, but the password does not flow. A password substitute is generated instead using the SHA-1 algorithm, and is sent to the application server. The application server generates a password substitute using the same algorithm and compares it with the application requester's password substitute. If equal, the user is authenticated. The SECTKN parameter is used to flow the client and server encryption seeds on the ACCSEC and ACCSECRD commands. More information in DRDA, V3, Volume 3 standard - PWDSSB (page 650)

Throws:

SqlException

flowServerAttributes

private void flowServerAttributes()
                           throws SqlException

Throws:

SqlException

flowKeyExchange

private void flowKeyExchange(int securityMechanism,
 byte[] publicKey)
                      throws SqlException

Throws:

SqlException

flowSeedExchange

private void flowSeedExchange(int securityMechanism,
 byte[] sourceSeed)
                       throws SqlException

Throws:

SqlException

flowServerAttributesAndKeyExchange

private void flowServerAttributesAndKeyExchange(int securityMechanism,
 byte[] publicKey)
                                         throws SqlException

Throws:

SqlException

flowSecurityCheckAndAccessRdb

private void flowSecurityCheckAndAccessRdb(int securityMechanism,
 String user,
 String password,
 byte[] encryptedUserid,
 byte[] encryptedPassword)
                                    throws SqlException

Throws:

SqlException

writeAllConnectCommandsChained

private void writeAllConnectCommandsChained(int securityMechanism,
 String user,
 String password)
                                     throws SqlException

Throws:

SqlException

readAllConnectCommandsChained

private void readAllConnectCommandsChained(int securityMechanism)
                                    throws SqlException

Throws:

SqlException

writeServerAttributesAndKeyExchange

private void writeServerAttributesAndKeyExchange(int securityMechanism,
 byte[] publicKey)
                                          throws SqlException

Throws:

SqlException

readServerAttributesAndKeyExchange

private void readServerAttributesAndKeyExchange(int securityMechanism)
                                         throws SqlException

Throws:

SqlException

writeSecurityCheckAndAccessRdb

private void writeSecurityCheckAndAccessRdb(int securityMechanism,
 String user,
 String password,
 byte[] encryptedUserid,
 byte[] encryptedPassword)
                                     throws SqlException

Throws:

SqlException

readSecurityCheckAndAccessRdb

private void readSecurityCheckAndAccessRdb()
                                    throws SqlException

Throws:

SqlException

writeDeferredReset

void writeDeferredReset()
                 throws SqlException

Throws:

SqlException

readDeferredReset

void readDeferredReset()
                throws SqlException

Throws:

SqlException

setServerAttributeData

void setServerAttributeData(String srvclsnm,
 String srvrlslv)

setAccessSecurityData

void setAccessSecurityData(int secchkcd,
 int desiredSecmec,
 int[] secmecList,
 boolean sectknReceived,
 byte[] sectkn)
                    throws DisconnectException

Throws:

DisconnectException

securityCheckComplete

void securityCheckComplete(int svrcod,
 int secchkcd)

rdbAccessed

void rdbAccessed(int svrcod,
 String prdid,
 boolean crrtknReceived,
 byte[] crrtkn)

newAgent_

protected Agent newAgent_(LogWriter logWriter,
 int loginTimeout,
 String serverName,
 int portNumber,
 int clientSSLMode)
                   throws SqlException

Specified by:

newAgent_ in class ClientConnection

Throws:

SqlException

newStatement_

protected ClientStatement newStatement_(int type,
 int concurrency,
 int holdability)
                                 throws SqlException

Specified by:

newStatement_ in class ClientConnection

Throws:

SqlException

resetStatement_

protected void resetStatement_(ClientStatement statement,
 int type,
 int concurrency,
 int holdability)
                        throws SqlException

Specified by:

resetStatement_ in class ClientConnection

Throws:

SqlException

newPositionedUpdatePreparedStatement_

protected ClientPreparedStatement newPositionedUpdatePreparedStatement_(String sql,
 Section section)
                                                                 throws SqlException

Specified by:

newPositionedUpdatePreparedStatement_ in class ClientConnection

Throws:

SqlException

newPreparedStatement_

protected ClientPreparedStatement newPreparedStatement_(String sql,
 int type,
 int concurrency,
 int holdability,
 int autoGeneratedKeys,
 String[] columnNames,
 int[] columnIndexes)
                                                 throws SqlException

Specified by:

newPreparedStatement_ in class ClientConnection

Throws:

SqlException

resetPreparedStatement_

protected void resetPreparedStatement_(ClientPreparedStatement ps,
 String sql,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability,
 int autoGeneratedKeys,
 String[] columnNames,
 int[] columnIndexes)
                                throws SqlException

Specified by:

resetPreparedStatement_ in class ClientConnection

Throws:

SqlException

newCallableStatement_

protected ClientCallableStatement newCallableStatement_(String sql,
 int type,
 int concurrency,
 int holdability)
                                                 throws SqlException

Specified by:

newCallableStatement_ in class ClientConnection

Throws:

SqlException

resetCallableStatement_

protected void resetCallableStatement_(ClientCallableStatement cs,
 String sql,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                                throws SqlException

Specified by:

resetCallableStatement_ in class ClientConnection

Throws:

SqlException

newDatabaseMetaData_

protected ClientDatabaseMetaData newDatabaseMetaData_()

Specified by:

newDatabaseMetaData_ in class ClientConnection

checkDatabaseName

private void checkDatabaseName()
                        throws SqlException

Throws:

SqlException

checkUserLength

private void checkUserLength(String user)
                      throws SqlException

Throws:

SqlException

checkPasswordLength

private void checkPasswordLength(String password)
                          throws SqlException

Throws:

SqlException

checkUser

private void checkUser(String user)
                throws SqlException

Throws:

SqlException

checkUserPassword

private void checkUserPassword(String user,
 String password)
                        throws SqlException

Throws:

SqlException

checkSecmgrForSecmecSupport

private void checkSecmgrForSecmecSupport(int securityMechanism)
                                  throws SqlException

Throws:

SqlException

mapSecchkcd

private SqlException mapSecchkcd(int secchkcd)

constructCrrtkn

protected void constructCrrtkn()
                        throws SqlException

Throws:

SqlException

constructExtnam

private void constructExtnam()
                      throws SqlException

Throws:

SqlException

constructPrddta

private void constructPrddta()
                      throws SqlException

Throws:

SqlException

initializePublicKeyForEncryption

private void initializePublicKeyForEncryption()
                                       throws SqlException

Throws:

SqlException

initializeClientSeed

private void initializeClientSeed()
                           throws SqlException

Throws:

SqlException

encryptedPasswordForUSRENCPWD

private byte[] encryptedPasswordForUSRENCPWD(String password)
                                      throws SqlException

Throws:

SqlException

encryptedUseridForEUSRIDPWD

private byte[] encryptedUseridForEUSRIDPWD()
                                    throws SqlException

Throws:

SqlException

encryptedPasswordForEUSRIDPWD

private byte[] encryptedPasswordForEUSRIDPWD(String password)
                                      throws SqlException

Throws:

SqlException

passwordSubstituteForUSRSSBPWD

private byte[] passwordSubstituteForUSRSSBPWD(String password)
                                       throws SqlException

Throws:

SqlException

getSQLAM

public int getSQLAM()

getAGENT

public int getAGENT()

getCMNTCPIP

public int getCMNTCPIP()

getRDB

public int getRDB()

getSECMGR

public int getSECMGR()

getXAMGR

public int getXAMGR()

getSYNCPTMGR

public int getSYNCPTMGR()

getRSYNCMGR

public int getRSYNCMGR()

flipBits

private char[] flipBits(char[] array)

writeCommitSubstitute_

public void writeCommitSubstitute_()
                            throws SqlException

Specified by:

writeCommitSubstitute_ in class ClientConnection

Throws:

SqlException

readCommitSubstitute_

public void readCommitSubstitute_()
                           throws SqlException

Specified by:

readCommitSubstitute_ in class ClientConnection

Throws:

SqlException

writeLocalXAStart_

public void writeLocalXAStart_()
                        throws SqlException

Specified by:

writeLocalXAStart_ in class ClientConnection

Throws:

SqlException

readLocalXAStart_

public void readLocalXAStart_()
                       throws SqlException

Specified by:

readLocalXAStart_ in class ClientConnection

Throws:

SqlException

writeLocalXACommit_

public void writeLocalXACommit_()
                         throws SqlException

Specified by:

writeLocalXACommit_ in class ClientConnection

Throws:

SqlException

readLocalXACommit_

public void readLocalXACommit_()
                        throws SqlException

Specified by:

readLocalXACommit_ in class ClientConnection

Throws:

SqlException

writeLocalXARollback_

public void writeLocalXARollback_()
                           throws SqlException

Specified by:

writeLocalXARollback_ in class ClientConnection

Throws:

SqlException

readLocalXARollback_

public void readLocalXARollback_()
                          throws SqlException

Specified by:

readLocalXARollback_ in class ClientConnection

Throws:

SqlException

writeLocalCommit_

public void writeLocalCommit_()
                       throws SqlException

Specified by:

writeLocalCommit_ in class ClientConnection

Throws:

SqlException

readLocalCommit_

public void readLocalCommit_()
                      throws SqlException

Specified by:

readLocalCommit_ in class ClientConnection

Throws:

SqlException

writeLocalRollback_

public void writeLocalRollback_()
                         throws SqlException

Specified by:

writeLocalRollback_ in class ClientConnection

Throws:

SqlException

readLocalRollback_

public void readLocalRollback_()
                        throws SqlException

Specified by:

readLocalRollback_ in class ClientConnection

Throws:

SqlException

markClosed_

protected void markClosed_()

Specified by:

markClosed_ in class ClientConnection

isGlobalPending_

protected boolean isGlobalPending_()

Specified by:

isGlobalPending_ in class ClientConnection

doCloseStatementsOnClose_

protected boolean doCloseStatementsOnClose_()

Specified by:

doCloseStatementsOnClose_ in class ClientConnection

allowCloseInUOW_

protected boolean allowCloseInUOW_()

Check if the connection can be closed when there are uncommitted operations.

Specified by:

allowCloseInUOW_ in class ClientConnection

Returns:

if this connection can be closed when it has uncommitted operations, true; otherwise, false

allowLocalCommitRollback_

protected boolean allowLocalCommitRollback_()

Specified by:

allowLocalCommitRollback_ in class ClientConnection

setInputStream

public void setInputStream(InputStream inputStream)

setOutputStream

public void setOutputStream(OutputStream outputStream)

getInputStream

public InputStream getInputStream()

getOutputStream

public OutputStream getOutputStream()

writeTransactionStart

public void writeTransactionStart(ClientStatement statement)
                           throws SqlException

Overrides:

writeTransactionStart in class ClientConnection

Throws:

SqlException

readTransactionStart

public void readTransactionStart()
                          throws SqlException

Overrides:

readTransactionStart in class ClientConnection

Throws:

SqlException

setIndoubtTransactions

public void setIndoubtTransactions(List<Xid> indoubtTransactions)

getIndoubtTransactionIds

Xid[] getIndoubtTransactionIds()

newSectionManager

public SectionManager newSectionManager(Agent agent)

Specified by:

newSectionManager in class ClientConnection

willAutoCommitGenerateFlow

public boolean willAutoCommitGenerateFlow()

Overrides:

willAutoCommitGenerateFlow in class ClientConnection

getSecurityMechanism

public int getSecurityMechanism()

getEncryptionManager

public EncryptionManager getEncryptionManager()

getTargetPublicKey

public byte[] getTargetPublicKey()

getProductID

public String getProductID()

isConnectionNull

public final boolean isConnectionNull()

Returns:

Returns the connectionNull.

setConnectionNull

public void setConnectionNull(boolean connectionNull)

Parameters:

connectionNull - The connectionNull to set.

serverSupportsQryclsimp

final boolean serverSupportsQryclsimp()

Check whether the server has full support for the QRYCLSIMP parameter in OPNQRY.

Returns:

true if QRYCLSIMP is fully supported

serverSupportsLayerBStreaming

public final boolean serverSupportsLayerBStreaming()

serverSupportLongRDBNAM

public final boolean serverSupportLongRDBNAM()

supportsSessionDataCaching

protected final boolean supportsSessionDataCaching()

Check whether the server supports session data caching

Specified by:

supportsSessionDataCaching in class ClientConnection

Returns:

true session data caching is supported

serverSupportsUtf8Ccsid

protected final boolean serverSupportsUtf8Ccsid()

Check whether the server supports the UTF-8 Ccsid Manager

Returns:

true if the server supports the UTF-8 Ccsid Manager

serverSupportsUDTs

protected final boolean serverSupportsUDTs()

Check whether the server supports UDTs

Returns:

true if UDTs are supported

serverSupportsEXTDTAAbort

protected final boolean serverSupportsEXTDTAAbort()

serverSupportsLocators

protected final boolean serverSupportsLocators()

Checks whether the server supports locators for large objects.

Specified by:

serverSupportsLocators in class ClientConnection

Returns:

true if LOB locators are supported.

serverSupportsTimestampNanoseconds

protected final boolean serverSupportsTimestampNanoseconds()

Return true if the server supports nanoseconds in timestamps

Specified by:

serverSupportsTimestampNanoseconds in class ClientConnection

isOpen

public boolean isOpen()

Returns if a transaction is in process

Returns:

open

writeXACommit_

protected void writeXACommit_()
                       throws SqlException

Invokes write commit on NetXAConnection

Specified by:

writeXACommit_ in class ClientConnection

Throws:

SqlException

readXACommit_

protected void readXACommit_()
                      throws SqlException

Invokes readCommit on NetXAConnection

Specified by:

readXACommit_ in class ClientConnection

Throws:

SqlException

writeXARollback_

protected void writeXARollback_()
                         throws SqlException

Invokes writeRollback on NetXAConnection

Specified by:

writeXARollback_ in class ClientConnection

Throws:

SqlException

readXARollback_

protected void readXARollback_()
                        throws SqlException

Invokes writeRollback on NetXAConnection

Specified by:

readXARollback_ in class ClientConnection

Throws:

SqlException

writeXATransactionStart

protected void writeXATransactionStart(ClientStatement statement)
                                throws SqlException

Specified by:

writeXATransactionStart in class ClientConnection

Throws:

SqlException

createArrayOf

public Array createArrayOf(String typeName,
 Object[] elements)
                    throws SQLException

Throws:

SQLException

createNClob

public NClob createNClob()
                  throws SQLException

Throws:

SQLException

createSQLXML

public SQLXML createSQLXML()
                    throws SQLException

Throws:

SQLException

createStruct

public Struct createStruct(String typeName,
 Object[] attributes)
                    throws SQLException

Throws:

SQLException

isValid

public boolean isValid(int timeout)
                throws 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. The timeout specified by the caller is implemented as follows: On the server: uses the queryTimeout functionality to make the query time out on the server in case the server has problems or is highly loaded. On the client: uses a timeout on the socket to make sure that the client is not blocked forever in the cases where the server is "hanging" or not sending the reply.

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:

SQLException - if the parameter value is illegal or if a database error has occurred

close

public void close()
           throws SQLException

Close the connection and release its resources.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Connection

Overrides:

close in class ClientConnection

Throws:

SQLException - if a database-access error occurs.

setClientInfo

public void setClientInfo(String name,
 String value)
                   throws SQLClientInfoException

setClientInfo will always throw a SQLClientInfoException since Derby does not support any properties.

Parameters:

name - a property key String

value - a property value String

Throws:

SQLClientInfoException - always.

setClientInfo

public void setClientInfo(Properties properties)
                   throws SQLClientInfoException

setClientInfo will throw a SQLClientInfoException unless the properties parameter is empty, since Derby does not support any properties. All the property keys in the properties parameter are added to failedProperties of the exception thrown, with REASON_UNKNOWN_PROPERTY as the value.

Parameters:

properties - a Properties object with the properties to set.

Throws:

SQLClientInfoException - unless the properties parameter is null or empty.

getClientInfo

public String getClientInfo(String name)
                     throws SQLException

getClientInfo always returns a null String since Derby doesn't support ClientInfoProperties.

Parameters:

name - a String value

Returns:

a null String value

Throws:

SQLException - if the connection is closed.

getClientInfo

public Properties getClientInfo()
                         throws SQLException

getClientInfo always returns an empty Properties object since Derby doesn't support ClientInfoProperties.

Returns:

an empty Properties object.

Throws:

SQLException - if the connection is closed.

isWrapperFor

public boolean isWrapperFor(Class<?> interfaces)
                     throws SQLException

Returns false unless interfaces is implemented

Parameters:

interfaces - a Class defining an interface.

Returns:

true if this implements the interface or directly or indirectly wraps an object that does.

Throws:

SQLException - if an error occurs while determining whether this is a wrapper for an object with the given interface.

unwrap

public <T> T unwrap(Class<T> interfaces)
             throws SQLException

Returns this if this class implements the interface

Parameters:

interfaces - a Class defining an interface

Returns:

an object that implements the interface

Throws:

SQLException - if no object if found that implements the interface