Package org.apache.derby.client.net
Class NetResultSetRequest
- 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
-
- org.apache.derby.client.net.NetResultSetRequest
-
- All Implemented Interfaces:
ConnectionRequestInterface
,ResultSetRequestInterface
,StatementRequestInterface
- Direct Known Subclasses:
NetXAConnectionRequest
class NetResultSetRequest extends NetStatementRequest implements ResultSetRequestInterface
-
-
Field Summary
-
Fields inherited from class org.apache.derby.client.net.Request
buffer, netAgent_, passwordIncluded_, passwordLength_, passwordStart_
-
-
Constructor Summary
Constructors Constructor Description NetResultSetRequest(NetAgent netAgent, int bufferSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
buildCLSQRY(Section section, long queryInstanceIdentifier)
private void
buildCNTQRY(Section section, boolean sendQryrowset, long queryInstanceIdentifier, int qryrowsetSize, boolean sendRtnextdta)
private void
buildCoreCNTQRY(Section section, boolean sendQryrowset, long queryInstanceIdentifier, int qryrowsetSize)
private void
buildOUTOVR(NetResultSet resultSet, ColumnMetaData resultSetMetaData, boolean firstOutovrBuilt, boolean hasLobs)
private void
buildPositioningCNTQRY(int scrollOrientation, long rowNumber, Section section, boolean sendQryrowset, long queryInstanceIdentifier, int qryrowsetSize)
private void
buildQRYBLKRST(int qryblkrst)
private void
buildQRYROWNBR(long rowNumber)
private void
buildQRYRTNDTA(int qryrtndta)
private void
buildQRYSCRORN(int scrollOrientation)
private void
buildRTNEXTDTA(int rtnextdta)
private void
buildScrollCNTQRY(int scrollOrientation, long rowNumber, Section section, boolean sendQryrowset, long queryInstanceIdentifier, int qryrowsetSize, boolean resetQueryBlocks)
private int
computePROTOCOLOrientation(int orientation)
void
writeCursorClose(NetResultSet resultSet, Section section)
void
writeFetch(NetResultSet resultSet, Section section, int fetchSize)
void
writePositioningFetch(NetResultSet resultSet, Section section, int orientation, long rowToFetch)
void
writeScrollableFetch(NetResultSet resultSet, Section section, int fetchSize, int orientation, long rowToFetch, boolean resetQueryBlocks)
-
Methods inherited from class org.apache.derby.client.net.NetStatementRequest
buildMAXBLKEXT, buildOUTOVR, buildQRYBLKSZ, buildQRYINSID, buildQRYROWSET, writeDescribeInput, writeDescribeOutput, writeExecute, writeExecuteCall, writeExecuteImmediate, writeOpenQuery, writeOpenQuery, writePrepare, writePrepareDescribeOutput, writeSetSpecialRegister
-
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
-
-
-
-
Constructor Detail
-
NetResultSetRequest
NetResultSetRequest(NetAgent netAgent, int bufferSize)
-
-
Method Detail
-
writeFetch
public void writeFetch(NetResultSet resultSet, Section section, int fetchSize) throws SqlException
- Specified by:
writeFetch
in interfaceResultSetRequestInterface
- Throws:
SqlException
-
writeScrollableFetch
public void writeScrollableFetch(NetResultSet resultSet, Section section, int fetchSize, int orientation, long rowToFetch, boolean resetQueryBlocks) throws SqlException
- Specified by:
writeScrollableFetch
in interfaceResultSetRequestInterface
- Throws:
SqlException
-
writePositioningFetch
public void writePositioningFetch(NetResultSet resultSet, Section section, int orientation, long rowToFetch) throws SqlException
- Specified by:
writePositioningFetch
in interfaceResultSetRequestInterface
- Throws:
SqlException
-
writeCursorClose
public void writeCursorClose(NetResultSet resultSet, Section section) throws SqlException
- Specified by:
writeCursorClose
in interfaceResultSetRequestInterface
- Throws:
SqlException
-
buildCLSQRY
private void buildCLSQRY(Section section, long queryInstanceIdentifier) throws SqlException
- Throws:
SqlException
-
buildCNTQRY
private void buildCNTQRY(Section section, boolean sendQryrowset, long queryInstanceIdentifier, int qryrowsetSize, boolean sendRtnextdta) throws SqlException
- Throws:
SqlException
-
buildCoreCNTQRY
private void buildCoreCNTQRY(Section section, boolean sendQryrowset, long queryInstanceIdentifier, int qryrowsetSize) throws SqlException
- Throws:
SqlException
-
buildScrollCNTQRY
private void buildScrollCNTQRY(int scrollOrientation, long rowNumber, Section section, boolean sendQryrowset, long queryInstanceIdentifier, int qryrowsetSize, boolean resetQueryBlocks) throws SqlException
- Throws:
SqlException
-
buildPositioningCNTQRY
private void buildPositioningCNTQRY(int scrollOrientation, long rowNumber, Section section, boolean sendQryrowset, long queryInstanceIdentifier, int qryrowsetSize) throws SqlException
- Throws:
SqlException
-
buildOUTOVR
private void buildOUTOVR(NetResultSet resultSet, ColumnMetaData resultSetMetaData, boolean firstOutovrBuilt, boolean hasLobs) throws SqlException
- Throws:
SqlException
-
buildRTNEXTDTA
private void buildRTNEXTDTA(int rtnextdta) throws SqlException
- Throws:
SqlException
-
buildQRYSCRORN
private void buildQRYSCRORN(int scrollOrientation) throws SqlException
- Throws:
SqlException
-
buildQRYBLKRST
private void buildQRYBLKRST(int qryblkrst) throws SqlException
- Throws:
SqlException
-
buildQRYROWNBR
private void buildQRYROWNBR(long rowNumber) throws SqlException
- Throws:
SqlException
-
buildQRYRTNDTA
private void buildQRYRTNDTA(int qryrtndta) throws SqlException
- Throws:
SqlException
-
computePROTOCOLOrientation
private int computePROTOCOLOrientation(int orientation) throws SqlException
- Throws:
SqlException
-
-