| java.lang.Object org.apache.derby.client.am.Connection org.apache.derby.client.net.NetConnection
All known Subclasses: org.apache.derby.client.net.NetConnection40,
Constructor Summary | |
public | NetConnection(NetLogWriter netLogWriter, String databaseName, java.util.Properties properties) | public | NetConnection(NetLogWriter netLogWriter, org.apache.derby.jdbc.ClientBaseDataSource dataSource, String user, String password) | public | NetConnection(NetLogWriter netLogWriter, int driverManagerLoginTimeout, String serverName, int portNumber, String databaseName, java.util.Properties properties) | public | NetConnection(NetLogWriter netLogWriter, String user, String password, org.apache.derby.jdbc.ClientBaseDataSource dataSource, int rmId, boolean isXAConn) | public | NetConnection(NetLogWriter netLogWriter, String ipaddr, int portNumber, org.apache.derby.jdbc.ClientBaseDataSource dataSource, boolean isXAConn) | public | NetConnection(NetLogWriter netLogWriter, String user, String password, org.apache.derby.jdbc.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
Parameters: netLogWriter - NetLogWriter object associated with this connection Parameters: user - user id for this connection Parameters: password - password for this connection Parameters: dataSource - The DataSource object passed from the PooledConnection object from which this constructor was called Parameters: rmId - The Resource manager ID for XA Connections Parameters: isXAConn - true if this is a XA connection Parameters: cpc - The ClientPooledConnection object from which this NetConnection constructor was called. |
Method Summary | |
public void | addSpecialRegisters(String s) | protected boolean | allowCloseInUOW_() | protected boolean | allowLocalCommitRollback_() | protected int | checkAlternateServerHasEqualOrHigherProductLevel(ProductLevel orgLvl, int orgServerType) | protected void | checkResetPreconditions(org.apache.derby.client.am.LogWriter logWriter, String user, String password, ClientBaseDataSource ds) | public synchronized void | close() closes underlying connection and associated resource. | public synchronized void | closeForReuse() Invalidates connection but keeps socket open. | public synchronized void | closeResources() closes resources connection will be not available
for reuse. | public synchronized void | closeX() closes underlying connection and associated resource. | public void | completeConnect() | protected void | completeReset(boolean isDeferredReset, boolean recomputeFromDataSource) | protected void | constructCrrtkn() | protected boolean | doCloseStatementsOnClose_() | public void | doResetNow() | protected void | finalize() | public void | flowConnect(String password, int securityMechanism) | protected boolean | flowReconnect(String password, int securityMechanism) | protected void | flowSimpleConnect() | public int | getAGENT() | public int | getCMNTCPIP() | protected byte[] | getCnnToken() | public EncryptionManager | getEncryptionManager() | public java.io.InputStream | getInputStream() | public java.io.OutputStream | getOutputStream() | public String | getProductID() | public int | getRDB() | public int | getRSYNCMGR() | public int | getSECMGR() | public int | getSQLAM() | public int | getSYNCPTMGR() | public int | getSecurityMechanism() | protected short | getSequenceNumber() | protected int | getSocketAndInputOutputStreams(String server, int port) | java.util.List | getSpecialRegisters() | public byte[] | getTargetPublicKey() | public int | getXAMGR() | public boolean | isConnectionNull() | protected boolean | isGlobalPending_() | public boolean | isOpen() | protected void | markClosed_() | protected org.apache.derby.client.am.Agent | newAgent_(org.apache.derby.client.am.LogWriter logWriter, int loginTimeout, String serverName, int portNumber) | protected CallableStatement | newCallableStatement_(String sql, int type, int concurrency, int holdability) | protected DatabaseMetaData | newDatabaseMetaData_() | protected PreparedStatement | newPositionedUpdatePreparedStatement_(String sql, org.apache.derby.client.am.Section section) | protected PreparedStatement | newPreparedStatement_(String sql, int type, int concurrency, int holdability, int autoGeneratedKeys, String[] columnNames) | public org.apache.derby.client.am.SectionManager | newSectionManager(String collection, org.apache.derby.client.am.Agent agent, String databaseName) | protected Statement | newStatement_(int type, int concurrency, int holdability) | void | rdbAccessed(int svrcod, String prdid, boolean crrtknReceived, byte[] crrtkn) | public void | readCommitSubstitute_() | void | readDeferredReset() | public void | readLocalCommit_() | public void | readLocalRollback_() | public void | readLocalXACommit_() | public void | readLocalXARollback_() | public void | readLocalXAStart_() | public void | readTransactionStart() | protected void | readXACommit_() | protected void | readXARollback_() | protected void | resetCallableStatement_(CallableStatement cs, String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) | public void | resetNetConnection(org.apache.derby.client.am.LogWriter logWriter, String user, String password, org.apache.derby.jdbc.ClientBaseDataSource ds, boolean recomputeFromDataSource) | protected void | resetPreparedStatement_(PreparedStatement ps, String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability, int autoGeneratedKeys, String[] columnNames) | protected void | resetStatement_(Statement statement, int type, int concurrency, int holdability) | protected void | reset_(org.apache.derby.client.am.LogWriter logWriter, String user, String password, ClientBaseDataSource ds, boolean recomputeFromDataSource) | protected void | reset_(org.apache.derby.client.am.LogWriter logWriter, ClientBaseDataSource ds, boolean recomputeFromDataSource) | void | securityCheckComplete(int svrcod, int secchkcd) | final public boolean | serverSupportsQryclsimp() Check whether the server has full support for the QRYCLSIMP
parameter in OPNQRY. | void | setAccessSecurityData(int secchkcd, int desiredSecmec, int[] secmecList, boolean sectknReceived, byte[] sectkn) | public void | setConnectionNull(boolean connectionNull) | public void | setIndoubtTransactions(java.util.Hashtable indoubtTransactions) | public void | setInputStream(java.io.InputStream inputStream) | public void | setOutputStream(java.io.OutputStream outputStream) | protected void | setReadOnlyTransactionFlag(boolean flag) | void | setServerAttributeData(String extnam, String srvclsnm, String srvnam, String srvrlslv) | public boolean | willAutoCommitGenerateFlow() | public void | writeCommitSubstitute_() | void | writeDeferredReset() | public void | writeLocalCommit_() | public void | writeLocalRollback_() | public void | writeLocalXACommit_() | public void | writeLocalXARollback_() | public void | writeLocalXAStart_() | public void | writeTransactionStart(Statement statement) | protected void | writeXACommit_() | protected void | writeXARollback_() | protected void | writeXATransactionStart(Statement statement) |
cachedConnectBytes_ | protected byte[] cachedConnectBytes_(Code) | | |
cnntkn_ | protected byte[] cnntkn_(Code) | | |
crrtkn_ | public byte[] crrtkn_(Code) | | |
currXACallInfoOffset_ | protected int currXACallInfoOffset_(Code) | | |
pendingEndXACallinfoOffset_ | protected int pendingEndXACallinfoOffset_(Code) | | |
publicKey_ | transient byte[] publicKey_(Code) | | |
readOnlyTransaction_ | protected boolean readOnlyTransaction_(Code) | | |
securityMechanism_ | protected int securityMechanism_(Code) | | |
sourceSeed_ | transient byte[] sourceSeed_(Code) | | |
targetAgent_ | protected int targetAgent_(Code) | | |
targetCmnappc_ | protected int targetCmnappc_(Code) | | |
targetCmntcpip_ | protected int targetCmntcpip_(Code) | | |
targetPublicKey_ | transient byte[] targetPublicKey_(Code) | | |
targetRdb_ | protected int targetRdb_(Code) | | |
targetRsyncmgr_ | protected int targetRsyncmgr_(Code) | | |
targetSecmec_ | int targetSecmec_(Code) | | |
targetSecmgr_ | public int targetSecmgr_(Code) | | |
targetSeed_ | transient byte[] targetSeed_(Code) | | |
targetSyncptmgr_ | protected int targetSyncptmgr_(Code) | | |
targetXamgr_ | protected int targetXamgr_(Code) | | |
wroteConnectFromCache_ | protected boolean wroteConnectFromCache_(Code) | | |
NetConnection | public NetConnection(NetLogWriter netLogWriter, String user, String password, org.apache.derby.jdbc.ClientBaseDataSource dataSource, int rmId, boolean isXAConn, ClientPooledConnection cpc) throws SqlException(Code) | | 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
Parameters: netLogWriter - NetLogWriter object associated with this connection Parameters: user - user id for this connection Parameters: password - password for this connection Parameters: dataSource - The DataSource object passed from the PooledConnection object from which this constructor was called Parameters: rmId - The Resource manager ID for XA Connections Parameters: isXAConn - true if this is a XA connection Parameters: cpc - The ClientPooledConnection object from which this NetConnection constructor was called. This is usedto pass StatementEvents back to the pooledConnectionobject throws: SqlException - |
addSpecialRegisters | public void addSpecialRegisters(String s)(Code) | | |
allowCloseInUOW_ | protected boolean allowCloseInUOW_()(Code) | | |
checkAlternateServerHasEqualOrHigherProductLevel | protected int checkAlternateServerHasEqualOrHigherProductLevel(ProductLevel orgLvl, int orgServerType)(Code) | | |
close | public synchronized void close() throws SQLException(Code) | | closes underlying connection and associated resource.
|
closeForReuse | public synchronized void closeForReuse() throws SqlException(Code) | | Invalidates connection but keeps socket open.
|
closeResources | public synchronized void closeResources() throws SQLException(Code) | | closes resources connection will be not available
for reuse.
|
closeX | public synchronized void closeX() throws SQLException(Code) | | closes underlying connection and associated resource.
|
completeReset | protected void completeReset(boolean isDeferredReset, boolean recomputeFromDataSource) throws SqlException(Code) | | |
doCloseStatementsOnClose_ | protected boolean doCloseStatementsOnClose_()(Code) | | |
getAGENT | public int getAGENT()(Code) | | |
getCMNTCPIP | public int getCMNTCPIP()(Code) | | |
getCnnToken | protected byte[] getCnnToken()(Code) | | |
getRDB | public int getRDB()(Code) | | |
getRSYNCMGR | public int getRSYNCMGR()(Code) | | |
getSECMGR | public int getSECMGR()(Code) | | |
getSQLAM | public int getSQLAM()(Code) | | |
getSYNCPTMGR | public int getSYNCPTMGR()(Code) | | |
getSecurityMechanism | public int getSecurityMechanism()(Code) | | |
getSequenceNumber | protected short getSequenceNumber()(Code) | | |
getSocketAndInputOutputStreams | protected int getSocketAndInputOutputStreams(String server, int port)(Code) | | |
getTargetPublicKey | public byte[] getTargetPublicKey()(Code) | | |
getXAMGR | public int getXAMGR()(Code) | | |
isConnectionNull | public boolean isConnectionNull()(Code) | | Returns the connectionNull. |
isGlobalPending_ | protected boolean isGlobalPending_()(Code) | | |
isOpen | public boolean isOpen()(Code) | | Returns if a transaction is in process
open |
markClosed_ | protected void markClosed_()(Code) | | |
rdbAccessed | void rdbAccessed(int svrcod, String prdid, boolean crrtknReceived, byte[] crrtkn)(Code) | | |
readXACommit_ | protected void readXACommit_() throws SqlException(Code) | | Invokes readCommit on NetXAConnection
|
readXARollback_ | protected void readXARollback_() throws SqlException(Code) | | Invokes writeRollback on NetXAConnection
|
resetPreparedStatement_ | protected void resetPreparedStatement_(PreparedStatement ps, String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability, int autoGeneratedKeys, String[] columnNames) throws SqlException(Code) | | |
resetStatement_ | protected void resetStatement_(Statement statement, int type, int concurrency, int holdability) throws SqlException(Code) | | |
securityCheckComplete | void securityCheckComplete(int svrcod, int secchkcd)(Code) | | |
serverSupportsQryclsimp | final public boolean serverSupportsQryclsimp()(Code) | | Check whether the server has full support for the QRYCLSIMP
parameter in OPNQRY.
true if QRYCLSIMP is fully supported |
setAccessSecurityData | void setAccessSecurityData(int secchkcd, int desiredSecmec, int[] secmecList, boolean sectknReceived, byte[] sectkn) throws DisconnectException(Code) | | |
setConnectionNull | public void setConnectionNull(boolean connectionNull)(Code) | | Parameters: connectionNull - The connectionNull to set. |
setReadOnlyTransactionFlag | protected void setReadOnlyTransactionFlag(boolean flag)(Code) | | |
willAutoCommitGenerateFlow | public boolean willAutoCommitGenerateFlow()(Code) | | |
writeXACommit_ | protected void writeXACommit_() throws SqlException(Code) | | Invokes write commit on NetXAConnection
|
writeXARollback_ | protected void writeXARollback_() throws SqlException(Code) | | Invokes writeRollback on NetXAConnection
|
Methods inherited from org.apache.derby.client.am.Connection | public void accumulate440WarningForMessageProcFailure(SqlWarning e)(Code)(Java Doc) public void accumulate444WarningForMessageProcFailure(SqlWarning e)(Code)(Java Doc) public void accumulateWarning(SqlWarning e)(Code)(Java Doc) abstract public void addSpecialRegisters(String s)(Code)(Java Doc) abstract protected boolean allowCloseInUOW_()(Code)(Java Doc) abstract protected boolean allowLocalCommitRollback_() throws org.apache.derby.client.am.SqlException(Code)(Java Doc) protected void checkForClosedConnection() throws SqlException(Code)(Java Doc) public synchronized void clearWarnings() throws SQLException(Code)(Java Doc) public void clearWarningsX() throws SqlException(Code)(Java Doc) public synchronized void close() throws SQLException(Code)(Java Doc) public synchronized void closeForReuse() throws SqlException(Code)(Java Doc) public synchronized void closeResources() throws SQLException(Code)(Java Doc) public synchronized void closeX() throws SQLException(Code)(Java Doc) public synchronized void commit() throws SQLException(Code)(Java Doc) public void completeAbnormalUnitOfWork()(Code)(Java Doc) public void completeAbnormalUnitOfWork(UnitOfWorkListener uwl)(Code)(Java Doc) public void completeChainBreakingDisconnect()(Code)(Java Doc) public void completeConnect() throws SqlException(Code)(Java Doc) public void completeLocalCommit()(Code)(Java Doc) public void completeLocalRollback()(Code)(Java Doc) protected void completeReset(boolean isDeferredReset, boolean recomputeFromDataSource) throws SqlException(Code)(Java Doc) public void completeSpecificRollback(UnitOfWorkListener uwl)(Code)(Java Doc) public void completeSqlca(Sqlca sqlca)(Code)(Java Doc) public synchronized java.sql.Statement createStatement() throws SQLException(Code)(Java Doc) public synchronized java.sql.Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException(Code)(Java Doc) public synchronized java.sql.Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException(Code)(Java Doc) abstract protected boolean doCloseStatementsOnClose_()(Code)(Java Doc) protected void finalize() throws java.lang.Throwable(Code)(Java Doc) public boolean flowAutoCommit() throws SqlException(Code)(Java Doc) public void flowCommit() throws SqlException(Code)(Java Doc) protected void flowRollback() throws SqlException(Code)(Java Doc) public boolean getAutoCommit() throws SQLException(Code)(Java Doc) public String getCatalog() throws SQLException(Code)(Java Doc) public int getHoldability() throws SQLException(Code)(Java Doc) public java.sql.DatabaseMetaData getMetaData() throws SQLException(Code)(Java Doc) public int getServerVersion()(Code)(Java Doc) public int getTransactionIsolation() throws SQLException(Code)(Java Doc) public java.util.Map getTypeMap() throws SQLException(Code)(Java Doc) public java.sql.SQLWarning getWarnings() throws SQLException(Code)(Java Doc) public int getXAState()(Code)(Java Doc) protected void initConnection(org.apache.derby.client.am.LogWriter logWriter, String user, org.apache.derby.jdbc.ClientBaseDataSource dataSource) throws SqlException(Code)(Java Doc) public boolean isClosed()(Code)(Java Doc) public boolean isClosedX()(Code)(Java Doc) abstract protected boolean isGlobalPending_()(Code)(Java Doc) public boolean isPhysicalConnClosed()(Code)(Java Doc) public boolean isReadOnly() throws SQLException(Code)(Java Doc) public boolean isXAConnection()(Code)(Java Doc) public synchronized void lightReset() throws SqlException(Code)(Java Doc) public void markClosed()(Code)(Java Doc) abstract protected void markClosed_()(Code)(Java Doc) public String nativeSQL(String sql) throws SQLException(Code)(Java Doc) public synchronized String nativeSQLX(String sql) throws SqlException(Code)(Java Doc) abstract protected Agent newAgent_(LogWriter logWriter, int loginTimeout, String serverName, int portNumber) throws SqlException(Code)(Java Doc) abstract protected CallableStatement newCallableStatement_(String sql, int type, int concurrency, int holdability) throws SqlException(Code)(Java Doc) abstract protected DatabaseMetaData newDatabaseMetaData_()(Code)(Java Doc) abstract protected PreparedStatement newPositionedUpdatePreparedStatement_(String sql, Section section) throws SqlException(Code)(Java Doc) abstract protected PreparedStatement newPreparedStatement_(String sql, int type, int concurrency, int holdability, int autoGeneratedKeys, String[] columnNames) throws SqlException(Code)(Java Doc) abstract public SectionManager newSectionManager(String collection, Agent agent, String databaseName)(Code)(Java Doc) abstract protected Statement newStatement_(int type, int concurrency, int holdability) throws SqlException(Code)(Java Doc) public synchronized java.sql.CallableStatement prepareCall(String sql) throws SQLException(Code)(Java Doc) public synchronized java.sql.CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency) throws SQLException(Code)(Java Doc) public synchronized java.sql.CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException(Code)(Java Doc) public synchronized CallableStatement prepareMessageProc(String sql) throws SqlException(Code)(Java Doc) public synchronized PreparedStatement preparePositionedUpdateStatement(String sql, Section querySection) throws SqlException(Code)(Java Doc) public synchronized java.sql.PreparedStatement prepareStatement(String sql) throws SQLException(Code)(Java Doc) public synchronized java.sql.PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException(Code)(Java Doc) public synchronized java.sql.PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException(Code)(Java Doc) public java.sql.PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException(Code)(Java Doc) public java.sql.PreparedStatement prepareStatement(String sql, int columnIndexes) throws SQLException(Code)(Java Doc) public java.sql.PreparedStatement prepareStatement(String sql, String columnNames) throws SQLException(Code)(Java Doc) public void readCommit() throws SqlException(Code)(Java Doc) abstract public void readCommitSubstitute_() throws SqlException(Code)(Java Doc) abstract public void readLocalCommit_() throws SqlException(Code)(Java Doc) abstract public void readLocalRollback_() throws SqlException(Code)(Java Doc) abstract public void readLocalXACommit_() throws SqlException(Code)(Java Doc) abstract public void readLocalXARollback_() throws SqlException(Code)(Java Doc) abstract public void readLocalXAStart_() throws SqlException(Code)(Java Doc) public void readRollback() throws SqlException(Code)(Java Doc) public void readTransactionStart() throws SqlException(Code)(Java Doc) abstract protected void readXACommit_() throws SqlException(Code)(Java Doc) abstract protected void readXARollback_() throws SqlException(Code)(Java Doc) public synchronized void releaseSavepoint(java.sql.Savepoint savepoint) throws SQLException(Code)(Java Doc) public synchronized void reset(LogWriter logWriter, String user, String password, ClientBaseDataSource ds, boolean recomputeFromDataSource) throws SqlException(Code)(Java Doc) public synchronized void reset(LogWriter logWriter, ClientBaseDataSource ds, boolean recomputeFromDataSource) throws SqlException(Code)(Java Doc) abstract protected void resetCallableStatement_(CallableStatement cs, String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SqlException(Code)(Java Doc) protected void resetConnection(LogWriter logWriter, String user, ClientBaseDataSource ds, boolean recomputeFromDataSource) throws SqlException(Code)(Java Doc) protected void resetConnection(LogWriter logWriter, String databaseName, java.util.Properties properties) throws SqlException(Code)(Java Doc) protected void resetPrepareCall(CallableStatement cs) throws SqlException(Code)(Java Doc) protected void resetPrepareStatement(PreparedStatement ps) throws SqlException(Code)(Java Doc) abstract protected void resetPreparedStatement_(PreparedStatement ps, String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability, int autoGeneratedKeys, String[] columnNames) throws SqlException(Code)(Java Doc) protected void resetStatement(Statement s) throws SqlException(Code)(Java Doc) abstract protected void resetStatement_(Statement statement, int type, int concurrency, int holdability) throws SqlException(Code)(Java Doc) abstract protected void reset_(LogWriter logWriter, String user, String password, ClientBaseDataSource ds, boolean recomputerFromDataSource) throws SqlException(Code)(Java Doc) abstract protected void reset_(LogWriter logWriter, ClientBaseDataSource ds, boolean recomputerFromDataSource) throws SqlException(Code)(Java Doc) public synchronized void rollback() throws SQLException(Code)(Java Doc) public synchronized void rollback(java.sql.Savepoint savepoint) throws SQLException(Code)(Java Doc) public synchronized void setAutoCommit(boolean autoCommit) throws SQLException(Code)(Java Doc) public synchronized void setCatalog(String catalog) throws SQLException(Code)(Java Doc) public synchronized void setHoldability(int holdability) throws SQLException(Code)(Java Doc) public void setInUnitOfWork(boolean inUnitOfWork)(Code)(Java Doc) public synchronized void setReadOnly(boolean readOnly) throws SQLException(Code)(Java Doc) public synchronized java.sql.Savepoint setSavepoint() throws SQLException(Code)(Java Doc) public synchronized java.sql.Savepoint setSavepoint(String name) throws SQLException(Code)(Java Doc) public synchronized void setTransactionIsolation(int level) throws SQLException(Code)(Java Doc) public synchronized void setTypeMap(java.util.Map map) throws SQLException(Code)(Java Doc) public void setXAState(int state)(Code)(Java Doc) public boolean transactionInProgress()(Code)(Java Doc) public boolean willAutoCommitGenerateFlow() throws org.apache.derby.client.am.SqlException(Code)(Java Doc) public void writeCommit() throws SqlException(Code)(Java Doc) abstract public void writeCommitSubstitute_() throws SqlException(Code)(Java Doc) abstract public void writeLocalCommit_() throws SqlException(Code)(Java Doc) abstract public void writeLocalRollback_() throws SqlException(Code)(Java Doc) abstract public void writeLocalXACommit_() throws SqlException(Code)(Java Doc) abstract public void writeLocalXARollback_() throws SqlException(Code)(Java Doc) abstract public void writeLocalXAStart_() throws SqlException(Code)(Java Doc) public void writeRollback() throws SqlException(Code)(Java Doc) public void writeTransactionStart(Statement statement) throws SqlException(Code)(Java Doc) abstract protected void writeXACommit_() throws SqlException(Code)(Java Doc) abstract protected void writeXARollback_() throws SqlException(Code)(Java Doc) abstract protected void writeXATransactionStart(Statement statement) throws SqlException(Code)(Java Doc)
|
|
|