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
-
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 -
Method Summary
Modifier and TypeMethodDescriptionprivate 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
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
private void
private int
private int
private int
private int
private long
private int
private int
private void
parseFastSQLDTARDdata
(NetCursor netCursor) private String
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 void
parsePrepareError
(StatementCallbackInterface statement) private void
parsePRPSQLSTTreply
(StatementCallbackInterface statement) private void
parseQRYDSC
(NetCursor cursor) (package private) void
parseQRYDTA
(NetResultSet netResultSet) private void
private NetResultSet
parseResultSetCursor
(StatementCallbackInterface statementI, Section section) private void
parseResultSetProcedure
(StatementCallbackInterface statementI) private ColumnMetaData
private ColumnMetaData
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
(List<Section> sections) private int
parseSQLRSLRDarray
(List<Section> sections) private void
parseSQLRSROW
(Section section) private void
parseSQLUDTGRP
(ColumnMetaData columnMetaData, int columnNumber) private String
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
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 Details
-
NetStatementReply
NetStatementReply(NetAgent netAgent, int bufferSize)
-
-
Method Details
-
readPrepareDescribeOutput
public void readPrepareDescribeOutput(StatementCallbackInterface statement) throws DisconnectException - Specified by:
readPrepareDescribeOutput
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readExecuteImmediate
- Specified by:
readExecuteImmediate
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readOpenQuery
- Specified by:
readOpenQuery
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readExecute
public void readExecute(PreparedStatementCallbackInterface preparedStatement) throws DisconnectException - Specified by:
readExecute
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
readPrepare
- 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
- Specified by:
readExecuteCall
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-
parsePRPSQLSTTreply
- Throws:
DisconnectException
-
parseDSCSQLSTTreply
private void parseDSCSQLSTTreply(PreparedStatementCallbackInterface ps, int metaDataType) throws DisconnectException - Throws:
DisconnectException
-
parseEXCSQLIMMreply
- Throws:
DisconnectException
-
parseOPNQRYreply
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
- Throws:
DisconnectException
-
parseEXCSQLSTTreply
- 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
- Throws:
DisconnectException
-
parseEndQuery
- Throws:
DisconnectException
-
parseOpenQueryFailure
private void parseOpenQueryFailure(StatementCallbackInterface statementI) throws DisconnectException - Throws:
DisconnectException
-
parsePrepareError
- Throws:
DisconnectException
-
parseExecuteImmediateError
private void parseExecuteImmediateError(StatementCallbackInterface statement) throws DisconnectException - Throws:
DisconnectException
-
parseDescribeError
- Throws:
DisconnectException
-
parseOpenQueryError
- Throws:
DisconnectException
-
parseExecuteError
- 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
- Throws:
DisconnectException
-
parseQRYPOPRM
- Throws:
DisconnectException
-
parseOPNQFLRM
- Throws:
DisconnectException
-
parseRSLSETRM
- Throws:
DisconnectException
-
parseSQLDTARD
- Throws:
DisconnectException
-
parseQRYDSC
- Throws:
DisconnectException
-
parseFDODSC
- Throws:
DisconnectException
-
parseSQLDTARDarray
- Throws:
DisconnectException
-
checkPreviousSQLDTARDtriplet
private void checkPreviousSQLDTARDtriplet(int previousTripletType, int tripletType, int previousTripletId, int tripletId) throws DisconnectException - Throws:
DisconnectException
-
checkFastRLO
- Throws:
DisconnectException
-
descriptorErrorDetected
- Throws:
DisconnectException
-
parseQRYDTA
- Throws:
DisconnectException
-
parseFDODTA
- Throws:
DisconnectException
-
parseFastSQLDTARDdata
- Throws:
DisconnectException
-
parseSQLDTARDdata
- Throws:
DisconnectException
-
copyEXTDTA
- Throws:
DisconnectException
-
parsePKGNAMCSN
- Throws:
DisconnectException
-
parseFastQRYPRCTYP
- Throws:
DisconnectException
-
parseFastSQLCSRHLD
- Throws:
DisconnectException
-
parseFastQRYATTSCR
- Throws:
DisconnectException
-
parseFastQRYATTSET
- Throws:
DisconnectException
-
parseFastQRYATTSNS
- Throws:
DisconnectException
-
parseFastQRYATTUPD
- Throws:
DisconnectException
-
parseFastQRYINSID
- Throws:
DisconnectException
-
parsePKGSNLST
- Throws:
DisconnectException
-
parseSQLDARD
private NetSqlca parseSQLDARD(ColumnMetaData columnMetaData, boolean skipBytes) throws DisconnectException - Throws:
DisconnectException
-
parseSQLRSLRD
- Throws:
DisconnectException
-
parseSQLCINRD
- Throws:
DisconnectException
-
parseSQLDARDarray
private NetSqlca parseSQLDARDarray(ColumnMetaData columnMetaData, boolean skipBytes) throws DisconnectException - Throws:
DisconnectException
-
parseSQLRSLRDarray
- Throws:
DisconnectException
-
parseSQLCINRDarray
- Throws:
DisconnectException
-
parseSQLDAROW
private void parseSQLDAROW(ColumnMetaData columnMetaData, int columnNumber) throws DisconnectException - Throws:
DisconnectException
-
parseSQLDHROW
- Throws:
DisconnectException
-
parseSQLRSROW
- 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
- Throws:
DisconnectException
-
parseSQLDHGRP
- Throws:
DisconnectException
-
parseSQLRSGRP
- Throws:
DisconnectException
-
parseFastVCMorVCS
- Throws:
DisconnectException
-
parseVCMorVCS
- 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
- Specified by:
readSetSpecialRegister
in interfaceStatementReplyInterface
- Throws:
DisconnectException
-