ConnectionReplyInterfaceNetPackageReplyclass NetConnectionReply extends Reply implements ConnectionReplyInterface
| Modifier and Type | Field | Description |
|---|---|---|
private static MessageUtil |
msgutil_ |
agent_, buffer_, count_, DEFAULT_BUFFER_SIZE, dssLength_, END_OF_COLLECTION, END_OF_SAME_ID_CHAIN, ensuredLengthForDecryption_, longBufferForDecryption_, longCountForDecryption_, longPosForDecryption_, longValueForDecryption_, netAgent_, peekedLength_, pos_| Constructor | Description |
|---|---|
NetConnectionReply(NetAgent netAgent,
int bufferSize) |
| Modifier and Type | Method | Description |
|---|---|---|
(package private) boolean |
checkAndGetReceivedFlag(boolean receivedFlag) |
|
(package private) void |
checkRequiredObjects(boolean receivedFlag) |
|
(package private) void |
checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2) |
|
(package private) void |
checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3) |
|
private 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) |
|
private void |
doObjnsprmSemantics(int codePoint) |
|
private void |
doPrccnvrmSemantics(int conversationProtocolErrorCode) |
|
(package private) void |
doPrmnsprmSemantics(int codePoint) |
|
(package private) void |
doValnsprmSemantics(int codePoint,
int value) |
|
private void |
doValnsprmSemantics(int codePoint,
java.lang.String value) |
|
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.
|
private void |
parseABNUOWRM() |
|
private void |
parseAccessRdbError(NetConnection netConnection) |
|
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) |
|
private int |
parseCCSIDDBC() |
|
private int |
parseCCSIDMBC() |
|
private int |
parseCCSIDSBC() |
|
(package private) void |
parseCMDCHKRM() |
|
(package private) void |
parseCMDNSPRM() |
|
private int |
parseCODPNT() |
|
private int |
parseCODPNTDR() |
|
private void |
parseCommitError(ConnectionCallbackInterface connection) |
|
(package private) void |
parseCommonError(int peekCP) |
|
private byte[] |
parseCRRTKN(boolean skip) |
|
private void |
parseDummyEXCSATRD(NetConnection netConnection) |
|
private void |
parseDummyEXCSATreply(NetConnection netConnection) |
|
(package private) void |
parseENDUOWRM(ConnectionCallbackInterface connection) |
|
private void |
parseExchangeServerAttributesError() |
|
private void |
parseEXCSATRD(NetConnection netConnection) |
|
private void |
parseEXCSATreply(NetConnection netConnection) |
|
private java.lang.String |
parseEXTNAM() |
|
private java.lang.String |
parseFastNVCMorNVCS() |
|
private int |
parseFastSQLNUMGRP() |
|
(package private) int |
parseFastSQLNUMROW() |
|
(package private) int |
parseFastSVRCOD(int minSvrcod,
int maxSvrcod) |
|
(package private) java.lang.String |
parseFastVCS() |
|
(package private) java.util.List<javax.transaction.xa.Xid> |
parseIndoubtList() |
|
private void |
parseInitialPBSD(ClientConnection connection) |
Parse the initial PBSD - PiggyBackedSessionData code point.
|
private void |
parseMGRLVLLS(NetConnection netConnection) |
|
private int |
parseMGRLVLN() |
|
private void |
parseMGRLVLRM() |
|
(package private) void |
parseOBJNSPRM() |
|
(package private) void |
parsePBSD() |
Parse a PBSD - PiggyBackedSessionData code point.
|
private int |
parsePRCCNVCD() |
|
private void |
parsePRCCNVRM() |
|
private java.lang.String |
parsePRDID(boolean skip) |
|
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() |
|
(package private) java.lang.String |
parseRDBNAM(boolean skip) |
|
private void |
parseRDBNFNRM(NetConnection netConnection) |
|
private void |
parseRDBRLLBCKreply(ConnectionCallbackInterface connection) |
|
private void |
parseRollbackError() |
|
private int |
parseSECCHKCD() |
|
private void |
parseSECCHKreply(NetConnection netConnection) |
|
private void |
parseSECCHKRM(NetConnection netConnection) |
|
private int[] |
parseSECMEC() |
|
private byte[] |
parseSECTKN(boolean skip) |
|
private void |
parseSecurityCheckError(NetConnection netConnection) |
|
private NetSqlca |
parseSQLCAGRP(Sqlca[] rowsetSqlca) |
|
(package private) 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) |
|
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() |
|
private java.lang.String |
parseSRVCLSNM() |
|
private java.lang.String |
parseSRVNAM() |
|
private java.lang.String |
parseSRVRLSLV() |
|
(package private) int |
parseSVRCOD(int minSvrcod,
int maxSvrcod) |
|
(package private) int |
parseSYNCCRD(ConnectionCallbackInterface connection) |
|
(package private) void |
parseSYNCCTLError(int peekCP) |
|
(package private) int |
parseSYNCCTLreply(ConnectionCallbackInterface connection) |
|
(package private) byte |
parseSYNCTYPE() |
|
private int |
parseSYNERRCD() |
|
private void |
parseSYNTAXRM() |
|
private void |
parseTYPDEFNAM() |
|
private void |
parseTYPDEFOVR() |
|
(package private) int |
parseTypdefsOrMgrlvlovrs() |
|
private int |
parseUOWDSP() |
|
private java.lang.String |
parseUSRID(boolean skip) |
|
private void |
parseVALNSPRM() |
|
(package private) int |
parseXARETVAL() |
|
(package private) javax.transaction.xa.Xid |
parseXID() |
|
(package private) int |
parseXIDCNT() |
|
(package private) void |
readAccessDatabase(ClientConnection connection) |
|
(package private) void |
readAccessSecurity(ClientConnection connection,
int securityMechanism) |
|
void |
readCommitSubstitute(ConnectionCallbackInterface connection) |
|
(package private) void |
readExchangeServerAttributes(ClientConnection 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(ClientConnection connection) |
|
(package private) void |
readXaCommit(NetConnection conn) |
|
(package private) int |
readXaEndUnitOfWork(NetConnection conn) |
|
(package private) void |
readXaForget(NetConnection conn) |
|
(package private) int |
readXaPrepare(NetConnection conn) |
|
(package private) void |
readXaRecover(NetConnection conn) |
|
(package private) int |
readXaRollback(NetConnection conn) |
|
(package private) void |
readXaStartUnitOfWork(NetConnection conn) |
|
private void |
resetRowsetSqlca(Sqlca[] rowsetSqlca,
int row) |
|
private void |
skipFastNVCMorNVCS() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitadjustDdmLength, adjustLengths, doSyntaxrmSemantics, endOfSameIdChainData, ensureBLayerDataInBuffer, getData, getDdmLength, getFastData, getFastSkipSQLCARDrowLength, initialize, mark, matchCodePoint, parseLengthAndMatchCodePoint, peekCodePoint, peekFastBytes, peekFastLength, peekForNullSqlcagrp, peekNumOfColumns, peekTotalColumnCount, popCollectionStack, pushLengthOnCollectionStack, readByte, readBytes, readBytes, readFastByte, readFastBytes, readFastInt, readFastIntArray, readFastLDBytes, readFastLong, readFastShort, readFastString, readFastString, readFastUnsignedByte, readFastUnsignedShort, readInt, readShort, readString, readString, readUnsignedByte, readUnsignedShort, readUnsignedShortList, skipBytes, skipBytes, skipFastBytes, startSameIdChainParseprivate static MessageUtil msgutil_
NetConnectionReply(NetAgent netAgent, int bufferSize)
void readExchangeServerAttributes(ClientConnection connection) throws SqlException
SqlExceptionvoid readAccessSecurity(ClientConnection connection, int securityMechanism) throws SqlException
SqlExceptionvoid readSecurityCheck(ClientConnection connection) throws SqlException
SqlExceptionvoid readAccessDatabase(ClientConnection 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 ConnectionReplyInterfaceDisconnectExceptionvoid readXaStartUnitOfWork(NetConnection conn) throws DisconnectException
DisconnectExceptionint readXaEndUnitOfWork(NetConnection conn) throws DisconnectException
DisconnectExceptionint readXaPrepare(NetConnection conn) throws DisconnectException
DisconnectExceptionvoid readXaCommit(NetConnection conn) throws DisconnectException
DisconnectExceptionint readXaRollback(NetConnection conn) throws DisconnectException
DisconnectExceptionvoid readXaRecover(NetConnection conn) throws DisconnectException
DisconnectExceptionvoid 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
DisconnectExceptionint parseTypdefsOrMgrlvlovrs()
throws DisconnectException
DisconnectExceptionprivate void parseCommitError(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectExceptionprivate void parseRollbackError()
throws DisconnectException
DisconnectExceptionprivate void parseExchangeServerAttributesError()
throws DisconnectException
DisconnectExceptionprivate void parseAccessSecurityError(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseSecurityCheckError(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseAccessRdbError(NetConnection netConnection) throws DisconnectException
DisconnectExceptionvoid parseCommonError(int peekCP)
throws DisconnectException
DisconnectExceptionprivate NetSqlca 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 ResultsetCallbackInterfaceDisconnectExceptionprivate void 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
DisconnectExceptionvoid parseCMDCHKRM()
throws DisconnectException
DisconnectExceptionvoid parseRDBNACRM()
throws DisconnectException
DisconnectExceptionprivate void parseRDBNFNRM(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseRDBATHRM(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate void parseSYNTAXRM()
throws DisconnectException
DisconnectExceptionprivate void parseRDBACCRM()
throws DisconnectException
DisconnectExceptionprivate void parseRDBAFLRM()
throws DisconnectException
DisconnectExceptionprivate void parseVALNSPRM()
throws DisconnectException
DisconnectExceptionprivate void parsePRCCNVRM()
throws DisconnectException
DisconnectExceptionvoid parseOBJNSPRM()
throws DisconnectException
DisconnectExceptionprivate void parseMGRLVLRM()
throws DisconnectException
DisconnectExceptionvoid parseCMDNSPRM()
throws DisconnectException
DisconnectExceptionprivate void 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
DisconnectExceptionprivate void parseTYPDEFNAM()
throws DisconnectException
DisconnectExceptionprivate void parseTYPDEFOVR()
throws DisconnectException
DisconnectExceptionint parseSYNCCRD(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectExceptionint parseXARETVAL()
throws DisconnectException
DisconnectExceptionbyte parseSYNCTYPE()
throws DisconnectException
DisconnectExceptionint parseSYNCCTLreply(ConnectionCallbackInterface connection) throws DisconnectException
DisconnectExceptionvoid parseSYNCCTLError(int peekCP)
throws DisconnectException
DisconnectExceptionprivate void parseMGRLVLLS(NetConnection netConnection) throws DisconnectException
DisconnectExceptionprivate java.lang.String parseEXTNAM()
throws DisconnectException
DisconnectExceptionprivate java.lang.String parseSRVCLSNM()
throws DisconnectException
DisconnectExceptionprivate java.lang.String parseSRVNAM()
throws DisconnectException
DisconnectExceptionprivate java.lang.String parseSRVRLSLV()
throws DisconnectException
DisconnectExceptionprivate int parseMGRLVLN()
throws DisconnectException
DisconnectExceptionprivate int[] parseSECMEC()
throws DisconnectException
DisconnectExceptionprivate byte[] parseSECTKN(boolean skip)
throws DisconnectException
DisconnectExceptionprivate int parseSECCHKCD()
throws DisconnectException
DisconnectExceptionprivate java.lang.String parsePRDID(boolean skip)
throws DisconnectException
DisconnectExceptionprivate java.lang.String parseUSRID(boolean skip)
throws DisconnectException
DisconnectExceptionprivate int parseCODPNTDR()
throws DisconnectException
DisconnectExceptionprivate byte[] parseCRRTKN(boolean skip)
throws DisconnectException
DisconnectExceptionprivate int parseUOWDSP()
throws DisconnectException
DisconnectExceptionjava.lang.String parseRDBNAM(boolean skip)
throws DisconnectException
DisconnectExceptionint parseXIDCNT()
throws DisconnectException
DisconnectExceptionjavax.transaction.xa.Xid parseXID()
throws DisconnectException
DisconnectExceptionjava.util.List<javax.transaction.xa.Xid> parseIndoubtList()
throws DisconnectException
DisconnectExceptionprivate int parseSYNERRCD()
throws DisconnectException
DisconnectExceptionprivate int parseCODPNT()
throws DisconnectException
DisconnectExceptionprivate int parsePRCCNVCD()
throws DisconnectException
DisconnectExceptionprivate int parseCCSIDSBC()
throws DisconnectException
DisconnectExceptionprivate int parseCCSIDMBC()
throws DisconnectException
DisconnectExceptionprivate int parseCCSIDDBC()
throws DisconnectException
DisconnectExceptionint parseSVRCOD(int minSvrcod,
int maxSvrcod)
throws DisconnectException
DisconnectExceptionint parseFastSVRCOD(int minSvrcod,
int maxSvrcod)
throws DisconnectException
DisconnectExceptionNetSqlca 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
DisconnectExceptionjava.lang.String parseFastVCS()
throws DisconnectException
DisconnectExceptionboolean checkAndGetReceivedFlag(boolean receivedFlag)
throws DisconnectException
DisconnectExceptionvoid checkRequiredObjects(boolean receivedFlag)
throws DisconnectException
DisconnectExceptionvoid checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2)
throws DisconnectException
DisconnectExceptionvoid checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3)
throws DisconnectException
DisconnectExceptionprivate void checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3,
boolean receivedFlag4)
throws DisconnectException
DisconnectExceptionprivate void doObjnsprmSemantics(int codePoint)
throws DisconnectException
DisconnectExceptionvoid doPrmnsprmSemantics(int codePoint)
throws DisconnectException
DisconnectExceptionvoid doValnsprmSemantics(int codePoint,
int value)
throws DisconnectException
DisconnectExceptionprivate void 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
DisconnectExceptionprivate void doPrccnvrmSemantics(int conversationProtocolErrorCode)
throws DisconnectException
DisconnectExceptionprivate void 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
DisconnectExceptionprivate void resetRowsetSqlca(Sqlca[] rowsetSqlca, int row)
private void parseInitialPBSD(ClientConnection 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.
DisconnectExceptionvoid parsePBSD()
throws DisconnectException
DisconnectExceptionApache Derby V10.14 Internals - Copyright © 2004,2018 The Apache Software Foundation. All Rights Reserved.