|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.derby.client.am.Connection
org.apache.derby.client.net.NetConnection
public class NetConnection
Field Summary | |
---|---|
private boolean |
closeStatementsOnClose
|
protected byte[] |
cnntkn_
|
private boolean |
connectionNull
|
byte[] |
crrtkn_
|
protected int |
currXACallInfoOffset_
|
private char[] |
deferredResetPassword_
|
(package private) java.lang.String |
extnam_
|
protected java.util.Hashtable |
indoubtTransactions_
|
protected static MessageUtil |
msgutil
|
protected NetAgent |
netAgent_
|
protected int |
pendingEndXACallinfoOffset_
|
private ClientPooledConnection |
pooledConnection_
|
(package private) byte[] |
prddta_
|
(package private) byte[] |
publicKey_
|
protected boolean |
readOnlyTransaction_
|
private int |
rmId_
|
protected int |
securityMechanism_
|
private short |
seqNo_
|
(package private) byte[] |
sourceSeed_
|
protected int |
targetAgent_
|
protected int |
targetCmnappc_
|
protected int |
targetCmntcpip_
|
(package private) java.lang.String |
targetExtnam_
|
(package private) byte[] |
targetPublicKey_
|
protected int |
targetRdb_
|
protected int |
targetRsyncmgr_
|
(package private) int |
targetSecmec_
|
int |
targetSecmgr_
|
(package private) byte[] |
targetSeed_
|
java.lang.String |
targetSrvclsnm_
|
protected java.lang.String |
targetSrvnam_
|
java.lang.String |
targetSrvrlslv_
|
protected int |
targetSyncptmgr_
|
protected int |
targetXamgr_
|
protected NetXAResource |
xares_
|
Fields inherited from class org.apache.derby.client.am.Connection |
---|
agent_, autoCommit_, clientSSLMode_, commBufferSize_, databaseMetaData_, databaseName_, dataSource_, dncGeneratedSavepointId_, dncGeneratedSavepointNamePrefix__, encryptionManager_, inUnitOfWork_, isXAConnection_, jdbcReadOnly_, loginTimeout_, open_, portNumber_, productID_, resetConnectionAtFirstSql_, retrieveMessageText_, 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 | |
---|---|
NetConnection(NetLogWriter netLogWriter,
ClientBaseDataSource dataSource,
java.lang.String user,
java.lang.String password)
|
|
NetConnection(NetLogWriter netLogWriter,
int driverManagerLoginTimeout,
java.lang.String serverName,
int portNumber,
java.lang.String databaseName,
java.util.Properties properties)
|
|
NetConnection(NetLogWriter netLogWriter,
java.lang.String ipaddr,
int portNumber,
ClientBaseDataSource dataSource,
boolean isXAConn)
|
|
NetConnection(NetLogWriter netLogWriter,
java.lang.String databaseName,
java.util.Properties properties)
|
|
NetConnection(NetLogWriter netLogWriter,
java.lang.String user,
java.lang.String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn)
|
|
NetConnection(NetLogWriter netLogWriter,
java.lang.String user,
java.lang.String password,
ClientBaseDataSource 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 inturn raise the statement events to the ClientPooledConnection object |
Method Summary | |
---|---|
void |
addSpecialRegisters(java.lang.String s)
|
protected boolean |
allowCloseInUOW_()
Check if the connection can be closed when there are uncommitted operations. |
protected boolean |
allowLocalCommitRollback_()
|
protected int |
checkAlternateServerHasEqualOrHigherProductLevel(ProductLevel orgLvl,
int orgServerType)
|
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()
closes underlying connection and associated resource. |
void |
closeForReuse()
Invalidates connection but keeps socket open. |
void |
closeResources()
closes resources connection will be not available for reuse. |
void |
closeX()
closes underlying connection and associated resource. |
void |
completeConnect()
|
protected void |
completeReset(boolean isDeferredReset)
|
protected void |
constructCrrtkn()
|
private void |
constructExtnam()
|
private void |
constructPrddta()
|
protected boolean |
doCloseStatementsOnClose_()
|
void |
doResetNow()
|
private byte[] |
encryptedPasswordForEUSRIDPWD(java.lang.String password)
|
private byte[] |
encryptedPasswordForUSRENCPWD(java.lang.String password)
|
private byte[] |
encryptedUseridForEUSRIDPWD()
|
protected void |
finalize()
|
private char[] |
flipBits(char[] array)
|
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)
|
protected 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 |
flowServerAttributesAndSeedExchange(int securityMechanism,
byte[] sourceSeed)
|
protected 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()
|
int |
getCMNTCPIP()
|
protected byte[] |
getCnnToken()
|
private java.lang.String |
getDeferredResetPassword()
|
EncryptionManager |
getEncryptionManager()
|
java.io.InputStream |
getInputStream()
|
java.io.OutputStream |
getOutputStream()
|
java.lang.String |
getProductID()
|
int |
getRDB()
|
int |
getRSYNCMGR()
|
int |
getSECMGR()
|
int |
getSecurityMechanism()
|
protected short |
getSequenceNumber()
|
protected int |
getSocketAndInputOutputStreams(java.lang.String server,
int port,
int clientSSLMode)
|
(package private) java.util.List |
getSpecialRegisters()
|
int |
getSQLAM()
|
int |
getSYNCPTMGR()
|
byte[] |
getTargetPublicKey()
|
int |
getXAMGR()
|
private void |
initialize(java.lang.String password,
ClientBaseDataSource dataSource,
int rmId,
boolean isXAConn)
|
private void |
initializeClientSeed()
|
private void |
initializePublicKeyForEncryption()
|
boolean |
isConnectionNull()
|
protected boolean |
isGlobalPending_()
|
boolean |
isOpen()
Returns if a transaction is in process |
private SqlException |
mapSecchkcd(int secchkcd)
|
protected void |
markClosed_()
|
protected Agent |
newAgent_(LogWriter logWriter,
int loginTimeout,
java.lang.String serverName,
int portNumber,
int clientSSLMode)
|
protected CallableStatement |
newCallableStatement_(java.lang.String sql,
int type,
int concurrency,
int holdability)
|
protected DatabaseMetaData |
newDatabaseMetaData_()
|
protected PreparedStatement |
newPositionedUpdatePreparedStatement_(java.lang.String sql,
Section section)
|
protected PreparedStatement |
newPreparedStatement_(java.lang.String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
java.lang.String[] columnNames,
int[] columnIndexes)
|
SectionManager |
newSectionManager(java.lang.String collection,
Agent agent,
java.lang.String databaseName)
|
protected Statement |
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)
|
private void |
readServerAttributesAndSeedExchange()
|
void |
readTransactionStart()
|
protected void |
readXACommit_()
Invokes readCommit on NetXAConnection |
protected void |
readXARollback_()
Invokes writeRollback on NetXAConnection |
protected void |
reset_(LogWriter logWriter)
|
protected void |
resetCallableStatement_(CallableStatement cs,
java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
void |
resetNetConnection(LogWriter logWriter)
|
protected void |
resetPreparedStatement_(PreparedStatement ps,
java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability,
int autoGeneratedKeys,
java.lang.String[] columnNames,
int[] columnIndexes)
|
protected void |
resetStatement_(Statement statement,
int type,
int concurrency,
int holdability)
|
(package private) void |
securityCheckComplete(int svrcod,
int secchkcd)
|
protected boolean |
serverSupportsEXTDTAAbort()
|
boolean |
serverSupportsLayerBStreaming()
|
protected boolean |
serverSupportsLocators()
Checks whether the server supports locators for large objects. |
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 |
(package private) void |
setAccessSecurityData(int secchkcd,
int desiredSecmec,
int[] secmecList,
boolean sectknReceived,
byte[] sectkn)
|
void |
setConnectionNull(boolean connectionNull)
|
private void |
setDeferredResetPassword(java.lang.String password)
|
void |
setIndoubtTransactions(java.util.Hashtable indoubtTransactions)
|
void |
setInputStream(java.io.InputStream inputStream)
|
void |
setOutputStream(java.io.OutputStream outputStream)
|
protected void |
setReadOnlyTransactionFlag(boolean flag)
|
(package private) void |
setServerAttributeData(java.lang.String extnam,
java.lang.String srvclsnm,
java.lang.String srvnam,
java.lang.String srvrlslv)
|
protected boolean |
supportsSessionDataCaching()
Check whether the server supports session data caching |
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)
|
private void |
writeServerAttributesAndSeedExchange(byte[] sourceSeed)
|
void |
writeTransactionStart(Statement statement)
|
protected void |
writeXACommit_()
Invokes write commit on NetXAConnection |
protected void |
writeXARollback_()
Invokes writeRollback on NetXAConnection |
protected void |
writeXATransactionStart(Statement statement)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface java.sql.Connection |
---|
createArrayOf, createNClob, createSQLXML, createStruct, getClientInfo, getClientInfo, isValid, setClientInfo, setClientInfo |
Methods inherited from interface java.sql.Wrapper |
---|
isWrapperFor, unwrap |
Field Detail |
---|
protected static MessageUtil msgutil
protected NetAgent netAgent_
private final ClientPooledConnection pooledConnection_
private final boolean closeStatementsOnClose
protected int pendingEndXACallinfoOffset_
protected int targetAgent_
protected int targetCmntcpip_
protected int targetRdb_
public int targetSecmgr_
protected int targetCmnappc_
protected int targetXamgr_
protected int targetSyncptmgr_
protected int targetRsyncmgr_
java.lang.String targetExtnam_
java.lang.String extnam_
public java.lang.String targetSrvclsnm_
protected java.lang.String targetSrvnam_
public java.lang.String targetSrvrlslv_
transient byte[] publicKey_
transient byte[] targetPublicKey_
transient byte[] sourceSeed_
transient byte[] targetSeed_
byte[] prddta_
public byte[] crrtkn_
int targetSecmec_
protected int securityMechanism_
private transient char[] deferredResetPassword_
private boolean connectionNull
protected byte[] cnntkn_
private int rmId_
protected NetXAResource xares_
protected java.util.Hashtable indoubtTransactions_
protected int currXACallInfoOffset_
private short seqNo_
protected boolean readOnlyTransaction_
Constructor Detail |
---|
public NetConnection(NetLogWriter netLogWriter, java.lang.String databaseName, java.util.Properties properties) throws SqlException
SqlException
public NetConnection(NetLogWriter netLogWriter, ClientBaseDataSource dataSource, java.lang.String user, java.lang.String password) throws SqlException
SqlException
public NetConnection(NetLogWriter netLogWriter, int driverManagerLoginTimeout, java.lang.String serverName, int portNumber, java.lang.String databaseName, java.util.Properties properties) throws SqlException
SqlException
public NetConnection(NetLogWriter netLogWriter, java.lang.String user, java.lang.String password, ClientBaseDataSource dataSource, int rmId, boolean isXAConn) throws SqlException
SqlException
public NetConnection(NetLogWriter netLogWriter, java.lang.String ipaddr, int portNumber, ClientBaseDataSource dataSource, boolean isXAConn) throws SqlException
SqlException
public NetConnection(NetLogWriter netLogWriter, java.lang.String user, java.lang.String password, ClientBaseDataSource dataSource, int rmId, boolean isXAConn, ClientPooledConnection cpc) throws SqlException
this
on to the associated
prepared statement object thus enabling the prepared statement object
to inturn raise the statement events to the ClientPooledConnection object
netLogWriter
- NetLogWriter object associated with this connectionuser
- user id for this connectionpassword
- password for this connectiondataSource
- The DataSource object passed from the PooledConnection
object from which this constructor was calledrmId
- The Resource manager ID for XA ConnectionsisXAConn
- true if this is a XA connectioncpc
- The ClientPooledConnection object from which this
NetConnection constructor was called. This is used
to pass StatementEvents back to the pooledConnection
object
SqlException
Method Detail |
---|
private void setDeferredResetPassword(java.lang.String password)
private java.lang.String getDeferredResetPassword()
private void initialize(java.lang.String password, ClientBaseDataSource dataSource, int rmId, boolean isXAConn) throws SqlException
SqlException
public void resetNetConnection(LogWriter logWriter) throws SqlException
SqlException
protected void reset_(LogWriter logWriter) throws SqlException
reset_
in class Connection
SqlException
java.util.List getSpecialRegisters()
public void addSpecialRegisters(java.lang.String s)
addSpecialRegisters
in class Connection
public void completeConnect() throws SqlException
completeConnect
in class Connection
SqlException
protected void completeReset(boolean isDeferredReset) throws SqlException
SqlException
public void flowConnect(java.lang.String password, int securityMechanism) throws SqlException
SqlException
protected void flowSimpleConnect() throws SqlException
SqlException
protected boolean flowReconnect(java.lang.String password, int securityMechanism) throws SqlException
SqlException
protected void finalize() throws java.lang.Throwable
finalize
in class Connection
java.lang.Throwable
protected byte[] getCnnToken()
protected short getSequenceNumber()
private void flowUSRIDPWDconnect(java.lang.String password) throws SqlException
SqlException
private void flowUSRIDONLconnect() throws SqlException
SqlException
private void flowUSRENCPWDconnect(java.lang.String password) throws SqlException
SqlException
private void flowEUSRIDPWDconnect(java.lang.String password) throws SqlException
SqlException
private void flowEUSRIDDTAconnect() throws SqlException
SqlException
private void flowEUSRPWDDTAconnect(java.lang.String password) throws SqlException
SqlException
private void flowUSRSSBPWDconnect(java.lang.String password) throws SqlException
SqlException
private void flowServerAttributes() throws SqlException
SqlException
private void flowKeyExchange(int securityMechanism, byte[] publicKey) throws SqlException
SqlException
private void flowSeedExchange(int securityMechanism, byte[] sourceSeed) throws SqlException
SqlException
private void flowServerAttributesAndKeyExchange(int securityMechanism, byte[] publicKey) throws SqlException
SqlException
private void flowServerAttributesAndSeedExchange(int securityMechanism, byte[] sourceSeed) throws SqlException
SqlException
private void flowSecurityCheckAndAccessRdb(int securityMechanism, java.lang.String user, java.lang.String password, byte[] encryptedUserid, byte[] encryptedPassword) throws SqlException
SqlException
private void writeAllConnectCommandsChained(int securityMechanism, java.lang.String user, java.lang.String password) throws SqlException
SqlException
private void readAllConnectCommandsChained(int securityMechanism) throws SqlException
SqlException
private void writeServerAttributesAndKeyExchange(int securityMechanism, byte[] publicKey) throws SqlException
SqlException
private void writeServerAttributesAndSeedExchange(byte[] sourceSeed) throws SqlException
SqlException
private void readServerAttributesAndKeyExchange(int securityMechanism) throws SqlException
SqlException
private void readServerAttributesAndSeedExchange() throws SqlException
SqlException
private void writeSecurityCheckAndAccessRdb(int securityMechanism, java.lang.String user, java.lang.String password, byte[] encryptedUserid, byte[] encryptedPassword) throws SqlException
SqlException
private void readSecurityCheckAndAccessRdb() throws SqlException
SqlException
void writeDeferredReset() throws SqlException
SqlException
void readDeferredReset() throws SqlException
SqlException
void setServerAttributeData(java.lang.String extnam, java.lang.String srvclsnm, java.lang.String srvnam, java.lang.String srvrlslv)
void setAccessSecurityData(int secchkcd, int desiredSecmec, int[] secmecList, boolean sectknReceived, byte[] sectkn) throws DisconnectException
DisconnectException
void securityCheckComplete(int svrcod, int secchkcd)
void rdbAccessed(int svrcod, java.lang.String prdid, boolean crrtknReceived, byte[] crrtkn)
protected Agent newAgent_(LogWriter logWriter, int loginTimeout, java.lang.String serverName, int portNumber, int clientSSLMode) throws SqlException
newAgent_
in class Connection
SqlException
protected Statement newStatement_(int type, int concurrency, int holdability) throws SqlException
newStatement_
in class Connection
SqlException
protected void resetStatement_(Statement statement, int type, int concurrency, int holdability) throws SqlException
resetStatement_
in class Connection
SqlException
protected PreparedStatement newPositionedUpdatePreparedStatement_(java.lang.String sql, Section section) throws SqlException
newPositionedUpdatePreparedStatement_
in class Connection
SqlException
protected PreparedStatement newPreparedStatement_(java.lang.String sql, int type, int concurrency, int holdability, int autoGeneratedKeys, java.lang.String[] columnNames, int[] columnIndexes) throws SqlException
newPreparedStatement_
in class Connection
SqlException
protected void resetPreparedStatement_(PreparedStatement ps, java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability, int autoGeneratedKeys, java.lang.String[] columnNames, int[] columnIndexes) throws SqlException
resetPreparedStatement_
in class Connection
SqlException
protected CallableStatement newCallableStatement_(java.lang.String sql, int type, int concurrency, int holdability) throws SqlException
newCallableStatement_
in class Connection
SqlException
protected void resetCallableStatement_(CallableStatement cs, java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SqlException
resetCallableStatement_
in class Connection
SqlException
protected DatabaseMetaData newDatabaseMetaData_()
newDatabaseMetaData_
in class Connection
private void checkDatabaseName() throws SqlException
SqlException
private void checkUserLength(java.lang.String user) throws SqlException
SqlException
private void checkPasswordLength(java.lang.String password) throws SqlException
SqlException
private void checkUser(java.lang.String user) throws SqlException
SqlException
private void checkUserPassword(java.lang.String user, java.lang.String password) throws SqlException
SqlException
private void checkSecmgrForSecmecSupport(int securityMechanism) throws SqlException
SqlException
private SqlException mapSecchkcd(int secchkcd)
protected void constructCrrtkn() throws SqlException
SqlException
private void constructExtnam() throws SqlException
SqlException
private void constructPrddta() throws SqlException
SqlException
private void initializePublicKeyForEncryption() throws SqlException
SqlException
private void initializeClientSeed() throws SqlException
SqlException
private byte[] encryptedPasswordForUSRENCPWD(java.lang.String password) throws SqlException
SqlException
private byte[] encryptedUseridForEUSRIDPWD() throws SqlException
SqlException
private byte[] encryptedPasswordForEUSRIDPWD(java.lang.String password) throws SqlException
SqlException
private byte[] passwordSubstituteForUSRSSBPWD(java.lang.String password) throws SqlException
SqlException
public int getSQLAM()
public int getAGENT()
public int getCMNTCPIP()
public int getRDB()
public int getSECMGR()
public int getXAMGR()
public int getSYNCPTMGR()
public int getRSYNCMGR()
private char[] flipBits(char[] array)
public void writeCommitSubstitute_() throws SqlException
writeCommitSubstitute_
in class Connection
SqlException
public void readCommitSubstitute_() throws SqlException
readCommitSubstitute_
in class Connection
SqlException
public void writeLocalXAStart_() throws SqlException
writeLocalXAStart_
in class Connection
SqlException
public void readLocalXAStart_() throws SqlException
readLocalXAStart_
in class Connection
SqlException
public void writeLocalXACommit_() throws SqlException
writeLocalXACommit_
in class Connection
SqlException
public void readLocalXACommit_() throws SqlException
readLocalXACommit_
in class Connection
SqlException
public void writeLocalXARollback_() throws SqlException
writeLocalXARollback_
in class Connection
SqlException
public void readLocalXARollback_() throws SqlException
readLocalXARollback_
in class Connection
SqlException
public void writeLocalCommit_() throws SqlException
writeLocalCommit_
in class Connection
SqlException
public void readLocalCommit_() throws SqlException
readLocalCommit_
in class Connection
SqlException
public void writeLocalRollback_() throws SqlException
writeLocalRollback_
in class Connection
SqlException
public void readLocalRollback_() throws SqlException
readLocalRollback_
in class Connection
SqlException
protected void markClosed_()
markClosed_
in class Connection
protected boolean isGlobalPending_()
isGlobalPending_
in class Connection
protected boolean doCloseStatementsOnClose_()
doCloseStatementsOnClose_
in class Connection
protected boolean allowCloseInUOW_()
allowCloseInUOW_
in class Connection
true
; otherwise, false
protected boolean allowLocalCommitRollback_()
allowLocalCommitRollback_
in class Connection
public void setInputStream(java.io.InputStream inputStream)
public void setOutputStream(java.io.OutputStream outputStream)
public java.io.InputStream getInputStream()
public java.io.OutputStream getOutputStream()
public void writeTransactionStart(Statement statement) throws SqlException
writeTransactionStart
in class Connection
SqlException
public void readTransactionStart() throws SqlException
readTransactionStart
in class Connection
SqlException
public void setIndoubtTransactions(java.util.Hashtable indoubtTransactions)
protected void setReadOnlyTransactionFlag(boolean flag)
public SectionManager newSectionManager(java.lang.String collection, Agent agent, java.lang.String databaseName)
newSectionManager
in class Connection
protected int getSocketAndInputOutputStreams(java.lang.String server, int port, int clientSSLMode)
protected int checkAlternateServerHasEqualOrHigherProductLevel(ProductLevel orgLvl, int orgServerType)
public boolean willAutoCommitGenerateFlow()
willAutoCommitGenerateFlow
in class Connection
public int getSecurityMechanism()
public EncryptionManager getEncryptionManager()
public byte[] getTargetPublicKey()
public java.lang.String getProductID()
public void doResetNow() throws SqlException
SqlException
public boolean isConnectionNull()
public void setConnectionNull(boolean connectionNull)
connectionNull
- The connectionNull to set.public final boolean serverSupportsQryclsimp()
public final boolean serverSupportsLayerBStreaming()
protected final boolean supportsSessionDataCaching()
supportsSessionDataCaching
in class Connection
protected final boolean serverSupportsUDTs()
protected final boolean serverSupportsEXTDTAAbort()
protected final boolean serverSupportsLocators()
serverSupportsLocators
in class Connection
true
if LOB locators are supported.protected final boolean serverSupportsTimestampNanoseconds()
serverSupportsTimestampNanoseconds
in class Connection
public boolean isOpen()
public void close() throws java.sql.SQLException
close
in interface java.sql.Connection
close
in class Connection
java.sql.SQLException
public void closeX() throws java.sql.SQLException
closeX
in class Connection
java.sql.SQLException
public void closeForReuse() throws SqlException
SqlException
public void closeResources() throws java.sql.SQLException
closeResources
in class Connection
java.sql.SQLException
protected void writeXACommit_() throws SqlException
writeXACommit_
in class Connection
SqlException
protected void readXACommit_() throws SqlException
readXACommit_
in class Connection
SqlException
protected void writeXARollback_() throws SqlException
writeXARollback_
in class Connection
SqlException
protected void readXARollback_() throws SqlException
readXARollback_
in class Connection
SqlException
protected void writeXATransactionStart(Statement statement) throws SqlException
writeXATransactionStart
in class Connection
SqlException
|
Built on Thu 2010-12-23 20:49:13+0000, from revision ??? | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |