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

Field Summary

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_

Constructor Summary

Constructors

Constructor and Description
NetStatementReply(NetAgent netAgent, int bufferSize)

Method Summary

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)

Methods inherited from class org.apache.derby.client.net.NetPackageReply

parseDTAMCHRM, parseRDBUPDRM, parseSqlErrorCondition, parseSQLERRRM

Methods inherited from class org.apache.derby.client.net.NetConnectionReply

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

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

Constructor Detail

NetStatementReply

NetStatementReply(NetAgent netAgent,
                  int bufferSize)

Method Detail

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

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

private java.util.List<Section> 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 Section parsePKGNAMCSN(boolean skip)
                          throws DisconnectException

Throws:

DisconnectException

parseFastQRYPRCTYP

protected int parseFastQRYPRCTYP()
                          throws DisconnectException

Throws:

DisconnectException

parseFastSQLCSRHLD

protected int parseFastSQLCSRHLD()
                          throws DisconnectException

Throws:

DisconnectException

parseFastQRYATTSCR

protected int parseFastQRYATTSCR()
                          throws DisconnectException

Throws:

DisconnectException

parseFastQRYATTSET

protected int parseFastQRYATTSET()
                          throws DisconnectException

Throws:

DisconnectException

parseFastQRYATTSNS

protected int parseFastQRYATTSNS()
                          throws DisconnectException

Throws:

DisconnectException

parseFastQRYATTUPD

protected 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

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

Throws:

DisconnectException

parseSQLRSLRD

private int parseSQLRSLRD(java.util.List<Section> sections)
                   throws DisconnectException

Throws:

DisconnectException

parseSQLCINRD

protected ColumnMetaData parseSQLCINRD()
                                throws DisconnectException

Throws:

DisconnectException

parseSQLDARDarray

NetSqlca parseSQLDARDarray(ColumnMetaData columnMetaData,
                           boolean skipBytes)
                    throws DisconnectException

Throws:

DisconnectException

parseSQLRSLRDarray

private int parseSQLRSLRDarray(java.util.List<Section> sections)
                        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

readSetSpecialRegister

public void readSetSpecialRegister(StatementCallbackInterface statement)
                            throws DisconnectException

Specified by:

readSetSpecialRegister in interface StatementReplyInterface

Throws:

DisconnectException