org.apache.derby.client.net
Class NetStatementRequest
java.lang.Object
org.apache.derby.client.net.Request
org.apache.derby.client.net.NetConnectionRequest
org.apache.derby.client.net.NetPackageRequest
org.apache.derby.client.net.NetStatementRequest
- All Implemented Interfaces:
- ConnectionRequestInterface, StatementRequestInterface
- Direct Known Subclasses:
- NetResultSetRequest
public class NetStatementRequest
- extends NetPackageRequest
- implements StatementRequestInterface
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.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 |
extdtaPositions_
java.util.ArrayList extdtaPositions_
overrideLid_
int overrideLid_
promototedParameters_
java.util.HashMap promototedParameters_
NetStatementRequest
NetStatementRequest(NetAgent netAgent,
CcsidManager ccsidManager,
int bufferSize)
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
Apache Derby V10.6 Internals - Copyright © 2004,2007 The Apache Software Foundation. All Rights Reserved.