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 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

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 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 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 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(List<Section> sections)
private int	parseSQLRSLRDarray(List<Section> sections)
private void	parseSQLRSROW(Section section)
private void	parseSQLUDTGRP(ColumnMetaData columnMetaData, int columnNumber)
private 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 NetPackageReply

parseDTAMCHRM, parseRDBUPDRM, parseSqlErrorCondition

Methods inherited from class 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 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

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NetStatementReply

NetStatementReply(NetAgent netAgent,
 int bufferSize)

Method Details

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

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 interface

isOPNQRYreply - 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 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 List<Section> parsePKGSNLST()
                             throws DisconnectException

Throws:

DisconnectException

parseSQLDARD

private NetSqlca parseSQLDARD(ColumnMetaData columnMetaData,
 boolean skipBytes)
                       throws DisconnectException

Throws:

DisconnectException

parseSQLRSLRD

private int parseSQLRSLRD(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(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 String parseFastVCMorVCS()
                          throws DisconnectException

Throws:

DisconnectException

parseVCMorVCS

private 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 interface StatementReplyInterface

Throws:

DisconnectException