org.apache.derby.client.net
Class NetStatementReply
java.lang.Object
org.apache.derby.client.net.Reply
org.apache.derby.client.net.NetConnectionReply
org.apache.derby.client.net.NetPackageReply
org.apache.derby.client.net.NetStatementReply
- All Implemented Interfaces:
- ConnectionReplyInterface, StatementReplyInterface
- Direct Known Subclasses:
- NetResultSetReply
public class NetStatementReply
- extends NetPackageReply
- implements StatementReplyInterface
Fields inherited from class org.apache.derby.client.net.Reply |
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_ |
Method Summary |
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 java.lang.Object |
parsePKGNAMCSN(boolean skip)
|
protected java.util.ArrayList |
parsePKGSNLST()
|
(package private) void |
parsePrepareError(StatementCallbackInterface statement)
|
private void |
parsePRPSQLSTTreply(StatementCallbackInterface statement)
|
protected int |
parseQRYATTSCR()
|
protected int |
parseQRYATTSET()
|
protected int |
parseQRYATTSNS()
|
protected int |
parseQRYATTUPD()
|
protected void |
parseQRYDSC(NetCursor cursor)
|
protected void |
parseQRYDTA(NetResultSet netResultSet)
|
private void |
parseQRYPOPRM()
|
protected int |
parseQRYPRCTYP()
|
protected NetResultSet |
parseResultSetCursor(StatementCallbackInterface statementI,
Section section)
|
protected void |
parseResultSetProcedure(StatementCallbackInterface statementI)
|
protected java.util.ArrayList |
parseRSLSETRM()
|
protected ColumnMetaData |
parseSQLCINRD()
|
(package private) ColumnMetaData |
parseSQLCINRDarray()
|
protected int |
parseSQLCSRHLD()
|
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)
|
protected int |
parseSQLRSLRD(java.util.ArrayList sectionAL)
|
(package private) int |
parseSQLRSLRDarray(java.util.ArrayList sectionAL)
|
private void |
parseSQLRSROW(Section section)
|
private java.lang.String |
parseSQLSTT()
|
private java.lang.String |
parseSQLSTTGRP()
|
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)
|
Methods inherited from class org.apache.derby.client.net.NetConnectionReply |
checkAndGetReceivedFlag, checkRequiredObjects, checkRequiredObjects, 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, parseConnectError, parseCRRTKN, parseENDUOWRM, parseExchangeServerAttributesError, parseEXTNAM, parseFastSQLNUMROW, parseFastSVRCOD, parseFastVCS, parseIndoubtList, 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, readDummyExchangeServerAttributes, readExchangeServerAttributes, readLocalCommit, readLocalRollback, readLocalXACommit, readLocalXARollback, readLocalXAStart, readSecurityCheck, readXaCommit, readXaEndUnitOfWork, readXaForget, readXaPrepare, readXaRecover, readXaRollback, readXaStartUnitOfWork, resetRowsetSqlca, verifyConnectReply |
Methods inherited from class org.apache.derby.client.net.Reply |
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
NetStatementReply
NetStatementReply(NetAgent netAgent,
int bufferSize)
readPrepareDescribeOutput
public void readPrepareDescribeOutput(StatementCallbackInterface statement)
throws DisconnectException
- Specified by:
readPrepareDescribeOutput
in interface StatementReplyInterface
- Throws:
DisconnectException
readExecuteImmediate
public void readExecuteImmediate(StatementCallbackInterface statement)
throws DisconnectException
- Specified by:
readExecuteImmediate
in interface StatementReplyInterface
- Throws:
DisconnectException
readOpenQuery
public void readOpenQuery(StatementCallbackInterface statement)
throws DisconnectException
- Specified by:
readOpenQuery
in interface StatementReplyInterface
- Throws:
DisconnectException
readExecute
public void readExecute(PreparedStatementCallbackInterface preparedStatement)
throws DisconnectException
- Specified by:
readExecute
in interface StatementReplyInterface
- Throws:
DisconnectException
readPrepare
public void readPrepare(StatementCallbackInterface statement)
throws DisconnectException
- Specified by:
readPrepare
in interface StatementReplyInterface
- Throws:
DisconnectException
readDescribeInput
public void readDescribeInput(PreparedStatementCallbackInterface preparedStatement)
throws DisconnectException
- Specified by:
readDescribeInput
in interface StatementReplyInterface
- Throws:
DisconnectException
readDescribeOutput
public void readDescribeOutput(PreparedStatementCallbackInterface preparedStatement)
throws DisconnectException
- Specified by:
readDescribeOutput
in interface StatementReplyInterface
- Throws:
DisconnectException
readExecuteCall
public void readExecuteCall(StatementCallbackInterface statement)
throws DisconnectException
- Specified by:
readExecuteCall
in interface StatementReplyInterface
- Throws:
DisconnectException
parsePRPSQLSTTreply
private void parsePRPSQLSTTreply(StatementCallbackInterface statement)
throws DisconnectException
- Throws:
DisconnectException
parseDSCSQLSTTreply
private void parseDSCSQLSTTreply(PreparedStatementCallbackInterface ps,
int metaDataType)
throws DisconnectException
- Throws:
DisconnectException
parseEXCSQLIMMreply
private void parseEXCSQLIMMreply(StatementCallbackInterface statement)
throws DisconnectException
- Throws:
DisconnectException
parseOPNQRYreply
private void parseOPNQRYreply(StatementCallbackInterface statementI)
throws DisconnectException
- Parse the reply for the Open Query Command. This method handles the
parsing of all command replies and reply data for the opnqry command.
will be replaced by parseOPNQRYreply (see parseOPNQRYreplyProto)
- Parameters:
statementI
- statement to invoke callbacks on
- Throws:
DisconnectException
parseEXCSQLSETreply
private void parseEXCSQLSETreply(StatementCallbackInterface statement)
throws DisconnectException
- Throws:
DisconnectException
parseEXCSQLSTTreply
private void parseEXCSQLSTTreply(StatementCallbackInterface statementI)
throws DisconnectException
- Throws:
DisconnectException
parseResultSetProcedure
protected void parseResultSetProcedure(StatementCallbackInterface statementI)
throws DisconnectException
- Throws:
DisconnectException
parseResultSetCursor
protected NetResultSet parseResultSetCursor(StatementCallbackInterface statementI,
Section section)
throws DisconnectException
- Throws:
DisconnectException
parseOpenQuery
protected void parseOpenQuery(StatementCallbackInterface statementI)
throws DisconnectException
- Throws:
DisconnectException
parseEndQuery
protected void parseEndQuery(ResultSetCallbackInterface resultSetI)
throws DisconnectException
- Throws:
DisconnectException
parseOpenQueryFailure
void parseOpenQueryFailure(StatementCallbackInterface statementI)
throws DisconnectException
- Throws:
DisconnectException
parsePrepareError
void parsePrepareError(StatementCallbackInterface statement)
throws DisconnectException
- Throws:
DisconnectException
parseExecuteImmediateError
void parseExecuteImmediateError(StatementCallbackInterface statement)
throws DisconnectException
- Throws:
DisconnectException
parseDescribeError
void parseDescribeError(StatementCallbackInterface statement)
throws DisconnectException
- Throws:
DisconnectException
parseOpenQueryError
void parseOpenQueryError(StatementCallbackInterface statementI)
throws DisconnectException
- Throws:
DisconnectException
parseExecuteError
void parseExecuteError(StatementCallbackInterface statementI)
throws DisconnectException
- Throws:
DisconnectException
parseExecuteSetStatementError
void parseExecuteSetStatementError(StatementCallbackInterface statement)
throws DisconnectException
- Throws:
DisconnectException
parseOPNQRYRM
protected NetResultSet parseOPNQRYRM(StatementCallbackInterface statementI,
boolean isOPNQRYreply)
throws DisconnectException
- 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. It also indicates the
type of query protocol and cursor used for the query.
When an EXCSQLSTT contains an SQL statement that invokes a
stored procedure, and the procedure completes, an OPNQRYRM is
returned for each answer set.
- Parameters:
statementI
- statement callback interfaceisOPNQRYreply
- If true, parse a reply to an OPNQRY
command. Otherwise, parse a reply to an EXCSQLSTT command.
- Returns:
- a
NetResultSet
value
- Throws:
DisconnectException
parseENDQRYRM
protected void parseENDQRYRM(ResultSetCallbackInterface resultSetI)
throws DisconnectException
- Throws:
DisconnectException
parseQRYPOPRM
private void parseQRYPOPRM()
throws DisconnectException
- Throws:
DisconnectException
parseOPNQFLRM
private void parseOPNQFLRM(StatementCallbackInterface statement)
throws DisconnectException
- Throws:
DisconnectException
parseRSLSETRM
protected java.util.ArrayList parseRSLSETRM()
throws DisconnectException
- Throws:
DisconnectException
parseSQLDTARD
protected NetSqlca parseSQLDTARD(NetSqldta netSqldta)
throws DisconnectException
- Throws:
DisconnectException
parseQRYDSC
protected void parseQRYDSC(NetCursor cursor)
throws DisconnectException
- Throws:
DisconnectException
parseFDODSC
private void parseFDODSC(NetCursor cursor)
throws DisconnectException
- Throws:
DisconnectException
parseSQLDTARDarray
private void parseSQLDTARDarray(NetCursor cursor,
boolean skipBytes)
throws DisconnectException
- Throws:
DisconnectException
checkPreviousSQLDTARDtriplet
private void checkPreviousSQLDTARDtriplet(int previousTripletType,
int tripletType,
int previousTripletId,
int tripletId)
throws DisconnectException
- Throws:
DisconnectException
checkFastRLO
private void checkFastRLO(int[][] rlo)
throws DisconnectException
- Throws:
DisconnectException
descriptorErrorDetected
private void descriptorErrorDetected()
throws DisconnectException
- Throws:
DisconnectException
parseQRYDTA
protected void parseQRYDTA(NetResultSet netResultSet)
throws DisconnectException
- Throws:
DisconnectException
parseFDODTA
NetSqlca parseFDODTA(NetCursor netCursor)
throws DisconnectException
- Throws:
DisconnectException
parseFastSQLDTARDdata
void parseFastSQLDTARDdata(NetCursor netCursor)
throws DisconnectException
- Throws:
DisconnectException
parseSQLDTARDdata
void parseSQLDTARDdata(NetCursor netCursor)
throws DisconnectException
- Throws:
DisconnectException
copyEXTDTA
protected void copyEXTDTA(NetCursor netCursor)
throws DisconnectException
- Throws:
DisconnectException
parsePKGNAMCSN
protected java.lang.Object parsePKGNAMCSN(boolean skip)
throws DisconnectException
- Throws:
DisconnectException
parseQRYPRCTYP
protected int parseQRYPRCTYP()
throws DisconnectException
- Throws:
DisconnectException
parseFastQRYPRCTYP
protected int parseFastQRYPRCTYP()
throws DisconnectException
- Throws:
DisconnectException
parseSQLCSRHLD
protected int parseSQLCSRHLD()
throws DisconnectException
- Throws:
DisconnectException
parseFastSQLCSRHLD
protected int parseFastSQLCSRHLD()
throws DisconnectException
- Throws:
DisconnectException
parseQRYATTSCR
protected int parseQRYATTSCR()
throws DisconnectException
- Throws:
DisconnectException
parseFastQRYATTSCR
protected int parseFastQRYATTSCR()
throws DisconnectException
- Throws:
DisconnectException
parseQRYATTSET
protected int parseQRYATTSET()
throws DisconnectException
- Throws:
DisconnectException
parseFastQRYATTSET
protected int parseFastQRYATTSET()
throws DisconnectException
- Throws:
DisconnectException
parseQRYATTSNS
protected int parseQRYATTSNS()
throws DisconnectException
- Throws:
DisconnectException
parseFastQRYATTSNS
protected int parseFastQRYATTSNS()
throws DisconnectException
- Throws:
DisconnectException
parseQRYATTUPD
protected int parseQRYATTUPD()
throws DisconnectException
- Throws:
DisconnectException
parseFastQRYATTUPD
protected int parseFastQRYATTUPD()
throws DisconnectException
- Throws:
DisconnectException
parseFastQRYINSID
private long parseFastQRYINSID()
throws DisconnectException
- Throws:
DisconnectException
parsePKGSNLST
protected java.util.ArrayList parsePKGSNLST()
throws DisconnectException
- Throws:
DisconnectException
parseSQLDARD
protected NetSqlca parseSQLDARD(ColumnMetaData columnMetaData,
boolean skipBytes)
throws DisconnectException
- Throws:
DisconnectException
parseSQLRSLRD
protected int parseSQLRSLRD(java.util.ArrayList sectionAL)
throws DisconnectException
- Throws:
DisconnectException
parseSQLCINRD
protected ColumnMetaData parseSQLCINRD()
throws DisconnectException
- Throws:
DisconnectException
parseSQLDARDarray
NetSqlca parseSQLDARDarray(ColumnMetaData columnMetaData,
boolean skipBytes)
throws DisconnectException
- Throws:
DisconnectException
parseSQLRSLRDarray
int parseSQLRSLRDarray(java.util.ArrayList sectionAL)
throws DisconnectException
- Throws:
DisconnectException
parseSQLCINRDarray
ColumnMetaData parseSQLCINRDarray()
throws DisconnectException
- Throws:
DisconnectException
parseSQLDAROW
private void parseSQLDAROW(ColumnMetaData columnMetaData,
int columnNumber)
throws DisconnectException
- Throws:
DisconnectException
parseSQLDHROW
private void parseSQLDHROW(ColumnMetaData columnMetaData)
throws DisconnectException
- Throws:
DisconnectException
parseSQLRSROW
private void parseSQLRSROW(Section section)
throws DisconnectException
- Throws:
DisconnectException
parseSQLDAGRP
private void parseSQLDAGRP(ColumnMetaData columnMetaData,
int columnNumber)
throws DisconnectException
- Throws:
DisconnectException
parseSQLUDTGRP
private void parseSQLUDTGRP(ColumnMetaData columnMetaData,
int columnNumber)
throws DisconnectException
- Throws:
DisconnectException
parseSQLDOPTGRP
private void parseSQLDOPTGRP(ColumnMetaData columnMetaData,
int columnNumber)
throws DisconnectException
- Throws:
DisconnectException
parseSQLDXGRP
private void parseSQLDXGRP(ColumnMetaData columnMetaData,
int column)
throws DisconnectException
- Throws:
DisconnectException
parseSQLDHGRP
private void parseSQLDHGRP(ColumnMetaData columnMetaData)
throws DisconnectException
- Throws:
DisconnectException
parseSQLRSGRP
private void parseSQLRSGRP(Section section)
throws DisconnectException
- Throws:
DisconnectException
parseFastVCMorVCS
private java.lang.String parseFastVCMorVCS()
throws DisconnectException
- Throws:
DisconnectException
parseVCMorVCS
private java.lang.String parseVCMorVCS()
throws DisconnectException
- Throws:
DisconnectException
calculateResultSetType
private int calculateResultSetType(int qryattscr,
int qryattsns,
int defaultType)
calculateResultSetConcurrency
private int calculateResultSetConcurrency(int qryattupd,
int defaultConcurrency)
calculateResultSetHoldability
private int calculateResultSetHoldability(int sqlcsrhld)
parseSQLDTAGRPdataLabelsAndUpdateColumn
private int parseSQLDTAGRPdataLabelsAndUpdateColumn(NetCursor cursor,
int columnIndex,
int tripletLength)
throws DisconnectException
- Throws:
DisconnectException
parseSQLSTT
private java.lang.String parseSQLSTT()
throws DisconnectException
- Throws:
DisconnectException
parseSQLSTTGRP
private java.lang.String parseSQLSTTGRP()
throws DisconnectException
- Throws:
DisconnectException
readSetSpecialRegister
public void readSetSpecialRegister(StatementCallbackInterface statement)
throws DisconnectException
- Specified by:
readSetSpecialRegister
in interface StatementReplyInterface
- Throws:
DisconnectException
Apache Derby V10.6 Internals - Copyright © 2004,2007 The Apache Software Foundation. All Rights Reserved.