ConnectionRequestInterface, StatementRequestInterfaceNetResultSetRequestclass NetStatementRequest extends NetPackageRequest implements StatementRequestInterface
| Modifier and Type | Field | 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 | Description |
|---|---|
NetStatementRequest(NetAgent netAgent,
int bufferSize) |
| Modifier and Type | Method | 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) |
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, writeXIDbuildPKGNAMCSN, buildSQLATTRcommandData, buildSQLSTTcommandData, encryptDataStreamclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitbuildTripletHeader, 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, writeUDTprivate 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 StatementRequestInterfaceSqlExceptionpublic void writePrepareDescribeOutput(NetStatement materialStatement, java.lang.String sql, Section section) throws SqlException
writePrepareDescribeOutput in interface StatementRequestInterfaceSqlExceptionpublic void writePrepare(NetStatement materialStatement, java.lang.String sql, Section section) throws SqlException
writePrepare in interface StatementRequestInterfaceSqlExceptionpublic void writeExecute(NetPreparedStatement materialPreparedStatement, Section section, ColumnMetaData parameterMetaData, java.lang.Object[] inputs, int numInputColumns, boolean outputExpected, boolean chained) throws SqlException
writeExecute in interface StatementRequestInterfaceSqlExceptionpublic void writeOpenQuery(NetPreparedStatement materialPreparedStatement, Section section, int fetchSize, int resultSetType, int numInputColumns, ColumnMetaData parameterMetaData, java.lang.Object[] inputs) throws SqlException
writeOpenQuery in interface StatementRequestInterfaceSqlExceptionpublic void writeOpenQuery(NetStatement materialStatement, Section section, int fetchSize, int resultSetType) throws SqlException
writeOpenQuery in interface StatementRequestInterfaceSqlExceptionpublic void writeDescribeInput(NetPreparedStatement materialPreparedStatement, Section section) throws SqlException
writeDescribeInput in interface StatementRequestInterfaceSqlExceptionpublic void writeDescribeOutput(NetPreparedStatement materialPreparedStatement, Section section) throws SqlException
writeDescribeOutput in interface StatementRequestInterfaceSqlExceptionpublic 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 StatementRequestInterfaceSqlExceptionprivate void buildOPNQRY(Section section, boolean sendQueryRowSet, int fetchSize) throws SqlException
SqlExceptionprivate void buildEXCSQLIMM(Section section, boolean sendQryinsid, long qryinsid) throws SqlException
SqlExceptionprivate void buildPRPSQLSTT(Section section, java.lang.String sql, boolean sendRtnsqlda, boolean sendTypsqlda, int typsqlda) throws SqlException
SqlExceptionprivate void buildEXCSQLSET(Section section) throws SqlException
SqlExceptionprivate 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
SqlExceptionprivate void buildDSCSQLSTT(Section section, boolean sendTypsqlda, int typsqlda) throws SqlException
SqlExceptionprivate boolean buildSQLDTAcommandData(int numInputColumns,
ColumnMetaData parameterMetaData,
java.lang.Object[] inputRow)
throws SqlException
SqlExceptionprivate void buildFDODSC(int numColumns,
int[][] protocolTypesAndLengths,
boolean overrideExists,
java.util.Hashtable overrideMap,
java.util.ArrayList overrideArray)
throws SqlException
SqlExceptionprivate void buildSQLDTA(int numColumns,
int[][] lidAndLengthOverrides,
boolean overrideExists,
java.util.Hashtable overrideMap,
java.util.ArrayList overrideArray)
throws SqlException
SqlExceptionprivate void buildSQLDTAGRP(int numVars,
int[][] lidAndLengthOverrides,
boolean mddRequired,
java.util.Hashtable overrideMap)
throws SqlException
SqlExceptionprotected void buildOUTOVR(ClientResultSet resultSet, ColumnMetaData resultSetMetaData) throws SqlException
SqlExceptionprivate int[][] calculateOUTOVRLidAndLengthOverrides(ClientResultSet resultSet, ColumnMetaData resultSetMetaData)
private void buildSQLDTARD(int numColumns,
int[][] lidAndLengthOverrides)
throws SqlException
SqlExceptionprivate void buildSQLCADTA(int numColumns,
int[][] lidAndLengthOverrides)
throws SqlException
SqlExceptionprivate void buildFDODTA(int numVars,
int[][] protocolTypesAndLengths,
java.lang.Object[] inputs)
throws SqlException
SqlExceptionprivate void buildEXTDTA(ColumnMetaData parameterMetaData, java.lang.Object[] inputRow, boolean chained) throws SqlException
SqlExceptionprivate 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
SqlExceptionprivate int buildPlaceholderLength(long totalLength)
private void buildOUTEXP(boolean outputExpected)
throws SqlException
SqlExceptionvoid buildMAXBLKEXT(int maxNumOfExtraBlocks)
throws SqlException
SqlExceptionvoid buildQRYROWSET(int fetchSize)
throws SqlException
SqlExceptionprivate void buildPRCNAM(java.lang.String prcnam)
throws SqlException
SqlExceptionvoid buildQRYBLKSZ()
throws SqlException
SqlExceptionprivate void buildMAXRSLCNT(int maxResultSetCount)
throws SqlException
SqlExceptionprivate void buildRDBCMTOK()
throws SqlException
SqlExceptionprivate void buildRSLSETFLG(int resultSetFlag)
throws SqlException
SqlExceptionvoid buildQRYINSID(long qryinsid)
throws SqlException
SqlExceptionprivate void buildRTNSQLDA()
throws SqlException
SqlExceptionprivate void buildTYPSQLDA(int typeSqlda)
throws SqlException
SqlExceptionprivate void buildQRYCLSIMP()
private void setFDODTALobLength(int[][] protocolTypesAndLengths,
int i,
long dataLength)
throws SqlException
SqlExceptionprivate void setFDODTALobLengthUnknown(int i)
throws SqlException
SqlExceptionprivate 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 StatementRequestInterfaceSqlExceptionprivate int[][] allocateLidAndLengthsArray(ColumnMetaData parameterMetaData)
private void buildMddOverrides(java.util.ArrayList sdaOverrides)
throws SqlException
SqlExceptionprivate void setFDODTALob(int securityMechanism,
Lob lob,
int[][] protocolTypesAndLengths,
int i)
throws SqlException,
java.sql.SQLException
SqlExceptionjava.sql.SQLExceptionApache Derby V10.14 Internals - Copyright © 2004,2018 The Apache Software Foundation. All Rights Reserved.