Package 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
-
Field Summary
FieldsModifier and TypeFieldDescriptionFields inherited from class org.apache.derby.client.net.Request
buffer, netAgent_, passwordIncluded_, passwordLength_, passwordStart_
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate int[][]
allocateLidAndLengthsArray
(ColumnMetaData parameterMetaData) private void
buildDSCSQLSTT
(Section section, boolean sendTypsqlda, int typsqlda) private void
buildEXCSQLIMM
(Section section, boolean sendQryinsid, long qryinsid) private void
buildEXCSQLSET
(Section section) private void
buildEXCSQLSTT
(Section section, boolean sendOutexp, boolean outexp, boolean sendPrcnam, 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, Object[] inputRow, boolean chained) private void
buildFDODSC
(int numColumns, int[][] protocolTypesAndLengths, boolean overrideExists, Hashtable overrideMap, ArrayList overrideArray) private void
buildFDODTA
(int numVars, int[][] protocolTypesAndLengths, Object[] inputs) (package private) void
buildMAXBLKEXT
(int maxNumOfExtraBlocks) private void
buildMAXRSLCNT
(int maxResultSetCount) private void
buildMddOverrides
(ArrayList sdaOverrides) private void
buildOPNQRY
(Section section, boolean sendQueryRowSet, int fetchSize) private void
buildOUTEXP
(boolean outputExpected) protected void
buildOUTOVR
(ClientResultSet resultSet, ColumnMetaData resultSetMetaData) private int
buildPlaceholderLength
(long totalLength) private void
buildPRCNAM
(String prcnam) private void
buildPRPSQLSTT
(Section section, String sql, boolean sendRtnsqlda, boolean sendTypsqlda, int typsqlda) (package private) void
private void
Build QRYCLSIMP (Query Close Implicit).(package private) void
buildQRYINSID
(long qryinsid) (package private) void
buildQRYROWSET
(int fetchSize) private void
private void
buildRSLSETFLG
(int resultSetFlag) private void
private void
buildSQLCADTA
(int numColumns, int[][] lidAndLengthOverrides) private void
buildSQLDTA
(int numColumns, int[][] lidAndLengthOverrides, boolean overrideExists, Hashtable overrideMap, ArrayList overrideArray) private boolean
buildSQLDTAcommandData
(int numInputColumns, ColumnMetaData parameterMetaData, Object[] inputRow) private void
buildSQLDTAGRP
(int numVars, int[][] lidAndLengthOverrides, boolean mddRequired, Hashtable overrideMap) private void
buildSQLDTARD
(int numColumns, int[][] lidAndLengthOverrides) private void
buildTYPSQLDA
(int typeSqlda) private int
calculateColumnsInSQLDTAGRPtriplet
(int numVars) private int[][]
calculateOUTOVRLidAndLengthOverrides
(ClientResultSet resultSet, ColumnMetaData resultSetMetaData) private int
private int
checkFetchsize
(int fetchSize, int resultSetType) private boolean
checkSendQryrowset
(int fetchSize, int resultSetType) private Hashtable
computeProtocolTypesAndLengths
(Object[] inputRow, ColumnMetaData parameterMetaData, int[][] lidAndLengths, Hashtable overrideMap) private 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, Object[] inputs, int numInputColumns, boolean outputExpected, boolean chained) void
writeExecuteCall
(NetStatement materialStatement, boolean outputExpected, String procedureName, Section section, int fetchSize, boolean suppressResultSets, int resultSetType, ColumnMetaData parameterMetaData, Object[] inputs) void
writeExecuteImmediate
(NetStatement materialStatement, String sql, Section section) void
writeOpenQuery
(NetPreparedStatement materialPreparedStatement, Section section, int fetchSize, int resultSetType, int numInputColumns, ColumnMetaData parameterMetaData, Object[] inputs) void
writeOpenQuery
(NetStatement materialStatement, Section section, int fetchSize, int resultSetType) void
writePrepare
(NetStatement materialStatement, String sql, Section section) void
writePrepareDescribeOutput
(NetStatement materialStatement, String sql, Section section) void
writeSetSpecialRegister
(Section section, ArrayList sqlsttList) Methods inherited from class org.apache.derby.client.net.NetPackageRequest
buildPKGNAMCSN, buildSQLATTRcommandData, buildSQLSTTcommandData, encryptDataStream
Methods inherited from class org.apache.derby.client.net.NetConnectionRequest
buildSYNCCTLCommit, buildSYNCCTLMigrate, buildSYNCCTLRollback, writeAccessDatabase, writeAccessSecurity, writeCommitSubstitute, 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, createCommand, createCommandData, createEncryptedCommandData, flush, initialize, markForCachingPKGNAMCSN, markLengthBytes, popMarkForCachingPKGNAMCSN, setCorrelationID, setDssLengthLocation, updateLengthBytes, write1Byte, write2Bytes, write4Bytes, writeBigDecimal, writeBoolean, writeBytes, writeBytes, writeCodePoint4Bytes, writeDate, writeDouble, writeFloat, writeInt, writeIntFdocaData, writeLDBytes, writeLengthCodePoint, writeLidAndLengths, writeLong, writeLong6Bytes, writeLongFdocaData, writeScalar1Byte, writeScalar2Bytes, writeScalar4Bytes, writeScalar8Bytes, writeScalarBytes, writeScalarBytes, writeScalarPaddedBytes, writeScalarStream, writeScalarStream, writeScalarStream, writeScalarStream, writeScalarString, writeScalarString, writeShort, writeShortFdocaData, writeSingleorMixedCcsidLDString, writeTime, writeTimestamp, writeUDT
-
Field Details
-
extdtaPositions_
-
promototedParameters_
-
-
Constructor Details
-
NetStatementRequest
NetStatementRequest(NetAgent netAgent, int bufferSize)
-
-
Method Details
-
writeExecuteImmediate
public void writeExecuteImmediate(NetStatement materialStatement, String sql, Section section) throws SqlException - Specified by:
writeExecuteImmediate
in interfaceStatementRequestInterface
- Throws:
SqlException
-
writePrepareDescribeOutput
public void writePrepareDescribeOutput(NetStatement materialStatement, String sql, Section section) throws SqlException - Specified by:
writePrepareDescribeOutput
in interfaceStatementRequestInterface
- Throws:
SqlException
-
writePrepare
public void writePrepare(NetStatement materialStatement, String sql, Section section) throws SqlException - Specified by:
writePrepare
in interfaceStatementRequestInterface
- Throws:
SqlException
-
writeExecute
public void writeExecute(NetPreparedStatement materialPreparedStatement, Section section, ColumnMetaData parameterMetaData, Object[] inputs, int numInputColumns, boolean outputExpected, boolean chained) throws SqlException - Specified by:
writeExecute
in interfaceStatementRequestInterface
- Throws:
SqlException
-
writeOpenQuery
public void writeOpenQuery(NetPreparedStatement materialPreparedStatement, Section section, int fetchSize, int resultSetType, int numInputColumns, ColumnMetaData parameterMetaData, Object[] inputs) throws SqlException - Specified by:
writeOpenQuery
in interfaceStatementRequestInterface
- Throws:
SqlException
-
writeOpenQuery
public void writeOpenQuery(NetStatement materialStatement, Section section, int fetchSize, int resultSetType) throws SqlException - Specified by:
writeOpenQuery
in interfaceStatementRequestInterface
- Throws:
SqlException
-
writeDescribeInput
public void writeDescribeInput(NetPreparedStatement materialPreparedStatement, Section section) throws SqlException - Specified by:
writeDescribeInput
in interfaceStatementRequestInterface
- Throws:
SqlException
-
writeDescribeOutput
public void writeDescribeOutput(NetPreparedStatement materialPreparedStatement, Section section) throws SqlException - Specified by:
writeDescribeOutput
in interfaceStatementRequestInterface
- Throws:
SqlException
-
writeExecuteCall
public void writeExecuteCall(NetStatement materialStatement, boolean outputExpected, String procedureName, Section section, int fetchSize, boolean suppressResultSets, int resultSetType, ColumnMetaData parameterMetaData, Object[] inputs) throws SqlException - Specified by:
writeExecuteCall
in interfaceStatementRequestInterface
- Throws:
SqlException
-
buildOPNQRY
private void buildOPNQRY(Section section, boolean sendQueryRowSet, int fetchSize) throws SqlException - Throws:
SqlException
-
buildEXCSQLIMM
private void buildEXCSQLIMM(Section section, boolean sendQryinsid, long qryinsid) throws SqlException - Throws:
SqlException
-
buildPRPSQLSTT
private void buildPRPSQLSTT(Section section, String sql, boolean sendRtnsqlda, boolean sendTypsqlda, int typsqlda) throws SqlException - Throws:
SqlException
-
buildEXCSQLSET
- Throws:
SqlException
-
buildEXCSQLSTT
private void buildEXCSQLSTT(Section section, boolean sendOutexp, boolean outexp, boolean sendPrcnam, 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
private void buildDSCSQLSTT(Section section, boolean sendTypsqlda, int typsqlda) throws SqlException - Throws:
SqlException
-
buildSQLDTAcommandData
private boolean buildSQLDTAcommandData(int numInputColumns, ColumnMetaData parameterMetaData, Object[] inputRow) throws SqlException - Throws:
SqlException
-
buildFDODSC
private void buildFDODSC(int numColumns, int[][] protocolTypesAndLengths, boolean overrideExists, Hashtable overrideMap, ArrayList overrideArray) throws SqlException - Throws:
SqlException
-
buildSQLDTA
private void buildSQLDTA(int numColumns, int[][] lidAndLengthOverrides, boolean overrideExists, Hashtable overrideMap, ArrayList overrideArray) throws SqlException - Throws:
SqlException
-
buildSQLDTAGRP
private void buildSQLDTAGRP(int numVars, int[][] lidAndLengthOverrides, boolean mddRequired, Hashtable overrideMap) throws SqlException - Throws:
SqlException
-
buildOUTOVR
protected void buildOUTOVR(ClientResultSet resultSet, ColumnMetaData resultSetMetaData) throws SqlException - Throws:
SqlException
-
calculateOUTOVRLidAndLengthOverrides
private int[][] calculateOUTOVRLidAndLengthOverrides(ClientResultSet resultSet, ColumnMetaData resultSetMetaData) -
buildSQLDTARD
- Throws:
SqlException
-
buildSQLCADTA
- Throws:
SqlException
-
buildFDODTA
private void buildFDODTA(int numVars, int[][] protocolTypesAndLengths, Object[] inputs) throws SqlException - Throws:
SqlException
-
buildEXTDTA
private void buildEXTDTA(ColumnMetaData parameterMetaData, Object[] inputRow, boolean chained) throws SqlException - Throws:
SqlException
-
retrievePromotedParameterIfExists
-
calculateColumnsInSQLDTAGRPtriplet
private int calculateColumnsInSQLDTAGRPtriplet(int numVars) -
computeProtocolTypesAndLengths
private Hashtable computeProtocolTypesAndLengths(Object[] inputRow, ColumnMetaData parameterMetaData, int[][] lidAndLengths, Hashtable overrideMap) throws SqlException - Throws:
SqlException
-
buildPlaceholderLength
private int buildPlaceholderLength(long totalLength) -
buildOUTEXP
- Throws:
SqlException
-
buildMAXBLKEXT
- Throws:
SqlException
-
buildQRYROWSET
- Throws:
SqlException
-
buildPRCNAM
- Throws:
SqlException
-
buildQRYBLKSZ
- Throws:
SqlException
-
buildMAXRSLCNT
- Throws:
SqlException
-
buildRDBCMTOK
- Throws:
SqlException
-
buildRSLSETFLG
- Throws:
SqlException
-
buildQRYINSID
- Throws:
SqlException
-
buildRTNSQLDA
- Throws:
SqlException
-
buildTYPSQLDA
- 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
- Throws:
SqlException
-
checkSendQryrowset
private boolean checkSendQryrowset(int fetchSize, int resultSetType) -
checkFetchsize
private int checkFetchsize(int fetchSize, int resultSetType) -
calculateResultSetFlags
private int calculateResultSetFlags() -
writeSetSpecialRegister
- Specified by:
writeSetSpecialRegister
in interfaceStatementRequestInterface
- Throws:
SqlException
-
allocateLidAndLengthsArray
-
buildMddOverrides
- Throws:
SqlException
-
setFDODTALob
private void setFDODTALob(int securityMechanism, Lob lob, int[][] protocolTypesAndLengths, int i) throws SqlException, SQLException - Throws:
SqlException
SQLException
-