NetConnection (Apache Derby V10.14 Internals)

java.lang.Object
- org.apache.derby.client.am.ClientConnection
- - org.apache.derby.client.net.NetConnection

All Implemented Interfaces:

java.lang.AutoCloseable, java.sql.Connection, java.sql.Wrapper, ConnectionCallbackInterface
```
public class NetConnection
extends ClientConnection
```

Field Summary

Fields
Modifier and Type	Field	Description
`private boolean`	`closeStatementsOnClose`
`private boolean`	`connectionNull`
`(package private) byte[]`	`crrtkn_`
`protected int`	`currXACallInfoOffset_`
`private char[]`	`deferredResetPassword_`
`private java.lang.String`	`extnam_`
`private java.util.List<javax.transaction.xa.Xid>`	`indoubtTransactions_`
`private java.sql.PreparedStatement`	`isValidStmt`	Prepared statement that is used each time isValid() is called on this connection.
`private static MessageUtil`	`msgutil`
`protected NetAgent`	`netAgent_`
`private ClientPooledConnection`	`pooledConnection_`
`private java.nio.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) java.lang.String`	`targetSrvclsnm_`
`(package private) java.lang.String`	`targetSrvrlslv_`
`protected int`	`targetSyncptmgr_`
`protected int`	`targetUnicodemgr_`
`protected int`	`targetXamgr_`
`protected NetXAResource`	`xares_`

Fields inherited from class org.apache.derby.client.am.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 java.sql.Connection
TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors
Constructor	Description
`NetConnection(LogWriter logWriter, int driverManagerLoginTimeout, java.lang.String serverName, int portNumber, java.lang.String databaseName, java.util.Properties properties)`
`NetConnection(LogWriter logWriter, java.lang.String user, java.lang.String password, BasicClientDataSource40 dataSource, int rmId, boolean isXAConn)`
`NetConnection(LogWriter logWriter, java.lang.String user, java.lang.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

All Methods Instance Methods Concrete Methods
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(java.lang.String password)`
`private void`	`checkSecmgrForSecmecSupport(int securityMechanism)`
`private void`	`checkUser(java.lang.String user)`
`private void`	`checkUserLength(java.lang.String user)`
`private void`	`checkUserPassword(java.lang.String user, java.lang.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()`
`java.sql.Array`	`createArrayOf(java.lang.String typeName, java.lang.Object[] elements)`
`java.sql.NClob`	`createNClob()`
`java.sql.SQLXML`	`createSQLXML()`
`java.sql.Struct`	`createStruct(java.lang.String typeName, java.lang.Object[] attributes)`
`protected boolean`	`doCloseStatementsOnClose_()`
`private byte[]`	`encryptedPasswordForEUSRIDPWD(java.lang.String password)`
`private byte[]`	`encryptedPasswordForUSRENCPWD(java.lang.String password)`
`private byte[]`	`encryptedUseridForEUSRIDPWD()`
`private char[]`	`flipBits(char[] array)`
`private void`	`flowConnect(java.lang.String password, int securityMechanism)`
`private void`	`flowEUSRIDDTAconnect()`
`private void`	`flowEUSRIDPWDconnect(java.lang.String password)`
`private void`	`flowEUSRPWDDTAconnect(java.lang.String password)`
`private void`	`flowKeyExchange(int securityMechanism, byte[] publicKey)`
`private boolean`	`flowReconnect(java.lang.String password, int securityMechanism)`
`private void`	`flowSecurityCheckAndAccessRdb(int securityMechanism, java.lang.String user, java.lang.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(java.lang.String password)`
`private void`	`flowUSRIDONLconnect()`
`private void`	`flowUSRIDPWDconnect(java.lang.String password)`
`private void`	`flowUSRSSBPWDconnect(java.lang.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()`
`java.util.Properties`	`getClientInfo()`	`getClientInfo` always returns an empty `Properties` object since Derby doesn't support ClientInfoProperties.
`java.lang.String`	`getClientInfo(java.lang.String name)`	`getClientInfo` always returns a `null String` since Derby doesn't support ClientInfoProperties.
`int`	`getCMNTCPIP()`
`private java.lang.String`	`getDeferredResetPassword()`
`EncryptionManager`	`getEncryptionManager()`
`(package private) javax.transaction.xa.Xid[]`	`getIndoubtTransactionIds()`
`java.io.InputStream`	`getInputStream()`
`java.io.OutputStream`	`getOutputStream()`
`java.lang.String`	`getProductID()`
`int`	`getRDB()`
`int`	`getRSYNCMGR()`
`int`	`getSECMGR()`
`int`	`getSecurityMechanism()`
`int`	`getSQLAM()`
`int`	`getSYNCPTMGR()`
`byte[]`	`getTargetPublicKey()`
`int`	`getXAMGR()`
`private void`	`handleLoginTimeout(java.lang.Throwable original)`	Handle socket timeouts during connection attempts
`private void`	`initialize(java.lang.String password, BasicClientDataSource40 dataSource, boolean isXAConn)`
`private void`	`initializeClientSeed()`
`private void`	`initializePublicKeyForEncryption()`
`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(java.lang.Class<?> interfaces)`	Returns false unless `interfaces` is implemented
`private SqlException`	`mapSecchkcd(int secchkcd)`
`protected void`	`markClosed_()`
`protected Agent`	`newAgent_(LogWriter logWriter, int loginTimeout, java.lang.String serverName, int portNumber, int clientSSLMode)`
`protected ClientCallableStatement`	`newCallableStatement_(java.lang.String sql, int type, int concurrency, int holdability)`
`protected ClientDatabaseMetaData`	`newDatabaseMetaData_()`
`protected ClientPreparedStatement`	`newPositionedUpdatePreparedStatement_(java.lang.String sql, Section section)`
`protected ClientPreparedStatement`	`newPreparedStatement_(java.lang.String sql, int type, int concurrency, int holdability, int autoGeneratedKeys, java.lang.String[] columnNames, int[] columnIndexes)`
`SectionManager`	`newSectionManager(Agent agent)`
`protected ClientStatement`	`newStatement_(int type, int concurrency, int holdability)`
`private byte[]`	`passwordSubstituteForUSRSSBPWD(java.lang.String password)`
`(package private) void`	`rdbAccessed(int svrcod, java.lang.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, java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)`
`private void`	`resetNetConnection(LogWriter logWriter)`
`protected void`	`resetPreparedStatement_(ClientPreparedStatement ps, java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability, int autoGeneratedKeys, java.lang.String[] columnNames, int[] columnIndexes)`
`protected void`	`resetStatement_(ClientStatement statement, int type, int concurrency, int holdability)`
`(package private) void`	`securityCheckComplete(int svrcod, int secchkcd)`
`boolean`	`serverSupportLongRDBNAM()`
`protected boolean`	`serverSupportsEXTDTAAbort()`
`boolean`	`serverSupportsLayerBStreaming()`
`protected boolean`	`serverSupportsLocators()`	Checks whether the server supports locators for large objects.
`(package private) boolean`	`serverSupportsQryclsimp()`	Check whether the server has full support for the QRYCLSIMP parameter in OPNQRY.
`protected boolean`	`serverSupportsTimestampNanoseconds()`	Return true if the server supports nanoseconds in timestamps
`protected boolean`	`serverSupportsUDTs()`	Check whether the server supports UDTs
`protected 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(java.lang.String name, java.lang.String value)`	`setClientInfo` will always throw a `SQLClientInfoException` since Derby does not support any properties.
`void`	`setClientInfo(java.util.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(java.lang.String password)`
`void`	`setIndoubtTransactions(java.util.List<javax.transaction.xa.Xid> indoubtTransactions)`
`void`	`setInputStream(java.io.InputStream inputStream)`
`void`	`setOutputStream(java.io.OutputStream outputStream)`
`(package private) void`	`setServerAttributeData(java.lang.String srvclsnm, java.lang.String srvrlslv)`
`protected boolean`	`supportsSessionDataCaching()`	Check whether the server supports session data caching
`<T> T`	`unwrap(java.lang.Class<T> interfaces)`	Returns `this` if this class implements the interface
`boolean`	`willAutoCommitGenerateFlow()`
`private void`	`writeAllConnectCommandsChained(int securityMechanism, java.lang.String user, java.lang.String password)`
`void`	`writeCommitSubstitute_()`
`(package private) void`	`writeDeferredReset()`
`void`	`writeLocalCommit_()`
`void`	`writeLocalRollback_()`
`void`	`writeLocalXACommit_()`
`void`	`writeLocalXARollback_()`
`void`	`writeLocalXAStart_()`
`private void`	`writeSecurityCheckAndAccessRdb(int securityMechanism, java.lang.String user, java.lang.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 org.apache.derby.client.am.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 interface java.sql.Connection
beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

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 java.lang.String extnam_
```

targetSrvclsnm_
```
java.lang.String targetSrvclsnm_
```

targetSrvrlslv_
```
java.lang.String targetSrvrlslv_
```

publicKey_
```
private transient byte[] publicKey_
```

targetPublicKey_

private transient byte[] targetPublicKey_

sourceSeed_
```
private transient byte[] sourceSeed_
```

targetSeed_
```
private transient byte[] targetSeed_
```

prddta_
```
private java.nio.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 java.util.List<javax.transaction.xa.Xid> indoubtTransactions_

currXACallInfoOffset_
```
protected int currXACallInfoOffset_
```

isValidStmt
```
private java.sql.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 Detail
- NetConnection
```
NetConnection(LogWriter logWriter,
              int driverManagerLoginTimeout,
              java.lang.String serverName,
              int portNumber,
              java.lang.String databaseName,
              java.util.Properties properties)
       throws SqlException
```
  Throws:
  
  SqlException
- NetConnection
```
NetConnection(LogWriter logWriter,
              java.lang.String user,
              java.lang.String password,
              BasicClientDataSource40 dataSource,
              int rmId,
              boolean isXAConn)
       throws SqlException
```
  Throws:
  
  SqlException
- NetConnection
```
NetConnection(LogWriter logWriter,
              java.lang.String user,
              java.lang.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 Detail

setDeferredResetPassword

private void setDeferredResetPassword(java.lang.String password)

getDeferredResetPassword

private java.lang.String getDeferredResetPassword()

initialize

private void initialize(java.lang.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(java.lang.String password,
                         int securityMechanism)
                  throws SqlException

Throws:: SqlException

flowSimpleConnect

private void flowSimpleConnect()
                        throws SqlException

Throws:: SqlException

handleLoginTimeout

private void handleLoginTimeout(java.lang.Throwable original)
                         throws SqlException

Handle socket timeouts during connection attempts

Throws:: SqlException

flowReconnect

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

Throws:: SqlException

flowUSRIDPWDconnect

private void flowUSRIDPWDconnect(java.lang.String password)
                          throws SqlException

Throws:: SqlException

flowUSRIDONLconnect

private void flowUSRIDONLconnect()
                          throws SqlException

Throws:: SqlException

flowUSRENCPWDconnect

private void flowUSRENCPWDconnect(java.lang.String password)
                           throws SqlException

Throws:: SqlException

flowEUSRIDPWDconnect

private void flowEUSRIDPWDconnect(java.lang.String password)
                           throws SqlException

Throws:: SqlException

flowEUSRIDDTAconnect

private void flowEUSRIDDTAconnect()
                           throws SqlException

Throws:: SqlException

flowEUSRPWDDTAconnect

private void flowEUSRPWDDTAconnect(java.lang.String password)
                            throws SqlException

Throws:: SqlException

flowUSRSSBPWDconnect
```
private void flowUSRSSBPWDconnect(java.lang.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,
                                           java.lang.String user,
                                           java.lang.String password,
                                           byte[] encryptedUserid,
                                           byte[] encryptedPassword)
                                    throws SqlException

Throws:: SqlException

writeAllConnectCommandsChained

private void writeAllConnectCommandsChained(int securityMechanism,
                                            java.lang.String user,
                                            java.lang.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,
                                            java.lang.String user,
                                            java.lang.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(java.lang.String srvclsnm,
                            java.lang.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,
                 java.lang.String prdid,
                 boolean crrtknReceived,
                 byte[] crrtkn)

newAgent_

protected Agent newAgent_(LogWriter logWriter,
                          int loginTimeout,
                          java.lang.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_(java.lang.String sql,
                                                                        Section section)
                                                                 throws SqlException

Specified by:: newPositionedUpdatePreparedStatement_ in class ClientConnection
Throws:: SqlException

newPreparedStatement_

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

Specified by:: newPreparedStatement_ in class ClientConnection
Throws:: SqlException

resetPreparedStatement_

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

Specified by:: resetPreparedStatement_ in class ClientConnection
Throws:: SqlException

newCallableStatement_

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

Specified by:: newCallableStatement_ in class ClientConnection
Throws:: SqlException

resetCallableStatement_

protected void resetCallableStatement_(ClientCallableStatement cs,
                                       java.lang.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(java.lang.String user)
                      throws SqlException

Throws:: SqlException

checkPasswordLength

private void checkPasswordLength(java.lang.String password)
                          throws SqlException

Throws:: SqlException

checkUser

private void checkUser(java.lang.String user)
                throws SqlException

Throws:: SqlException

checkUserPassword

private void checkUserPassword(java.lang.String user,
                               java.lang.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(java.lang.String password)
                                      throws SqlException

Throws:: SqlException

encryptedUseridForEUSRIDPWD

private byte[] encryptedUseridForEUSRIDPWD()
                                    throws SqlException

Throws:: SqlException

encryptedPasswordForEUSRIDPWD

private byte[] encryptedPasswordForEUSRIDPWD(java.lang.String password)
                                      throws SqlException

Throws:: SqlException

passwordSubstituteForUSRSSBPWD

private byte[] passwordSubstituteForUSRSSBPWD(java.lang.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(java.io.InputStream inputStream)

setOutputStream

public void setOutputStream(java.io.OutputStream outputStream)

getInputStream

public java.io.InputStream getInputStream()

getOutputStream

public java.io.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(java.util.List<javax.transaction.xa.Xid> indoubtTransactions)

getIndoubtTransactionIds

javax.transaction.xa.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 java.lang.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 java.sql.Array createArrayOf(java.lang.String typeName,
                                    java.lang.Object[] elements)
                             throws java.sql.SQLException

Throws:: java.sql.SQLException

createNClob

public java.sql.NClob createNClob()
                           throws java.sql.SQLException

Throws:: java.sql.SQLException

createSQLXML

public java.sql.SQLXML createSQLXML()
                             throws java.sql.SQLException

Throws:: java.sql.SQLException

createStruct

public java.sql.Struct createStruct(java.lang.String typeName,
                                    java.lang.Object[] attributes)
                             throws java.sql.SQLException

Throws:: java.sql.SQLException

isValid
```
public boolean isValid(int timeout)
                throws java.sql.SQLException
```
Checks if the connection has not been closed and is still valid. The validity is checked by running a simple query against the database. 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:

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

close
```
public void close()
           throws java.sql.SQLException
```
Close the connection and release its resources.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.sql.Connection

Overrides:

close in class ClientConnection

Throws:

java.sql.SQLException - if a database-access error occurs.

setClientInfo
```
public void setClientInfo(java.lang.String name,
                          java.lang.String value)
                   throws java.sql.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:

java.sql.SQLClientInfoException - always.

setClientInfo
```
public void setClientInfo(java.util.Properties properties)
                   throws java.sql.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:

java.sql.SQLClientInfoException - unless the properties parameter is null or empty.

getClientInfo
```
public java.lang.String getClientInfo(java.lang.String name)
                               throws java.sql.SQLException
```
getClientInfo always returns a null String since Derby doesn't support ClientInfoProperties.

Parameters:

name - a String value

Returns:

a null String value

Throws:

java.sql.SQLException - if the connection is closed.

getClientInfo
```
public java.util.Properties getClientInfo()
                                   throws java.sql.SQLException
```
getClientInfo always returns an empty Properties object since Derby doesn't support ClientInfoProperties.

Returns:

an empty Properties object.

Throws:

java.sql.SQLException - if the connection is closed.

isWrapperFor
```
public boolean isWrapperFor(java.lang.Class<?> interfaces)
                     throws java.sql.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:

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

unwrap
```
public <T> T unwrap(java.lang.Class<T> interfaces)
             throws java.sql.SQLException
```
Returns this if this class implements the interface

Parameters:

interfaces - a Class defining an interface

Returns:

an object that implements the interface

Throws:

java.sql.SQLException - if no object if found that implements the interface

Class NetConnection

Field Summary

Fields inherited from class org.apache.derby.client.am.ClientConnection

Fields inherited from interface java.sql.Connection

Constructor Summary

Method Summary

Methods inherited from class org.apache.derby.client.am.ClientConnection

Methods inherited from interface java.sql.Connection

Methods inherited from class java.lang.Object

Field Detail

msgutil

netAgent_

pooledConnection_

closeStatementsOnClose

targetAgent_

targetCmntcpip_

targetRdb_

targetSecmgr_

targetCmnappc_

targetXamgr_

targetSyncptmgr_

targetRsyncmgr_

targetUnicodemgr_

extnam_

targetSrvclsnm_

targetSrvrlslv_

publicKey_

targetPublicKey_

sourceSeed_

targetSeed_

prddta_

crrtkn_

targetSecmec_

securityMechanism_

deferredResetPassword_

connectionNull

xares_

indoubtTransactions_

currXACallInfoOffset_

isValidStmt

Constructor Detail

NetConnection

NetConnection

NetConnection

Method Detail

setDeferredResetPassword

getDeferredResetPassword

initialize

resetNetConnection

reset_

completeReset

flowConnect

flowSimpleConnect

handleLoginTimeout

flowReconnect

flowUSRIDPWDconnect

flowUSRIDONLconnect

flowUSRENCPWDconnect

flowEUSRIDPWDconnect

flowEUSRIDDTAconnect

flowEUSRPWDDTAconnect

flowUSRSSBPWDconnect

flowServerAttributes

flowKeyExchange

flowSeedExchange

flowServerAttributesAndKeyExchange

flowSecurityCheckAndAccessRdb

writeAllConnectCommandsChained

readAllConnectCommandsChained

writeServerAttributesAndKeyExchange

readServerAttributesAndKeyExchange

writeSecurityCheckAndAccessRdb

readSecurityCheckAndAccessRdb

writeDeferredReset

readDeferredReset

setServerAttributeData

setAccessSecurityData

securityCheckComplete

rdbAccessed

newAgent_