org.apache.derby.client.net
Class NetStatementRequest

java.lang.Object
  extended by org.apache.derby.client.net.Request
      extended by org.apache.derby.client.net.NetConnectionRequest
          extended by org.apache.derby.client.net.NetPackageRequest
              extended by org.apache.derby.client.net.NetStatementRequest
All Implemented Interfaces:
ConnectionRequestInterface, StatementRequestInterface
Direct Known Subclasses:
NetResultSetRequest

public class NetStatementRequest
extends NetPackageRequest
implements StatementRequestInterface


Field Summary
(package private)  java.util.ArrayList extdtaPositions_
           
(package private)  int overrideLid_
           
(package private)  java.util.HashMap promototedParameters_
           
 
Fields inherited from class org.apache.derby.client.net.NetPackageRequest
collectionName, COLLECTIONNAME
 
Fields inherited from class org.apache.derby.client.net.Request
bytes_, ccsidManager_, netAgent_, offset_, passwordIncluded_, passwordLength_, passwordStart_
 
Constructor Summary
NetStatementRequest(NetAgent netAgent, CcsidManager ccsidManager, int bufferSize)
           
 
Method Summary
private  int[][] allocateLidAndLengthsArray(ColumnMetaData parameterMetaData)
           
(package private)  void buildDSCSQLSTT(Section section, boolean sendTypsqlda, int typsqlda)
           
(package private)  void buildEXCSQLIMM(Section section, boolean sendQryinsid, long qryinsid)
           
(package private)  void buildEXCSQLSET(Section section)
           
(package private)  void buildEXCSQLSTT(Section section, boolean sendOutexp, boolean outexp, boolean sendPrcnam, java.lang.String prcnam, boolean sendQryblksz, boolean sendMaxrslcnt, int maxrslcnt, boolean sendMaxblkext, int maxblkext, boolean sendRslsetflg, int resultSetFlag, boolean sendQryrowset, int qryrowset)
           
private  void buildEXTDTA(ColumnMetaData parameterMetaData, java.lang.Object[] inputRow, boolean chained)
           
private  void buildFDODSC(int numColumns, int[][] protocolTypesAndLengths, boolean overrideExists, java.util.Hashtable overrideMap, java.util.ArrayList overrideArray)
           
private  void buildFDODTA(int numVars, int[][] protocolTypesAndLengths, java.lang.Object[] inputs)
           
(package private)  void buildMAXBLKEXT(int maxNumOfExtraBlocks)
           
private  void buildMAXRSLCNT(int maxResultSetCount)
           
private  void buildMddOverrides(java.util.ArrayList sdaOverrides)
           
(package private)  void buildOPNQRY(Section section, boolean sendQueryRowSet, int fetchSize)
           
private  void buildOUTEXP(boolean outputExpected)
           
protected  void buildOUTOVR(ResultSet resultSet, ColumnMetaData resultSetMetaData)
           
private  int buildPlaceholderLength(long totalLength)
           
private  void buildPRCNAM(java.lang.String prcnam)
           
(package private)  void buildPRPSQLSTT(Section section, java.lang.String sql, boolean sendRtnsqlda, boolean sendTypsqlda, int typsqlda)
           
(package private)  void buildQRYBLKSZ()
           
private  void buildQRYCLSIMP()
          Build QRYCLSIMP (Query Close Implicit).
(package private)  void buildQRYINSID(long qryinsid)
           
(package private)  void buildQRYROWSET(int fetchSize)
           
private  void buildRDBCMTOK()
           
private  void buildRSLSETFLG(int resultSetFlag)
           
private  void buildRTNSQLDA()
           
protected  void buildSQLCADTA(int numColumns, int[][] lidAndLengthOverrides)
           
protected  void buildSQLDTA(int numColumns, int[][] lidAndLengthOverrides, boolean overrideExists, java.util.Hashtable overrideMap, java.util.ArrayList overrideArray)
           
(package private)  boolean buildSQLDTAcommandData(int numInputColumns, ColumnMetaData parameterMetaData, java.lang.Object[] inputRow)
           
protected  void buildSQLDTAGRP(int numVars, int[][] lidAndLengthOverrides, boolean mddRequired, java.util.Hashtable overrideMap)
           
protected  void buildSQLDTARD(int numColumns, int[][] lidAndLengthOverrides)
           
private  void buildTYPSQLDA(int typeSqlda)
           
private  int calculateColumnsInSQLDTAGRPtriplet(int numVars)
           
private  int[][] calculateOUTOVRLidAndLengthOverrides(ResultSet resultSet, ColumnMetaData resultSetMetaData)
           
private  int calculateResultSetFlags()
           
private  int checkFetchsize(int fetchSize, int resultSetType)
           
private  boolean checkSendQryrowset(int fetchSize, int resultSetType)
           
private  java.util.Hashtable computeProtocolTypesAndLengths(java.lang.Object[] inputRow, ColumnMetaData parameterMetaData, int[][] lidAndLengths, java.util.Hashtable overrideMap)
           
private  int getNextOverrideLid()
           
private  java.lang.Object retrievePromotedParameterIfExists(int index)
           
private  void setFDODTALob(int securityMechanism, Lob lob, int[][] protocolTypesAndLengths, int i)
           
private  void setFDODTALobLength(int[][] protocolTypesAndLengths, int i, long dataLength)
           
private  void setFDODTALobLengthUnknown(int i)
           
 void writeDescribeInput(NetPreparedStatement materialPreparedStatement, Section section)
           
 void writeDescribeOutput(NetPreparedStatement materialPreparedStatement, Section section)
           
 void writeExecute(NetPreparedStatement materialPreparedStatement, Section section, ColumnMetaData parameterMetaData, java.lang.Object[] inputs, int numInputColumns, boolean outputExpected, boolean chained)
           
 void writeExecuteCall(NetStatement materialStatement, boolean outputExpected, java.lang.String procedureName, Section section, int fetchSize, boolean suppressResultSets, int resultSetType, ColumnMetaData parameterMetaData, java.lang.Object[] inputs)
           
 void writeExecuteImmediate(NetStatement materialStatement, java.lang.String sql, Section section)
           
 void writeOpenQuery(NetPreparedStatement materialPreparedStatement, Section section, int fetchSize, int resultSetType, int numInputColumns, ColumnMetaData parameterMetaData, java.lang.Object[] inputs)
           
 void writeOpenQuery(NetStatement materialStatement, Section section, int fetchSize, int resultSetType)
           
 void writePrepare(NetStatement materialStatement, java.lang.String sql, Section section)
           
 void writePrepareDescribeOutput(NetStatement materialStatement, java.lang.String sql, Section section)
           
 void writeSetSpecialRegister(Section section, java.util.ArrayList sqlsttList)
           
 
Methods inherited from class org.apache.derby.client.net.NetPackageRequest
buildCommonPKGNAMinfo, buildPKGNAMCSN, buildSQLATTRcommandData, buildSQLSTTcommandData, encryptDataStream
 
Methods inherited from class org.apache.derby.client.net.NetConnectionRequest
buildACCRDB, buildACCSEC, buildDummyEXCSAT, buildEXCSAT, buildRDBCMM, buildRDBRLLBCK, buildSECCHK, buildSYNCCTLCommit, buildSYNCCTLMigrate, buildSYNCCTLRollback, buildTYPDEFOVR, writeAccessDatabase, writeAccessSecurity, writeCommitSubstitute, writeDummyExchangeServerAttributes, writeExchangeServerAttributes, writeForget, writeLocalCommit, writeLocalRollback, writeLocalXACommit, writeLocalXARollback, writeLocalXAStart, writeNullXID, writeReleaseConversation, writeSecurityCheck, writeSYNCType, writeXaCommit, writeXaEndUnitOfWork, writeXAFlags, writeXaForget, writeXaPrepare, writeXaRecover, writeXaRollback, writeXaStartUnitOfWork, writeXATimeout, writeXID
 
Methods inherited from class org.apache.derby.client.net.Request
buildTripletHeader, clearBuffer, createCommand, createCommandData, createEncryptedCommandData, createXACommand, doesRequestContainData, ensureLength, finalizeDssLength, finalizePreviousChainedDss, flush, flushExistingDSS, flushScalarStreamSegment, flushScalarStreamSegment, initialize, markForCachingPKGNAMCSN, markLengthBytes, maskOutPassword, padBytes, padScalarStreamForError, popMarkForCachingPKGNAMCSN, prepScalarStream, sendBytes, setCcsidMgr, setCorrelationID, setDssLengthLocation, updateLengthBytes, write1Byte, write2Bytes, write4Bytes, writeBigDecimal, writeBoolean, writeByte, writeBytes, writeBytes, writeCodePoint4Bytes, writeDate, writeDDMString, writeDouble, writeFloat, writeInt, writeIntFdocaData, writeLDBytes, writeLengthCodePoint, writeLidAndLengths, writeLidAndLengths, writeLong, writeLong6Bytes, writeLongFdocaData, writeScalar1Byte, writeScalar2Bytes, writeScalar4Bytes, writeScalar8Bytes, writeScalarBytes, writeScalarBytes, writeScalarBytes, writeScalarHeader, writeScalarPaddedBytes, writeScalarPaddedBytes, writeScalarPaddedString, writeScalarStream, writeScalarStream, writeScalarStream, writeScalarStream, writeScalarString, writeScalarString, writeShort, writeShortFdocaData, writeSingleorMixedCcsidLDString, writeTime, writeTimestamp, writeUDT
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

extdtaPositions_

java.util.ArrayList extdtaPositions_

overrideLid_

int overrideLid_

promototedParameters_

java.util.HashMap promototedParameters_
Constructor Detail

NetStatementRequest

NetStatementRequest(NetAgent netAgent,
                    CcsidManager ccsidManager,
                    int bufferSize)
Method Detail

writeExecuteImmediate

public void writeExecuteImmediate(NetStatement materialStatement,
                                  java.lang.String sql,
                                  Section section)
                           throws SqlException
Specified by:
writeExecuteImmediate in interface StatementRequestInterface
Throws:
SqlException

writePrepareDescribeOutput

public void writePrepareDescribeOutput(NetStatement materialStatement,
                                       java.lang.String sql,
                                       Section section)
                                throws SqlException
Specified by:
writePrepareDescribeOutput in interface StatementRequestInterface
Throws:
SqlException

writePrepare

public void writePrepare(NetStatement materialStatement,
                         java.lang.String sql,
                         Section section)
                  throws SqlException
Specified by:
writePrepare in interface StatementRequestInterface
Throws:
SqlException

writeExecute

public void writeExecute(NetPreparedStatement materialPreparedStatement,
                         Section section,
                         ColumnMetaData parameterMetaData,
                         java.lang.Object[] inputs,
                         int numInputColumns,
                         boolean outputExpected,
                         boolean chained)
                  throws SqlException
Specified by:
writeExecute in interface StatementRequestInterface
Throws:
SqlException

writeOpenQuery

public void writeOpenQuery(NetPreparedStatement materialPreparedStatement,
                           Section section,
                           int fetchSize,
                           int resultSetType,
                           int numInputColumns,
                           ColumnMetaData parameterMetaData,
                           java.lang.Object[] inputs)
                    throws SqlException
Specified by:
writeOpenQuery in interface StatementRequestInterface
Throws:
SqlException

writeOpenQuery

public void writeOpenQuery(NetStatement materialStatement,
                           Section section,
                           int fetchSize,
                           int resultSetType)
                    throws SqlException
Specified by:
writeOpenQuery in interface StatementRequestInterface
Throws:
SqlException

writeDescribeInput

public void writeDescribeInput(NetPreparedStatement materialPreparedStatement,
                               Section section)
                        throws SqlException
Specified by:
writeDescribeInput in interface StatementRequestInterface
Throws:
SqlException

writeDescribeOutput

public void writeDescribeOutput(NetPreparedStatement materialPreparedStatement,
                                Section section)
                         throws SqlException
Specified by:
writeDescribeOutput in interface StatementRequestInterface
Throws:
SqlException

writeExecuteCall

public void writeExecuteCall(NetStatement materialStatement,
                             boolean outputExpected,
                             java.lang.String procedureName,
                             Section section,
                             int fetchSize,
                             boolean suppressResultSets,
                             int resultSetType,
                             ColumnMetaData parameterMetaData,
                             java.lang.Object[] inputs)
                      throws SqlException
Specified by:
writeExecuteCall in interface StatementRequestInterface
Throws:
SqlException

buildOPNQRY

void buildOPNQRY(Section section,
                 boolean sendQueryRowSet,
                 int fetchSize)
           throws SqlException
Throws:
SqlException

buildEXCSQLIMM

void buildEXCSQLIMM(Section section,
                    boolean sendQryinsid,
                    long qryinsid)
              throws SqlException
Throws:
SqlException

buildPRPSQLSTT

void buildPRPSQLSTT(Section section,
                    java.lang.String sql,
                    boolean sendRtnsqlda,
                    boolean sendTypsqlda,
                    int typsqlda)
              throws SqlException
Throws:
SqlException

buildEXCSQLSET

void buildEXCSQLSET(Section section)
              throws SqlException
Throws:
SqlException

buildEXCSQLSTT

void buildEXCSQLSTT(Section section,
                    boolean sendOutexp,
                    boolean outexp,
                    boolean sendPrcnam,
                    java.lang.String prcnam,
                    boolean sendQryblksz,
                    boolean sendMaxrslcnt,
                    int maxrslcnt,
                    boolean sendMaxblkext,
                    int maxblkext,
                    boolean sendRslsetflg,
                    int resultSetFlag,
                    boolean sendQryrowset,
                    int qryrowset)
              throws SqlException
Throws:
SqlException

buildDSCSQLSTT

void buildDSCSQLSTT(Section section,
                    boolean sendTypsqlda,
                    int typsqlda)
              throws SqlException
Throws:
SqlException

buildSQLDTAcommandData

boolean buildSQLDTAcommandData(int numInputColumns,
                               ColumnMetaData parameterMetaData,
                               java.lang.Object[] inputRow)
                         throws SqlException
Throws:
SqlException

buildFDODSC

private void buildFDODSC(int numColumns,
                         int[][] protocolTypesAndLengths,
                         boolean overrideExists,
                         java.util.Hashtable overrideMap,
                         java.util.ArrayList overrideArray)
                  throws SqlException
Throws:
SqlException

buildSQLDTA

protected void buildSQLDTA(int numColumns,
                           int[][] lidAndLengthOverrides,
                           boolean overrideExists,
                           java.util.Hashtable overrideMap,
                           java.util.ArrayList overrideArray)
                    throws SqlException
Throws:
SqlException

buildSQLDTAGRP

protected void buildSQLDTAGRP(int numVars,
                              int[][] lidAndLengthOverrides,
                              boolean mddRequired,
                              java.util.Hashtable overrideMap)
                       throws SqlException
Throws:
SqlException

buildOUTOVR

protected void buildOUTOVR(ResultSet resultSet,
                           ColumnMetaData resultSetMetaData)
                    throws SqlException
Throws:
SqlException

calculateOUTOVRLidAndLengthOverrides

private int[][] calculateOUTOVRLidAndLengthOverrides(ResultSet resultSet,
                                                     ColumnMetaData resultSetMetaData)

buildSQLDTARD

protected void buildSQLDTARD(int numColumns,
                             int[][] lidAndLengthOverrides)
                      throws SqlException
Throws:
SqlException

buildSQLCADTA

protected void buildSQLCADTA(int numColumns,
                             int[][] lidAndLengthOverrides)
                      throws SqlException
Throws:
SqlException

buildFDODTA

private void buildFDODTA(int numVars,
                         int[][] protocolTypesAndLengths,
                         java.lang.Object[] inputs)
                  throws SqlException
Throws:
SqlException

buildEXTDTA

private void buildEXTDTA(ColumnMetaData parameterMetaData,
                         java.lang.Object[] inputRow,
                         boolean chained)
                  throws SqlException
Throws:
SqlException

retrievePromotedParameterIfExists

private java.lang.Object retrievePromotedParameterIfExists(int index)

calculateColumnsInSQLDTAGRPtriplet

private int calculateColumnsInSQLDTAGRPtriplet(int numVars)

computeProtocolTypesAndLengths

private java.util.Hashtable computeProtocolTypesAndLengths(java.lang.Object[] inputRow,
                                                           ColumnMetaData parameterMetaData,
                                                           int[][] lidAndLengths,
                                                           java.util.Hashtable overrideMap)
                                                    throws SqlException
Throws:
SqlException

buildPlaceholderLength

private int buildPlaceholderLength(long totalLength)

buildOUTEXP

private void buildOUTEXP(boolean outputExpected)
                  throws SqlException
Throws:
SqlException

buildMAXBLKEXT

void buildMAXBLKEXT(int maxNumOfExtraBlocks)
              throws SqlException
Throws:
SqlException

buildQRYROWSET

void buildQRYROWSET(int fetchSize)
              throws SqlException
Throws:
SqlException

buildPRCNAM

private void buildPRCNAM(java.lang.String prcnam)
                  throws SqlException
Throws:
SqlException

buildQRYBLKSZ

void buildQRYBLKSZ()
             throws SqlException
Throws:
SqlException

buildMAXRSLCNT

private void buildMAXRSLCNT(int maxResultSetCount)
                     throws SqlException
Throws:
SqlException

buildRDBCMTOK

private void buildRDBCMTOK()
                    throws SqlException
Throws:
SqlException

buildRSLSETFLG

private void buildRSLSETFLG(int resultSetFlag)
                     throws SqlException
Throws:
SqlException

buildQRYINSID

void buildQRYINSID(long qryinsid)
             throws SqlException
Throws:
SqlException

buildRTNSQLDA

private void buildRTNSQLDA()
                    throws SqlException
Throws:
SqlException

buildTYPSQLDA

private void buildTYPSQLDA(int typeSqlda)
                    throws SqlException
Throws:
SqlException

buildQRYCLSIMP

private void buildQRYCLSIMP()
Build QRYCLSIMP (Query Close Implicit). Query Close Implicit controls whether the target server implicitly closes a non-scrollable query upon end of data (SQLSTATE 02000).


setFDODTALobLength

private void setFDODTALobLength(int[][] protocolTypesAndLengths,
                                int i,
                                long dataLength)
                         throws SqlException
Throws:
SqlException

setFDODTALobLengthUnknown

private void setFDODTALobLengthUnknown(int i)
                                throws SqlException
Throws:
SqlException

checkSendQryrowset

private boolean checkSendQryrowset(int fetchSize,
                                   int resultSetType)

checkFetchsize

private int checkFetchsize(int fetchSize,
                           int resultSetType)

calculateResultSetFlags

private int calculateResultSetFlags()

writeSetSpecialRegister

public void writeSetSpecialRegister(Section section,
                                    java.util.ArrayList sqlsttList)
                             throws SqlException
Specified by:
writeSetSpecialRegister in interface StatementRequestInterface
Throws:
SqlException

allocateLidAndLengthsArray

private int[][] allocateLidAndLengthsArray(ColumnMetaData parameterMetaData)

buildMddOverrides

private void buildMddOverrides(java.util.ArrayList sdaOverrides)
                        throws SqlException
Throws:
SqlException

getNextOverrideLid

private int getNextOverrideLid()

setFDODTALob

private void setFDODTALob(int securityMechanism,
                          Lob lob,
                          int[][] protocolTypesAndLengths,
                          int i)
                   throws SqlException,
                          java.sql.SQLException
Throws:
SqlException
java.sql.SQLException

Built on Thu 2010-12-23 20:49:13+0000, from revision ???

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