Package 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
class NetStatementReply extends NetPackageReply implements StatementReplyInterface
-
-
Field Summary
-
Fields inherited from class org.apache.derby.client.net.Reply
agent_, buffer_, count_, DEFAULT_BUFFER_SIZE, dssLength_, END_OF_COLLECTION, END_OF_SAME_ID_CHAIN, ensuredLengthForDecryption_, longBufferForDecryption_, longCountForDecryption_, longPosForDecryption_, longValueForDecryption_, netAgent_, peekedLength_, pos_
-
-
Constructor Summary
Constructors Constructor Description NetStatementReply(NetAgent netAgent, int bufferSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
(package private) void
copyEXTDTA(NetCursor netCursor)
private void
descriptorErrorDetected()
private void
parseDescribeError(StatementCallbackInterface statement)
private void
parseDSCSQLSTTreply(PreparedStatementCallbackInterface ps, int metaDataType)
private void
parseENDQRYRM(ResultSetCallbackInterface resultSetI)
(package private) void
parseEndQuery(ResultSetCallbackInterface resultSetI)
private void
parseEXCSQLIMMreply(StatementCallbackInterface statement)
private void
parseEXCSQLSETreply(StatementCallbackInterface statement)
private void
parseEXCSQLSTTreply(StatementCallbackInterface statementI)
private void
parseExecuteError(StatementCallbackInterface statementI)
private void
parseExecuteImmediateError(StatementCallbackInterface statement)
private void
parseExecuteSetStatementError(StatementCallbackInterface statement)
private int
parseFastQRYATTSCR()
private int
parseFastQRYATTSET()
private int
parseFastQRYATTSNS()
private int
parseFastQRYATTUPD()
private long
parseFastQRYINSID()
private int
parseFastQRYPRCTYP()
private int
parseFastSQLCSRHLD()
private void
parseFastSQLDTARDdata(NetCursor netCursor)
private java.lang.String
parseFastVCMorVCS()
private void
parseFDODSC(NetCursor cursor)
private NetSqlca
parseFDODTA(NetCursor netCursor)
private void
parseOpenQuery(StatementCallbackInterface statementI)
private void
parseOpenQueryError(StatementCallbackInterface statementI)
private void
parseOpenQueryFailure(StatementCallbackInterface statementI)
private void
parseOPNQFLRM(StatementCallbackInterface statement)
private void
parseOPNQRYreply(StatementCallbackInterface statementI)
Parse the reply for the Open Query Command.private 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.(package private) Section
parsePKGNAMCSN(boolean skip)
private java.util.List<Section>
parsePKGSNLST()
private void
parsePrepareError(StatementCallbackInterface statement)
private void
parsePRPSQLSTTreply(StatementCallbackInterface statement)
private void
parseQRYDSC(NetCursor cursor)
(package private) void
parseQRYDTA(NetResultSet netResultSet)
private void
parseQRYPOPRM()
private NetResultSet
parseResultSetCursor(StatementCallbackInterface statementI, Section section)
private void
parseResultSetProcedure(StatementCallbackInterface statementI)
private java.util.List<Section>
parseRSLSETRM()
private ColumnMetaData
parseSQLCINRD()
private ColumnMetaData
parseSQLCINRDarray()
private void
parseSQLDAGRP(ColumnMetaData columnMetaData, int columnNumber)
private NetSqlca
parseSQLDARD(ColumnMetaData columnMetaData, boolean skipBytes)
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)
private NetSqlca
parseSQLDTARD(NetSqldta netSqldta)
private void
parseSQLDTARDarray(NetCursor cursor, boolean skipBytes)
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)
-
Methods inherited from class org.apache.derby.client.net.NetPackageReply
parseDTAMCHRM, parseRDBUPDRM, parseSqlErrorCondition
-
Methods inherited from class org.apache.derby.client.net.NetConnectionReply
checkAndGetReceivedFlag, checkRequiredObjects, checkRequiredObjects, checkRequiredObjects, doDtamchrmSemantics, doPrmnsprmSemantics, doValnsprmSemantics, parseAbnormalEndUow, parseAbnormalEndUow, parseCMDCHKRM, parseCMDNSPRM, parseCommonError, parseENDUOWRM, parseFastSQLNUMROW, parseFastSVRCOD, parseFastVCS, parseIndoubtList, parseOBJNSPRM, parsePBSD, parseRDBNACRM, parseRDBNAM, parseSQLCARD, parseSQLCARDrow, parseSQLNUMROW, parseSVRCOD, parseSYNCCRD, parseSYNCCTLError, parseSYNCCTLreply, parseSYNCTYPE, parseTypdefsOrMgrlvlovrs, parseXARETVAL, parseXID, parseXIDCNT, readAccessDatabase, readAccessSecurity, readCommitSubstitute, readExchangeServerAttributes, readLocalCommit, readLocalRollback, readLocalXACommit, readLocalXARollback, readLocalXAStart, readSecurityCheck, readXaCommit, readXaEndUnitOfWork, readXaForget, readXaPrepare, readXaRecover, readXaRollback, readXaStartUnitOfWork
-
Methods inherited from class org.apache.derby.client.net.Reply
adjustDdmLength, 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, startSameIdChainParse
-
-
-
-
Constructor Detail
-
NetStatementReply
NetStatementReply(NetAgent netAgent, int bufferSize)
-
-
Method Detail
-
readPrepareDescribeOutput
public void readPrepareDescribeOutput(StatementCallbackInterface statement) throws DisconnectException
- Specified by:
readPrepareDescribeOutput
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readExecuteImmediate
public void readExecuteImmediate(StatementCallbackInterface statement) throws DisconnectException
- Specified by:
readExecuteImmediate
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readOpenQuery
public void readOpenQuery(StatementCallbackInterface statement) throws DisconnectException
- Specified by:
readOpenQuery
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readExecute
public void readExecute(PreparedStatementCallbackInterface preparedStatement) throws DisconnectException
- Specified by:
readExecute
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readPrepare
public void readPrepare(StatementCallbackInterface statement) throws DisconnectException
- Specified by:
readPrepare
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readDescribeInput
public void readDescribeInput(PreparedStatementCallbackInterface preparedStatement) throws DisconnectException
- Specified by:
readDescribeInput
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readDescribeOutput
public void readDescribeOutput(PreparedStatementCallbackInterface preparedStatement) throws DisconnectException
- Specified by:
readDescribeOutput
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readExecuteCall
public void readExecuteCall(StatementCallbackInterface statement) throws DisconnectException
- Specified by:
readExecuteCall
in interfaceStatementReplyInterface
- 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
private void parseResultSetProcedure(StatementCallbackInterface statementI) throws DisconnectException
- Throws:
DisconnectException
-
parseResultSetCursor
private NetResultSet parseResultSetCursor(StatementCallbackInterface statementI, Section section) throws DisconnectException
- Throws:
DisconnectException
-
parseOpenQuery
private void parseOpenQuery(StatementCallbackInterface statementI) throws DisconnectException
- Throws:
DisconnectException
-
parseEndQuery
void parseEndQuery(ResultSetCallbackInterface resultSetI) throws DisconnectException
- Throws:
DisconnectException
-
parseOpenQueryFailure
private void parseOpenQueryFailure(StatementCallbackInterface statementI) throws DisconnectException
- Throws:
DisconnectException
-
parsePrepareError
private void parsePrepareError(StatementCallbackInterface statement) throws DisconnectException
- Throws:
DisconnectException
-
parseExecuteImmediateError
private void parseExecuteImmediateError(StatementCallbackInterface statement) throws DisconnectException
- Throws:
DisconnectException
-
parseDescribeError
private void parseDescribeError(StatementCallbackInterface statement) throws DisconnectException
- Throws:
DisconnectException
-
parseOpenQueryError
private void parseOpenQueryError(StatementCallbackInterface statementI) throws DisconnectException
- Throws:
DisconnectException
-
parseExecuteError
private void parseExecuteError(StatementCallbackInterface statementI) throws DisconnectException
- Throws:
DisconnectException
-
parseExecuteSetStatementError
private void parseExecuteSetStatementError(StatementCallbackInterface statement) throws DisconnectException
- Throws:
DisconnectException
-
parseOPNQRYRM
private 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
private 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
private java.util.List<Section> parseRSLSETRM() throws DisconnectException
- Throws:
DisconnectException
-
parseSQLDTARD
private NetSqlca parseSQLDTARD(NetSqldta netSqldta) throws DisconnectException
- Throws:
DisconnectException
-
parseQRYDSC
private 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
void parseQRYDTA(NetResultSet netResultSet) throws DisconnectException
- Throws:
DisconnectException
-
parseFDODTA
private NetSqlca parseFDODTA(NetCursor netCursor) throws DisconnectException
- Throws:
DisconnectException
-
parseFastSQLDTARDdata
private void parseFastSQLDTARDdata(NetCursor netCursor) throws DisconnectException
- Throws:
DisconnectException
-
parseSQLDTARDdata
private void parseSQLDTARDdata(NetCursor netCursor) throws DisconnectException
- Throws:
DisconnectException
-
copyEXTDTA
void copyEXTDTA(NetCursor netCursor) throws DisconnectException
- Throws:
DisconnectException
-
parsePKGNAMCSN
Section parsePKGNAMCSN(boolean skip) throws DisconnectException
- Throws:
DisconnectException
-
parseFastQRYPRCTYP
private int parseFastQRYPRCTYP() throws DisconnectException
- Throws:
DisconnectException
-
parseFastSQLCSRHLD
private int parseFastSQLCSRHLD() throws DisconnectException
- Throws:
DisconnectException
-
parseFastQRYATTSCR
private int parseFastQRYATTSCR() throws DisconnectException
- Throws:
DisconnectException
-
parseFastQRYATTSET
private int parseFastQRYATTSET() throws DisconnectException
- Throws:
DisconnectException
-
parseFastQRYATTSNS
private int parseFastQRYATTSNS() throws DisconnectException
- Throws:
DisconnectException
-
parseFastQRYATTUPD
private int parseFastQRYATTUPD() throws DisconnectException
- Throws:
DisconnectException
-
parseFastQRYINSID
private long parseFastQRYINSID() throws DisconnectException
- Throws:
DisconnectException
-
parsePKGSNLST
private java.util.List<Section> parsePKGSNLST() throws DisconnectException
- Throws:
DisconnectException
-
parseSQLDARD
private NetSqlca parseSQLDARD(ColumnMetaData columnMetaData, boolean skipBytes) throws DisconnectException
- Throws:
DisconnectException
-
parseSQLRSLRD
private int parseSQLRSLRD(java.util.List<Section> sections) throws DisconnectException
- Throws:
DisconnectException
-
parseSQLCINRD
private ColumnMetaData parseSQLCINRD() throws DisconnectException
- Throws:
DisconnectException
-
parseSQLDARDarray
private NetSqlca parseSQLDARDarray(ColumnMetaData columnMetaData, boolean skipBytes) throws DisconnectException
- Throws:
DisconnectException
-
parseSQLRSLRDarray
private int parseSQLRSLRDarray(java.util.List<Section> sections) throws DisconnectException
- Throws:
DisconnectException
-
parseSQLCINRDarray
private 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
-
readSetSpecialRegister
public void readSetSpecialRegister(StatementCallbackInterface statement) throws DisconnectException
- Specified by:
readSetSpecialRegister
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
-