org.apache.derby.client.net
Class NetStatementReply

java.lang.Object
  extended by org.apache.derby.client.net.Reply
      extended by org.apache.derby.client.net.NetConnectionReply
          extended by org.apache.derby.client.net.NetPackageReply
              extended by 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
NetStatementReply(NetAgent netAgent, int bufferSize)
           
 
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.NetPackageReply
parseDTAMCHRM, parsePKGNAMCT, parseRDBUPDRM, parseSqlErrorCondition, parseSQLERRRM
 
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
 

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

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

Built on Thu 2012-03-29 21:53:33+0000, from revision ???

Apache Derby V10.6 Internals - Copyright © 2004,2007 The Apache Software Foundation. All Rights Reserved.