class NetStatementRequest extends NetPackageRequest implements StatementRequestInterface
Modifier and Type | Field and Description |
---|---|
private java.util.ArrayList<java.lang.Integer> |
extdtaPositions_ |
private java.util.HashMap<java.lang.Integer,java.lang.Object> |
promototedParameters_ |
buffer, netAgent_, passwordIncluded_, passwordLength_, passwordStart_
Constructor and Description |
---|
NetStatementRequest(NetAgent netAgent,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
private 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,
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) |
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(java.lang.String prcnam) |
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() |
private void |
buildSQLCADTA(int numColumns,
int[][] lidAndLengthOverrides) |
private void |
buildSQLDTA(int numColumns,
int[][] lidAndLengthOverrides,
boolean overrideExists,
java.util.Hashtable overrideMap,
java.util.ArrayList overrideArray) |
private boolean |
buildSQLDTAcommandData(int numInputColumns,
ColumnMetaData parameterMetaData,
java.lang.Object[] inputRow) |
private void |
buildSQLDTAGRP(int numVars,
int[][] lidAndLengthOverrides,
boolean mddRequired,
java.util.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 |
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 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) |
buildPKGNAMCSN, buildSQLATTRcommandData, buildSQLSTTcommandData, encryptDataStream
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
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
private java.util.ArrayList<java.lang.Integer> extdtaPositions_
private final java.util.HashMap<java.lang.Integer,java.lang.Object> promototedParameters_
NetStatementRequest(NetAgent netAgent, int bufferSize)
public void writeExecuteImmediate(NetStatement materialStatement, java.lang.String sql, Section section) throws SqlException
writeExecuteImmediate
in interface StatementRequestInterface
SqlException
public void writePrepareDescribeOutput(NetStatement materialStatement, java.lang.String sql, Section section) throws SqlException
writePrepareDescribeOutput
in interface StatementRequestInterface
SqlException
public void writePrepare(NetStatement materialStatement, java.lang.String sql, Section section) throws SqlException
writePrepare
in interface StatementRequestInterface
SqlException
public void writeExecute(NetPreparedStatement materialPreparedStatement, Section section, ColumnMetaData parameterMetaData, java.lang.Object[] inputs, int numInputColumns, boolean outputExpected, boolean chained) throws SqlException
writeExecute
in interface StatementRequestInterface
SqlException
public void writeOpenQuery(NetPreparedStatement materialPreparedStatement, Section section, int fetchSize, int resultSetType, int numInputColumns, ColumnMetaData parameterMetaData, java.lang.Object[] inputs) throws SqlException
writeOpenQuery
in interface StatementRequestInterface
SqlException
public void writeOpenQuery(NetStatement materialStatement, Section section, int fetchSize, int resultSetType) throws SqlException
writeOpenQuery
in interface StatementRequestInterface
SqlException
public void writeDescribeInput(NetPreparedStatement materialPreparedStatement, Section section) throws SqlException
writeDescribeInput
in interface StatementRequestInterface
SqlException
public void writeDescribeOutput(NetPreparedStatement materialPreparedStatement, Section section) throws SqlException
writeDescribeOutput
in interface StatementRequestInterface
SqlException
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
writeExecuteCall
in interface StatementRequestInterface
SqlException
private void buildOPNQRY(Section section, boolean sendQueryRowSet, int fetchSize) throws SqlException
SqlException
private void buildEXCSQLIMM(Section section, boolean sendQryinsid, long qryinsid) throws SqlException
SqlException
private void buildPRPSQLSTT(Section section, java.lang.String sql, boolean sendRtnsqlda, boolean sendTypsqlda, int typsqlda) throws SqlException
SqlException
private void buildEXCSQLSET(Section section) throws SqlException
SqlException
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) throws SqlException
SqlException
private void buildDSCSQLSTT(Section section, boolean sendTypsqlda, int typsqlda) throws SqlException
SqlException
private boolean buildSQLDTAcommandData(int numInputColumns, ColumnMetaData parameterMetaData, java.lang.Object[] inputRow) throws SqlException
SqlException
private void buildFDODSC(int numColumns, int[][] protocolTypesAndLengths, boolean overrideExists, java.util.Hashtable overrideMap, java.util.ArrayList overrideArray) throws SqlException
SqlException
private void buildSQLDTA(int numColumns, int[][] lidAndLengthOverrides, boolean overrideExists, java.util.Hashtable overrideMap, java.util.ArrayList overrideArray) throws SqlException
SqlException
private void buildSQLDTAGRP(int numVars, int[][] lidAndLengthOverrides, boolean mddRequired, java.util.Hashtable overrideMap) throws SqlException
SqlException
protected void buildOUTOVR(ClientResultSet resultSet, ColumnMetaData resultSetMetaData) throws SqlException
SqlException
private int[][] calculateOUTOVRLidAndLengthOverrides(ClientResultSet resultSet, ColumnMetaData resultSetMetaData)
private void buildSQLDTARD(int numColumns, int[][] lidAndLengthOverrides) throws SqlException
SqlException
private void buildSQLCADTA(int numColumns, int[][] lidAndLengthOverrides) throws SqlException
SqlException
private void buildFDODTA(int numVars, int[][] protocolTypesAndLengths, java.lang.Object[] inputs) throws SqlException
SqlException
private void buildEXTDTA(ColumnMetaData parameterMetaData, java.lang.Object[] inputRow, boolean chained) throws SqlException
SqlException
private java.lang.Object retrievePromotedParameterIfExists(int index)
private int calculateColumnsInSQLDTAGRPtriplet(int numVars)
private java.util.Hashtable computeProtocolTypesAndLengths(java.lang.Object[] inputRow, ColumnMetaData parameterMetaData, int[][] lidAndLengths, java.util.Hashtable overrideMap) throws SqlException
SqlException
private int buildPlaceholderLength(long totalLength)
private void buildOUTEXP(boolean outputExpected) throws SqlException
SqlException
void buildMAXBLKEXT(int maxNumOfExtraBlocks) throws SqlException
SqlException
void buildQRYROWSET(int fetchSize) throws SqlException
SqlException
private void buildPRCNAM(java.lang.String prcnam) throws SqlException
SqlException
void buildQRYBLKSZ() throws SqlException
SqlException
private void buildMAXRSLCNT(int maxResultSetCount) throws SqlException
SqlException
private void buildRDBCMTOK() throws SqlException
SqlException
private void buildRSLSETFLG(int resultSetFlag) throws SqlException
SqlException
void buildQRYINSID(long qryinsid) throws SqlException
SqlException
private void buildRTNSQLDA() throws SqlException
SqlException
private void buildTYPSQLDA(int typeSqlda) throws SqlException
SqlException
private void buildQRYCLSIMP()
private void setFDODTALobLength(int[][] protocolTypesAndLengths, int i, long dataLength) throws SqlException
SqlException
private void setFDODTALobLengthUnknown(int i) throws SqlException
SqlException
private boolean checkSendQryrowset(int fetchSize, int resultSetType)
private int checkFetchsize(int fetchSize, int resultSetType)
private int calculateResultSetFlags()
public void writeSetSpecialRegister(Section section, java.util.ArrayList sqlsttList) throws SqlException
writeSetSpecialRegister
in interface StatementRequestInterface
SqlException
private int[][] allocateLidAndLengthsArray(ColumnMetaData parameterMetaData)
private void buildMddOverrides(java.util.ArrayList sdaOverrides) throws SqlException
SqlException
private void setFDODTALob(int securityMechanism, Lob lob, int[][] protocolTypesAndLengths, int i) throws SqlException, java.sql.SQLException
SqlException
java.sql.SQLException
Apache Derby V10.13 Internals - Copyright © 2004,2016 The Apache Software Foundation. All Rights Reserved.