public class NetStatementReply extends NetPackageReply implements StatementReplyInterface
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 |
---|
NetStatementReply(NetAgent netAgent,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
private int |
calculateResultSetConcurrency(int qryattupd,
int defaultConcurrency) |
private int |
calculateResultSetHoldability(int sqlcsrhld) |
private int |
calculateResultSetType(int qryattscr,
int qryattsns,
int defaultType) |
private void |
checkFastRLO(int[][] rlo) |
private void |
checkPreviousSQLDTARDtriplet(int previousTripletType,
int tripletType,
int previousTripletId,
int tripletId) |
protected void |
copyEXTDTA(NetCursor netCursor) |
private void |
descriptorErrorDetected() |
(package private) void |
parseDescribeError(StatementCallbackInterface statement) |
private void |
parseDSCSQLSTTreply(PreparedStatementCallbackInterface ps,
int metaDataType) |
protected void |
parseENDQRYRM(ResultSetCallbackInterface resultSetI) |
protected void |
parseEndQuery(ResultSetCallbackInterface resultSetI) |
private void |
parseEXCSQLIMMreply(StatementCallbackInterface statement) |
private void |
parseEXCSQLSETreply(StatementCallbackInterface statement) |
private void |
parseEXCSQLSTTreply(StatementCallbackInterface statementI) |
(package private) void |
parseExecuteError(StatementCallbackInterface statementI) |
(package private) void |
parseExecuteImmediateError(StatementCallbackInterface statement) |
(package private) void |
parseExecuteSetStatementError(StatementCallbackInterface statement) |
protected int |
parseFastQRYATTSCR() |
protected int |
parseFastQRYATTSET() |
protected int |
parseFastQRYATTSNS() |
protected int |
parseFastQRYATTUPD() |
private long |
parseFastQRYINSID() |
protected int |
parseFastQRYPRCTYP() |
protected int |
parseFastSQLCSRHLD() |
(package private) void |
parseFastSQLDTARDdata(NetCursor netCursor) |
private java.lang.String |
parseFastVCMorVCS() |
private void |
parseFDODSC(NetCursor cursor) |
(package private) NetSqlca |
parseFDODTA(NetCursor netCursor) |
protected void |
parseOpenQuery(StatementCallbackInterface statementI) |
(package private) void |
parseOpenQueryError(StatementCallbackInterface statementI) |
(package private) void |
parseOpenQueryFailure(StatementCallbackInterface statementI) |
private void |
parseOPNQFLRM(StatementCallbackInterface statement) |
private void |
parseOPNQRYreply(StatementCallbackInterface statementI)
Parse the reply for the Open Query Command.
|
protected NetResultSet |
parseOPNQRYRM(StatementCallbackInterface statementI,
boolean isOPNQRYreply)
Open Query Complete Reply Message indicates to the requester
that an OPNQRY or EXCSQLSTT command completed normally and that
the query process has been initiated.
|
protected Section |
parsePKGNAMCSN(boolean skip) |
private java.util.List<Section> |
parsePKGSNLST() |
(package private) void |
parsePrepareError(StatementCallbackInterface statement) |
private void |
parsePRPSQLSTTreply(StatementCallbackInterface statement) |
protected void |
parseQRYDSC(NetCursor cursor) |
protected void |
parseQRYDTA(NetResultSet netResultSet) |
private void |
parseQRYPOPRM() |
protected NetResultSet |
parseResultSetCursor(StatementCallbackInterface statementI,
Section section) |
protected void |
parseResultSetProcedure(StatementCallbackInterface statementI) |
private java.util.List<Section> |
parseRSLSETRM() |
protected ColumnMetaData |
parseSQLCINRD() |
(package private) ColumnMetaData |
parseSQLCINRDarray() |
private void |
parseSQLDAGRP(ColumnMetaData columnMetaData,
int columnNumber) |
protected NetSqlca |
parseSQLDARD(ColumnMetaData columnMetaData,
boolean skipBytes) |
(package private) NetSqlca |
parseSQLDARDarray(ColumnMetaData columnMetaData,
boolean skipBytes) |
private void |
parseSQLDAROW(ColumnMetaData columnMetaData,
int columnNumber) |
private void |
parseSQLDHGRP(ColumnMetaData columnMetaData) |
private void |
parseSQLDHROW(ColumnMetaData columnMetaData) |
private void |
parseSQLDOPTGRP(ColumnMetaData columnMetaData,
int columnNumber) |
private int |
parseSQLDTAGRPdataLabelsAndUpdateColumn(NetCursor cursor,
int columnIndex,
int tripletLength) |
protected NetSqlca |
parseSQLDTARD(NetSqldta netSqldta) |
private void |
parseSQLDTARDarray(NetCursor cursor,
boolean skipBytes) |
(package private) void |
parseSQLDTARDdata(NetCursor netCursor) |
private void |
parseSQLDXGRP(ColumnMetaData columnMetaData,
int column) |
private void |
parseSQLRSGRP(Section section) |
private int |
parseSQLRSLRD(java.util.List<Section> sections) |
private int |
parseSQLRSLRDarray(java.util.List<Section> sections) |
private void |
parseSQLRSROW(Section section) |
private void |
parseSQLUDTGRP(ColumnMetaData columnMetaData,
int columnNumber) |
private java.lang.String |
parseVCMorVCS() |
void |
readDescribeInput(PreparedStatementCallbackInterface preparedStatement) |
void |
readDescribeOutput(PreparedStatementCallbackInterface preparedStatement) |
void |
readExecute(PreparedStatementCallbackInterface preparedStatement) |
void |
readExecuteCall(StatementCallbackInterface statement) |
void |
readExecuteImmediate(StatementCallbackInterface statement) |
void |
readOpenQuery(StatementCallbackInterface statement) |
void |
readPrepare(StatementCallbackInterface statement) |
void |
readPrepareDescribeOutput(StatementCallbackInterface statement) |
void |
readSetSpecialRegister(StatementCallbackInterface statement) |
parseDTAMCHRM, parseRDBUPDRM, parseSqlErrorCondition, parseSQLERRRM
checkAndGetReceivedFlag, checkRequiredObjects, checkRequiredObjects, checkRequiredObjects, checkRequiredObjects, doDtamchrmSemantics, doObjnsprmSemantics, doPrccnvrmSemantics, doPrmnsprmSemantics, doValnsprmSemantics, doValnsprmSemantics, parseAbnormalEndUow, parseAbnormalEndUow, parseAbnormalEndUow, parseABNUOWRM, parseAccessRdbError, parseAccessSecurityError, parseCCSIDDBC, parseCCSIDMBC, parseCCSIDSBC, parseCMDCHKRM, parseCMDNSPRM, parseCODPNT, parseCODPNTDR, parseCommitError, parseCommonError, parseCRRTKN, parseENDUOWRM, parseExchangeServerAttributesError, parseEXTNAM, parseFastSQLNUMROW, parseFastSVRCOD, parseFastVCS, parseIndoubtList, parseInitialPBSD, parseMGRLVLN, parseOBJNSPRM, parsePBSD, parsePRCCNVCD, parsePRCCNVRM, parsePRDID, parseRdbAccessFailed, parseRDBNACRM, parseRDBNAM, parseRollbackError, parseSECCHKCD, parseSECMEC, parseSECTKN, parseSecurityCheckError, parseSQLCARD, parseSQLCARDrow, parseSQLDCTOKS, parseSQLNUMROW, parseSRVCLSNM, parseSRVNAM, parseSRVRLSLV, parseSVRCOD, parseSYNCCRD, parseSYNCCTLError, parseSYNCCTLreply, parseSYNCTYPE, parseSYNERRCD, parseSYNTAXRM, parseTYPDEFNAM, parseTYPDEFOVR, parseTypdefsOrMgrlvlovrs, parseUOWDSP, parseUSRID, parseVALNSPRM, parseXARETVAL, parseXID, parseXIDCNT, readAccessDatabase, readAccessSecurity, readCommitSubstitute, readExchangeServerAttributes, readLocalCommit, readLocalRollback, readLocalXACommit, readLocalXARollback, readLocalXAStart, readSecurityCheck, readXaCommit, readXaEndUnitOfWork, readXaForget, readXaPrepare, readXaRecover, readXaRollback, readXaStartUnitOfWork, resetRowsetSqlca
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, startSameIdChainParse
NetStatementReply(NetAgent netAgent, int bufferSize)
public void readPrepareDescribeOutput(StatementCallbackInterface statement) throws DisconnectException
readPrepareDescribeOutput
in interface StatementReplyInterface
DisconnectException
public void readExecuteImmediate(StatementCallbackInterface statement) throws DisconnectException
readExecuteImmediate
in interface StatementReplyInterface
DisconnectException
public void readOpenQuery(StatementCallbackInterface statement) throws DisconnectException
readOpenQuery
in interface StatementReplyInterface
DisconnectException
public void readExecute(PreparedStatementCallbackInterface preparedStatement) throws DisconnectException
readExecute
in interface StatementReplyInterface
DisconnectException
public void readPrepare(StatementCallbackInterface statement) throws DisconnectException
readPrepare
in interface StatementReplyInterface
DisconnectException
public void readDescribeInput(PreparedStatementCallbackInterface preparedStatement) throws DisconnectException
readDescribeInput
in interface StatementReplyInterface
DisconnectException
public void readDescribeOutput(PreparedStatementCallbackInterface preparedStatement) throws DisconnectException
readDescribeOutput
in interface StatementReplyInterface
DisconnectException
public void readExecuteCall(StatementCallbackInterface statement) throws DisconnectException
readExecuteCall
in interface StatementReplyInterface
DisconnectException
private void parsePRPSQLSTTreply(StatementCallbackInterface statement) throws DisconnectException
DisconnectException
private void parseDSCSQLSTTreply(PreparedStatementCallbackInterface ps, int metaDataType) throws DisconnectException
DisconnectException
private void parseEXCSQLIMMreply(StatementCallbackInterface statement) throws DisconnectException
DisconnectException
private void parseOPNQRYreply(StatementCallbackInterface statementI) throws DisconnectException
statementI
- statement to invoke callbacks onDisconnectException
private void parseEXCSQLSETreply(StatementCallbackInterface statement) throws DisconnectException
DisconnectException
private void parseEXCSQLSTTreply(StatementCallbackInterface statementI) throws DisconnectException
DisconnectException
protected void parseResultSetProcedure(StatementCallbackInterface statementI) throws DisconnectException
DisconnectException
protected NetResultSet parseResultSetCursor(StatementCallbackInterface statementI, Section section) throws DisconnectException
DisconnectException
protected void parseOpenQuery(StatementCallbackInterface statementI) throws DisconnectException
DisconnectException
protected void parseEndQuery(ResultSetCallbackInterface resultSetI) throws DisconnectException
DisconnectException
void parseOpenQueryFailure(StatementCallbackInterface statementI) throws DisconnectException
DisconnectException
void parsePrepareError(StatementCallbackInterface statement) throws DisconnectException
DisconnectException
void parseExecuteImmediateError(StatementCallbackInterface statement) throws DisconnectException
DisconnectException
void parseDescribeError(StatementCallbackInterface statement) throws DisconnectException
DisconnectException
void parseOpenQueryError(StatementCallbackInterface statementI) throws DisconnectException
DisconnectException
void parseExecuteError(StatementCallbackInterface statementI) throws DisconnectException
DisconnectException
void parseExecuteSetStatementError(StatementCallbackInterface statement) throws DisconnectException
DisconnectException
protected NetResultSet parseOPNQRYRM(StatementCallbackInterface statementI, boolean isOPNQRYreply) throws DisconnectException
When an EXCSQLSTT contains an SQL statement that invokes a stored procedure, and the procedure completes, an OPNQRYRM is returned for each answer set.
statementI
- statement callback interfaceisOPNQRYreply
- If true, parse a reply to an OPNQRY
command. Otherwise, parse a reply to an EXCSQLSTT command.NetResultSet
valueDisconnectException
protected void parseENDQRYRM(ResultSetCallbackInterface resultSetI) throws DisconnectException
DisconnectException
private void parseQRYPOPRM() throws DisconnectException
DisconnectException
private void parseOPNQFLRM(StatementCallbackInterface statement) throws DisconnectException
DisconnectException
private java.util.List<Section> parseRSLSETRM() throws DisconnectException
DisconnectException
protected NetSqlca parseSQLDTARD(NetSqldta netSqldta) throws DisconnectException
DisconnectException
protected void parseQRYDSC(NetCursor cursor) throws DisconnectException
DisconnectException
private void parseFDODSC(NetCursor cursor) throws DisconnectException
DisconnectException
private void parseSQLDTARDarray(NetCursor cursor, boolean skipBytes) throws DisconnectException
DisconnectException
private void checkPreviousSQLDTARDtriplet(int previousTripletType, int tripletType, int previousTripletId, int tripletId) throws DisconnectException
DisconnectException
private void checkFastRLO(int[][] rlo) throws DisconnectException
DisconnectException
private void descriptorErrorDetected() throws DisconnectException
DisconnectException
protected void parseQRYDTA(NetResultSet netResultSet) throws DisconnectException
DisconnectException
NetSqlca parseFDODTA(NetCursor netCursor) throws DisconnectException
DisconnectException
void parseFastSQLDTARDdata(NetCursor netCursor) throws DisconnectException
DisconnectException
void parseSQLDTARDdata(NetCursor netCursor) throws DisconnectException
DisconnectException
protected void copyEXTDTA(NetCursor netCursor) throws DisconnectException
DisconnectException
protected Section parsePKGNAMCSN(boolean skip) throws DisconnectException
DisconnectException
protected int parseFastQRYPRCTYP() throws DisconnectException
DisconnectException
protected int parseFastSQLCSRHLD() throws DisconnectException
DisconnectException
protected int parseFastQRYATTSCR() throws DisconnectException
DisconnectException
protected int parseFastQRYATTSET() throws DisconnectException
DisconnectException
protected int parseFastQRYATTSNS() throws DisconnectException
DisconnectException
protected int parseFastQRYATTUPD() throws DisconnectException
DisconnectException
private long parseFastQRYINSID() throws DisconnectException
DisconnectException
private java.util.List<Section> parsePKGSNLST() throws DisconnectException
DisconnectException
protected NetSqlca parseSQLDARD(ColumnMetaData columnMetaData, boolean skipBytes) throws DisconnectException
DisconnectException
private int parseSQLRSLRD(java.util.List<Section> sections) throws DisconnectException
DisconnectException
protected ColumnMetaData parseSQLCINRD() throws DisconnectException
DisconnectException
NetSqlca parseSQLDARDarray(ColumnMetaData columnMetaData, boolean skipBytes) throws DisconnectException
DisconnectException
private int parseSQLRSLRDarray(java.util.List<Section> sections) throws DisconnectException
DisconnectException
ColumnMetaData parseSQLCINRDarray() throws DisconnectException
DisconnectException
private void parseSQLDAROW(ColumnMetaData columnMetaData, int columnNumber) throws DisconnectException
DisconnectException
private void parseSQLDHROW(ColumnMetaData columnMetaData) throws DisconnectException
DisconnectException
private void parseSQLRSROW(Section section) throws DisconnectException
DisconnectException
private void parseSQLDAGRP(ColumnMetaData columnMetaData, int columnNumber) throws DisconnectException
DisconnectException
private void parseSQLUDTGRP(ColumnMetaData columnMetaData, int columnNumber) throws DisconnectException
DisconnectException
private void parseSQLDOPTGRP(ColumnMetaData columnMetaData, int columnNumber) throws DisconnectException
DisconnectException
private void parseSQLDXGRP(ColumnMetaData columnMetaData, int column) throws DisconnectException
DisconnectException
private void parseSQLDHGRP(ColumnMetaData columnMetaData) throws DisconnectException
DisconnectException
private void parseSQLRSGRP(Section section) throws DisconnectException
DisconnectException
private java.lang.String parseFastVCMorVCS() throws DisconnectException
DisconnectException
private java.lang.String parseVCMorVCS() throws DisconnectException
DisconnectException
private int calculateResultSetType(int qryattscr, int qryattsns, int defaultType)
private int calculateResultSetConcurrency(int qryattupd, int defaultConcurrency)
private int calculateResultSetHoldability(int sqlcsrhld)
private int parseSQLDTAGRPdataLabelsAndUpdateColumn(NetCursor cursor, int columnIndex, int tripletLength) throws DisconnectException
DisconnectException
public void readSetSpecialRegister(StatementCallbackInterface statement) throws DisconnectException
readSetSpecialRegister
in interface StatementReplyInterface
DisconnectException
Apache Derby V10.10 Internals - Copyright © 2004,2013 The Apache Software Foundation. All Rights Reserved.