public class NetConnectionReply extends Reply implements ConnectionReplyInterface
| Modifier and Type | Field and Description |
|---|---|
private static MessageUtil |
msgutil_ |
agent_, buffer_, count_, DEFAULT_BUFFER_SIZE, dssCorrelationID_, dssIsContinued_, dssLength_, END_OF_COLLECTION, END_OF_SAME_ID_CHAIN, ensuredLengthForDecryption_, longBufferForDecryption_, longCountForDecryption_, longPosForDecryption_, longValueForDecryption_, netAgent_, peekedCodePoint_, peekedLength_, pos_| Constructor and Description |
|---|
NetConnectionReply(NetAgent netAgent,
int bufferSize) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
checkAndGetReceivedFlag(boolean receivedFlag) |
protected void |
checkRequiredObjects(boolean receivedFlag) |
protected void |
checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2) |
protected void |
checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3) |
protected void |
checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3,
boolean receivedFlag4) |
(package private) void |
doDtamchrmSemantics() |
private void |
doMgrlvlrmSemantics(int[] nameList,
int[] levelList) |
private void |
doMgrlvlrmSemantics(int manager,
int level) |
private void |
doMgrlvlrmSemantics(java.lang.String manager,
java.lang.String level) |
protected void |
doObjnsprmSemantics(int codePoint) |
protected void |
doPrccnvrmSemantics(int conversationProtocolErrorCode) |
protected void |
doPrmnsprmSemantics(int codePoint) |
(package private) void |
doValnsprmSemantics(int codePoint,
int value) |
(package private) void |
doValnsprmSemantics(int codePoint,
java.lang.String value) |
(package private) NetSqlca |
parseAbnormalEndUow(ConnectionCallbackInterface connection,
UnitOfWorkListener uwl)
Perform necessary actions for parsing of a ABNUOWRM message.
|
(package private) NetSqlca |
parseAbnormalEndUow(ResultSetCallbackInterface r)
Perform necessary actions for parsing of a ABNUOWRM message.
|
(package private) NetSqlca |
parseAbnormalEndUow(StatementCallbackInterface s)
Perform necessary actions for parsing of a ABNUOWRM message.
|
(package private) void |
parseABNUOWRM() |
(package private) void |
parseAccessRdbError(NetConnection netConnection) |
(package private) void |
parseAccessSecurityError(NetConnection netConnection) |
private void |
parseACCRDBreply(NetConnection netConnection) |
private void |
parseACCRDBRM(NetConnection netConnection) |
private void |
parseACCSECRD(NetConnection netConnection,
int securityMechanism) |
private void |
parseACCSECreply(NetConnection netConnection,
int securityMechanism) |
protected int |
parseCCSIDDBC() |
protected int |
parseCCSIDMBC() |
protected int |
parseCCSIDSBC() |
protected void |
parseCMDCHKRM() |
protected void |
parseCMDNSPRM() |
protected int |
parseCODPNT() |
protected int |
parseCODPNTDR() |
protected void |
parseCommitError(ConnectionCallbackInterface connection) |
(package private) void |
parseCommonError(int peekCP) |
protected byte[] |
parseCRRTKN(boolean skip) |
private void |
parseDummyEXCSATRD(NetConnection netConnection) |
private void |
parseDummyEXCSATreply(NetConnection netConnection) |
(package private) void |
parseENDUOWRM(ConnectionCallbackInterface connection) |
(package private) void |
parseExchangeServerAttributesError() |
private void |
parseEXCSATRD(NetConnection netConnection) |
private void |
parseEXCSATreply(NetConnection netConnection) |
protected java.lang.String |
parseEXTNAM() |
private java.lang.String |
parseFastNVCMorNVCS() |
private int |
parseFastSQLNUMGRP() |
(package private) int |
parseFastSQLNUMROW() |
protected int |
parseFastSVRCOD(int minSvrcod,
int maxSvrcod) |
protected java.lang.String |
parseFastVCS() |
protected java.util.Hashtable |
parseIndoubtList() |
protected void |
parseInitialPBSD(Connection connection)
Parse the initial PBSD - PiggyBackedSessionData code point.
|
private void |
parseMGRLVLLS(NetConnection netConnection) |
protected int |
parseMGRLVLN() |
private void |
parseMGRLVLRM() |
(package private) void |
parseOBJNSPRM() |
protected void |
parsePBSD()
Parse a PBSD - PiggyBackedSessionData code point.
|
protected int |
parsePRCCNVCD() |
protected void |
parsePRCCNVRM() |
protected java.lang.String |
parsePRDID(boolean skip) |
(package private) void |
parseRdbAccessFailed(NetConnection netConnection) |
private void |
parseRDBACCRM() |
private void |
parseRDBAFLRM() |
private void |
parseRDBATHRM(NetConnection netConnection) |
private void |
parseRDBCMMreply(ConnectionCallbackInterface connection) |
(package private) void |
parseRDBNACRM() |
protected java.lang.String |
parseRDBNAM(boolean skip) |
private void |
parseRDBNFNRM(NetConnection netConnection) |
private void |
parseRDBRLLBCKreply(ConnectionCallbackInterface connection) |
(package private) void |
parseRollbackError() |
protected int |
parseSECCHKCD() |
private void |
parseSECCHKreply(NetConnection netConnection) |
private void |
parseSECCHKRM(NetConnection netConnection) |
protected int[] |
parseSECMEC() |
protected byte[] |
parseSECTKN(boolean skip) |
(package private) void |
parseSecurityCheckError(NetConnection netConnection) |
private NetSqlca |
parseSQLCAGRP(Sqlca[] rowsetSqlca) |
protected NetSqlca |
parseSQLCARD(Sqlca[] rowsetSqlca) |
(package private) NetSqlca |
parseSQLCARDrow(Sqlca[] rowsetSqlca) |
private void |
parseSQLCAXGRP(NetSqlca netSqlca) |
private void |
parseSQLCNGRP() |
private void |
parseSQLCNROW() |
private int |
parseSQLDCGRP(Sqlca[] rowsetSqlca,
int lastRow) |
private int |
parseSQLDCROW(Sqlca[] rowsetSqlca,
int lastRow) |
(package private) void |
parseSQLDCTOKS() |
private void |
parseSQLDCXGRP() |
private void |
parseSQLDIAGCI(Sqlca[] rowsetSqlca) |
private void |
parseSQLDIAGCN() |
private long |
parseSQLDIAGGRP(Sqlca[] rowsetSqlca) |
private long |
parseSQLDIAGSTT(Sqlca[] rowsetSqlca) |
private int |
parseSQLNUMGRP() |
(package private) int |
parseSQLNUMROW() |
private void |
parseSQLTOKGRP() |
private void |
parseSQLTOKROW() |
protected java.lang.String |
parseSRVCLSNM() |
protected java.lang.String |
parseSRVNAM() |
protected java.lang.String |
parseSRVRLSLV() |
protected int |
parseSVRCOD(int minSvrcod,
int maxSvrcod) |
(package private) int |
parseSYNCCRD(ConnectionCallbackInterface connection) |
(package private) void |
parseSYNCCTLError(int peekCP) |
protected int |
parseSYNCCTLreply(ConnectionCallbackInterface connection) |
protected byte |
parseSYNCTYPE() |
protected int |
parseSYNERRCD() |
protected void |
parseSYNTAXRM() |
(package private) void |
parseTYPDEFNAM() |
(package private) void |
parseTYPDEFOVR() |
protected int |
parseTypdefsOrMgrlvlovrs() |
protected int |
parseUOWDSP() |
protected java.lang.String |
parseUSRID(boolean skip) |
protected void |
parseVALNSPRM() |
protected int |
parseXARETVAL() |
protected javax.transaction.xa.Xid |
parseXID() |
protected int |
parseXIDCNT() |
(package private) void |
readAccessDatabase(Connection connection) |
(package private) void |
readAccessSecurity(Connection connection,
int securityMechanism) |
void |
readCommitSubstitute(ConnectionCallbackInterface connection) |
(package private) void |
readExchangeServerAttributes(Connection connection) |
void |
readLocalCommit(ConnectionCallbackInterface connection) |
void |
readLocalRollback(ConnectionCallbackInterface connection) |
void |
readLocalXACommit(ConnectionCallbackInterface connection) |
void |
readLocalXARollback(ConnectionCallbackInterface connection) |
void |
readLocalXAStart(ConnectionCallbackInterface connection) |
(package private) void |
readSecurityCheck(Connection connection) |
protected void |
readXaCommit(NetConnection conn) |
protected int |
readXaEndUnitOfWork(NetConnection conn) |
protected void |
readXaForget(NetConnection conn) |
protected int |
readXaPrepare(NetConnection conn) |
protected void |
readXaRecover(NetConnection conn) |
protected int |
readXaRollback(NetConnection conn) |
protected void |
readXaStartUnitOfWork(NetConnection conn) |
(package private) void |
resetRowsetSqlca(Sqlca[] rowsetSqlca,
int row) |
private void |
skipFastNVCMorNVCS() |
adjustDdmLength, adjustLengths, doSyntaxrmSemantics, endOfSameIdChainData, ensureALayerDataInBuffer, ensureBLayerDataInBuffer, ensureSpaceInBufferForFill, fill, getData, getDdmLength, getFastData, getFastSkipSQLCARDrowLength, initialize, mark, matchCodePoint, parseLengthAndMatchCodePoint, peekCodePoint, peekFastBytes, peekFastLength, peekForNullSqlcagrp, peekLength, peekNumOfColumns, peekTotalColumnCount, popCollectionStack, popMark, pushLengthOnCollectionStack, readBoolean, readByte, readBytes, readBytes, readDSSContinuationHeader, readDssHeader, readFastByte, readFastBytes, readFastInt, readFastIntArray, readFastLDBytes, readFastLong, readFastShort, readFastString, readFastString, readFastUnsignedByte, readFastUnsignedShort, readInt, readIntArray, readLDBytes, readLengthAndCodePoint, readLong, readShort, readString, readString, readString, readUnsignedByte, readUnsignedShort, readUnsignedShortList, skipBytes, skipBytes, skipFastBytes, startSameIdChainParseprivate static MessageUtil msgutil_
NetConnectionReply(NetAgent netAgent, int bufferSize)
void readExchangeServerAttributes(Connection connection) throws SqlException
SqlExceptionvoid readAccessSecurity(Connection connection, int securityMechanism) throws SqlException
SqlExceptionvoid readSecurityCheck(Connection connection) throws SqlException
SqlExceptionvoid readAccessDatabase(Connection connection) throws SqlException
SqlExceptionpublic void readCommitSubstitute(ConnectionCallbackInterface connection) throws DisconnectException
readCommitSubstitute in interface ConnectionReplyInterfaceDisconnectExceptionpublic void readLocalCommit(ConnectionCallbackInterface connection) throws DisconnectException
readLocalCommit in interface ConnectionReplyInterfaceDisconnectExceptionpublic void readLocalRollback(ConnectionCallbackInterface connection) throws DisconnectException
readLocalRollback in interface ConnectionReplyInterfaceDisconnectExceptionpublic void readLocalXAStart(ConnectionCallbackInterface connection) throws DisconnectException
readLocalXAStart in interface ConnectionReplyInterfaceDisconnectExceptionpublic void readLocalXACommit(ConnectionCallbackInterface connection) throws DisconnectException
readLocalXACommit in interface ConnectionReplyInterfaceDisconnectExceptionpublic void readLocalXARollback(ConnectionCallbackInterface connection) throws DisconnectException
readLocalXARollback in interface ConnectionReplyInterfaceDisconnectExceptionprotected void readXaStartUnitOfWork(NetConnection conn) throws DisconnectException
DisconnectExceptionprotected int readXaEndUnitOfWork(NetConnection conn) throws DisconnectException
DisconnectExceptionprotected int readXaPrepare(NetConnection conn) throws DisconnectException
DisconnectExceptionprotected void readXaCommit(NetConnection conn) throws DisconnectException
DisconnectExceptionprotected int readXaRollback(NetConnection conn) throws DisconnectException
DisconnectExceptionprotected void readXaRecover(NetConnection conn) throws DisconnectException
DisconnectExceptionprotected void readXaForget(NetConnection conn) throws DisconnectException
DisconnectExceptionprivate void parseRDBCMMreply(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectExceptionprivate void parseRDBRLLBCKreply(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectExceptionprivate void parseEXCSATreply(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseDummyEXCSATreply(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseACCSECreply(NetConnection netConnection, int securityMechanism) throws DisconnectException
DisconnectExceptionprivate void parseSECCHKreply(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseACCRDBreply(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprotected int parseTypdefsOrMgrlvlovrs()
throws DisconnectException
DisconnectExceptionprotected void parseCommitError(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectExceptionvoid parseRollbackError()
throws DisconnectException
DisconnectExceptionvoid parseExchangeServerAttributesError()
throws DisconnectException
DisconnectExceptionvoid parseAccessSecurityError(NetConnection netConnection) throws DisconnectException
DisconnectExceptionvoid parseSecurityCheckError(NetConnection netConnection) throws DisconnectException
DisconnectExceptionvoid parseAccessRdbError(NetConnection netConnection) throws DisconnectException
DisconnectExceptionvoid parseCommonError(int peekCP)
throws DisconnectException
DisconnectExceptionNetSqlca parseAbnormalEndUow(ConnectionCallbackInterface connection, UnitOfWorkListener uwl) throws DisconnectException
connection - an implementation of the ConnectionCallbackInterfaceDisconnectExceptionNetSqlca parseAbnormalEndUow(StatementCallbackInterface s) throws DisconnectException
s - an implementation of the StatementCallbackInterfaceDisconnectExceptionNetSqlca parseAbnormalEndUow(ResultSetCallbackInterface r) throws DisconnectException
r - an implementation of the ResultsetCallbackInterfaceDisconnectExceptionvoid parseRdbAccessFailed(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseSECCHKRM(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseACCRDBRM(NetConnection netConnection) throws DisconnectException
DisconnectExceptionvoid parseENDUOWRM(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectExceptionprotected void parseCMDCHKRM()
throws DisconnectException
DisconnectExceptionvoid parseRDBNACRM()
throws DisconnectException
DisconnectExceptionprivate void parseRDBNFNRM(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseRDBATHRM(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprotected void parseSYNTAXRM()
throws DisconnectException
DisconnectExceptionprivate void parseRDBACCRM()
throws DisconnectException
DisconnectExceptionprivate void parseRDBAFLRM()
throws DisconnectException
DisconnectExceptionprotected void parseVALNSPRM()
throws DisconnectException
DisconnectExceptionprotected void parsePRCCNVRM()
throws DisconnectException
DisconnectExceptionvoid parseOBJNSPRM()
throws DisconnectException
DisconnectExceptionprivate void parseMGRLVLRM()
throws DisconnectException
DisconnectExceptionprotected void parseCMDNSPRM()
throws DisconnectException
DisconnectExceptionvoid parseABNUOWRM()
throws DisconnectException
DisconnectExceptionprivate void parseEXCSATRD(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseDummyEXCSATRD(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseACCSECRD(NetConnection netConnection, int securityMechanism) throws DisconnectException
DisconnectExceptionvoid parseTYPDEFNAM()
throws DisconnectException
DisconnectExceptionvoid parseTYPDEFOVR()
throws DisconnectException
DisconnectExceptionint parseSYNCCRD(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectExceptionprotected int parseXARETVAL()
throws DisconnectException
DisconnectExceptionprotected byte parseSYNCTYPE()
throws DisconnectException
DisconnectExceptionprotected int parseSYNCCTLreply(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectExceptionvoid parseSYNCCTLError(int peekCP)
throws DisconnectException
DisconnectExceptionprivate void parseMGRLVLLS(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprotected java.lang.String parseEXTNAM()
throws DisconnectException
DisconnectExceptionprotected java.lang.String parseSRVCLSNM()
throws DisconnectException
DisconnectExceptionprotected java.lang.String parseSRVNAM()
throws DisconnectException
DisconnectExceptionprotected java.lang.String parseSRVRLSLV()
throws DisconnectException
DisconnectExceptionprotected int parseMGRLVLN()
throws DisconnectException
DisconnectExceptionprotected int[] parseSECMEC()
throws DisconnectException
DisconnectExceptionprotected byte[] parseSECTKN(boolean skip)
throws DisconnectException
DisconnectExceptionprotected int parseSECCHKCD()
throws DisconnectException
DisconnectExceptionprotected java.lang.String parsePRDID(boolean skip)
throws DisconnectException
DisconnectExceptionprotected java.lang.String parseUSRID(boolean skip)
throws DisconnectException
DisconnectExceptionprotected int parseCODPNTDR()
throws DisconnectException
DisconnectExceptionprotected byte[] parseCRRTKN(boolean skip)
throws DisconnectException
DisconnectExceptionprotected int parseUOWDSP()
throws DisconnectException
DisconnectExceptionprotected java.lang.String parseRDBNAM(boolean skip)
throws DisconnectException
DisconnectExceptionprotected int parseXIDCNT()
throws DisconnectException
DisconnectExceptionprotected javax.transaction.xa.Xid parseXID()
throws DisconnectException
DisconnectExceptionprotected java.util.Hashtable parseIndoubtList()
throws DisconnectException
DisconnectExceptionprotected int parseSYNERRCD()
throws DisconnectException
DisconnectExceptionprotected int parseCODPNT()
throws DisconnectException
DisconnectExceptionprotected int parsePRCCNVCD()
throws DisconnectException
DisconnectExceptionprotected int parseCCSIDSBC()
throws DisconnectException
DisconnectExceptionprotected int parseCCSIDMBC()
throws DisconnectException
DisconnectExceptionprotected int parseCCSIDDBC()
throws DisconnectException
DisconnectExceptionprotected int parseSVRCOD(int minSvrcod,
int maxSvrcod)
throws DisconnectException
DisconnectExceptionprotected int parseFastSVRCOD(int minSvrcod,
int maxSvrcod)
throws DisconnectException
DisconnectExceptionprotected NetSqlca parseSQLCARD(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectExceptionNetSqlca parseSQLCARDrow(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectExceptionint parseSQLNUMROW()
throws DisconnectException
DisconnectExceptionint parseFastSQLNUMROW()
throws DisconnectException
DisconnectExceptionprivate int parseSQLNUMGRP()
throws DisconnectException
DisconnectExceptionprivate int parseFastSQLNUMGRP()
throws DisconnectException
DisconnectExceptionprivate NetSqlca parseSQLCAGRP(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectExceptionprivate void parseSQLCAXGRP(NetSqlca netSqlca) throws DisconnectException
DisconnectExceptionprivate long parseSQLDIAGGRP(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectExceptionprotected java.lang.String parseFastVCS()
throws DisconnectException
DisconnectExceptionprotected boolean checkAndGetReceivedFlag(boolean receivedFlag)
throws DisconnectException
DisconnectExceptionprotected void checkRequiredObjects(boolean receivedFlag)
throws DisconnectException
DisconnectExceptionprotected void checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2)
throws DisconnectException
DisconnectExceptionprotected void checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3)
throws DisconnectException
DisconnectExceptionprotected void checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3,
boolean receivedFlag4)
throws DisconnectException
DisconnectExceptionprotected void doObjnsprmSemantics(int codePoint)
throws DisconnectException
DisconnectExceptionprotected void doPrmnsprmSemantics(int codePoint)
throws DisconnectException
DisconnectExceptionvoid doValnsprmSemantics(int codePoint,
int value)
throws DisconnectException
DisconnectExceptionvoid doValnsprmSemantics(int codePoint,
java.lang.String value)
throws DisconnectException
DisconnectExceptionvoid doDtamchrmSemantics()
throws DisconnectException
DisconnectExceptionprivate void doMgrlvlrmSemantics(java.lang.String manager,
java.lang.String level)
throws DisconnectException
DisconnectExceptionprivate void doMgrlvlrmSemantics(int manager,
int level)
throws DisconnectException
DisconnectExceptionprivate void doMgrlvlrmSemantics(int[] nameList,
int[] levelList)
throws DisconnectException
DisconnectExceptionprotected void doPrccnvrmSemantics(int conversationProtocolErrorCode)
throws DisconnectException
DisconnectExceptionvoid parseSQLDCTOKS()
throws DisconnectException
DisconnectExceptionprivate void parseSQLDIAGCI(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectExceptionprivate void parseSQLDIAGCN()
throws DisconnectException
DisconnectExceptionprivate void parseSQLCNROW()
throws DisconnectException
DisconnectExceptionprivate int parseSQLDCROW(Sqlca[] rowsetSqlca, int lastRow) throws DisconnectException
DisconnectExceptionprivate void parseSQLTOKROW()
throws DisconnectException
DisconnectExceptionprivate void parseSQLTOKGRP()
throws DisconnectException
DisconnectExceptionprivate long parseSQLDIAGSTT(Sqlca[] rowsetSqlca) throws DisconnectException
DisconnectExceptionprivate void parseSQLCNGRP()
throws DisconnectException
DisconnectExceptionprivate int parseSQLDCGRP(Sqlca[] rowsetSqlca, int lastRow) throws DisconnectException
DisconnectExceptionprivate void parseSQLDCXGRP()
throws DisconnectException
DisconnectExceptionprivate java.lang.String parseFastNVCMorNVCS()
throws DisconnectException
DisconnectExceptionprivate void skipFastNVCMorNVCS()
throws DisconnectException
DisconnectExceptionvoid resetRowsetSqlca(Sqlca[] rowsetSqlca, int row)
protected void parseInitialPBSD(Connection connection) throws DisconnectException
If sent by the server, it contains a PBSD_ISO code point followed by a byte representing the JDBC isolation level, and a PBSD_SCHEMA code point followed by the name of the current schema as an UTF-8 String.
DisconnectExceptionprotected void parsePBSD()
throws DisconnectException
DisconnectExceptionApache Derby V10.10 Internals - Copyright © 2004,2014 The Apache Software Foundation. All Rights Reserved.