Class NetResultSet

java.lang.Object

org.apache.derby.client.am.ClientResultSet

org.apache.derby.client.net.NetResultSet

All Implemented Interfaces:

AutoCloseable, ResultSet, Wrapper, ResultSetCallbackInterface, UnitOfWorkListener

Direct Known Subclasses:

NetResultSet42

class NetResultSet
extends ClientResultSet

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	firstOutovrBuilt_
private boolean	isFixedRowProtocol
private final NetAgent	netAgent_
private final NetConnection	netConnection_
(package private) final NetCursor	netCursor_
private final NetStatement	netStatement_

Fields inherited from class ClientResultSet

agent_, cursor_, cursorHold_, fetchSize_, generatedSection_, isRowsetCursor_, openOnServer_, queryInstanceIdentifier_, queryTerminatingSqlca_, resultSetMetaData_, resultSetType_, rowsetSqlca_, rowsReceivedInCurrentRowset_, rowsYetToBeReceivedForRowset_, scrollable_, scrollOrientation_absolute__, scrollOrientation_after__, scrollOrientation_before__, scrollOrientation_relative__, sensitivity_, sensitivity_insensitive__, sensitivity_sensitive_dynamic__, sensitivity_sensitive_static__, sensitivity_unknown__, statement_, suggestedFetchSize_

Fields inherited from interface ResultSet

CLOSE_CURSORS_AT_COMMIT, CONCUR_READ_ONLY, CONCUR_UPDATABLE, FETCH_FORWARD, FETCH_REVERSE, FETCH_UNKNOWN, HOLD_CURSORS_OVER_COMMIT, TYPE_FORWARD_ONLY, TYPE_SCROLL_INSENSITIVE, TYPE_SCROLL_SENSITIVE

Constructor Summary

Constructors

Constructor	Description
NetResultSet(NetAgent netAgent, NetStatement netStatement, Cursor cursor, int qryprctyp, int sqlcsrhld, int qryattscr, int qryattsns, int qryattset, long qryinsid, int actualResultSetType, int actualResultSetConcurrency, int actualResultSetHoldability)

Method Summary

Modifier and Type	Method	Description
(package private) void	flowFetch()
(package private) void	flowFetchToCompleteRowset()
protected void	parseRowset_()
protected void	preClose_()	Method that is invoked by closeX() before the result set is actually being closed.
void	readCursorClose_()
void	readFetch_()
void	readPositioningFetch_()
void	readScrollableFetch_()
void	setFetchSize_(int rows)
void	writeCursorClose_(Section section)
void	writeFetch_(Section section)
void	writePositioningFetch_(Section section, int orientation, long rowToFetch)
void	writeScrollableFetch_(Section section, int fetchSize, int orientation, long rowToFetch, boolean resetQueryBlocks)

Methods inherited from class ClientResultSet

absolute, accumulateWarning, afterLast, beforeFirst, cancelRowUpdates, checkAndThrowReceivedQueryTerminatingException, checkForClosedResultSet, clearWarnings, close, closeX, completeLocalCommit, completeLocalRollback, completeSqlca, deleteRow, earlyCloseComplete, expandRowsetSqlca, findColumn, findColumnX, first, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBigDecimal, getBigDecimal, getBinaryStream, getBinaryStream, getBlob, getBlob, getBoolean, getBoolean, getByte, getByte, getBytes, getBytes, getCharacterStream, getCharacterStream, getClob, getClob, getConcurrency, getConnectionCallbackInterface, getCursorName, getDate, getDate, getDate, getDate, getDouble, getDouble, getFetchDirection, getFetchSize, getFloat, getFloat, getHoldability, getInt, getInt, getLong, getLong, getMetaData, getNCharacterStream, getNCharacterStream, getNClob, getNClob, getNString, getNString, getObject, getObject, getObject, getObject, getObject, getObject, getRef, getRef, getRow, getRowCount, getRowId, getRowId, getRSReturnability, getShort, getShort, getSQLXML, getSQLXML, getStatement, getStatementCallbackInterface, getString, getString, getTime, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getTimestamp, getType, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, insertRow, isAfterLast, isBeforeFirst, isClosed, isFirst, isLast, isWrapperFor, last, listenToUnitOfWork, markClosedOnServer, markLOBAsPublished, moveToCurrentRow, moveToInsertRow, next, previous, refreshRow, relative, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setFetchSize, setRowCountEvent, setRSReturnability, setValidCursorPosition, unwrap, updateArray, updateArray, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateBigDecimal, updateBigDecimal, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBoolean, updateBoolean, updateByte, updateByte, updateBytes, updateBytes, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateClob, updateClob, updateClob, updateClob, updateClob, updateClob, updateDate, updateDate, updateDouble, updateDouble, updateFloat, updateFloat, updateInt, updateInt, updateLong, updateLong, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNString, updateNString, updateNull, updateNull, updateObject, updateObject, updateObject, updateObject, updateRef, updateRef, updateRow, updateRowId, updateRowId, updateShort, updateShort, updateSQLXML, updateSQLXML, updateString, updateString, updateTime, updateTime, updateTimestamp, updateTimestamp, wasNull

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ResultSet

updateObject, updateObject, updateObject, updateObject

Field Details

netConnection_

private final NetConnection netConnection_

netStatement_

private final NetStatement netStatement_

netCursor_

final NetCursor netCursor_

netAgent_

private final NetAgent netAgent_

isFixedRowProtocol

private boolean isFixedRowProtocol

firstOutovrBuilt_

boolean firstOutovrBuilt_

Constructor Details

NetResultSet

NetResultSet(NetAgent netAgent,
 NetStatement netStatement,
 Cursor cursor,
 int qryprctyp,
 int sqlcsrhld,
 int qryattscr,
 int qryattsns,
 int qryattset,
 long qryinsid,
 int actualResultSetType,
 int actualResultSetConcurrency,
 int actualResultSetHoldability)

Method Details

parseRowset_

protected void parseRowset_()
                     throws SqlException

Specified by:

parseRowset_ in class ClientResultSet

Throws:

SqlException

setFetchSize_

public void setFetchSize_(int rows)

Specified by:

setFetchSize_ in class ClientResultSet

flowFetchToCompleteRowset

void flowFetchToCompleteRowset()
                        throws DisconnectException

Throws:

DisconnectException

writeFetch_

public void writeFetch_(Section section)
                 throws SqlException

Specified by:

writeFetch_ in class ClientResultSet

Throws:

SqlException

readFetch_

public void readFetch_()
                throws SqlException

Specified by:

readFetch_ in class ClientResultSet

Throws:

SqlException

writeScrollableFetch_

public void writeScrollableFetch_(Section section,
 int fetchSize,
 int orientation,
 long rowToFetch,
 boolean resetQueryBlocks)
                           throws SqlException

Specified by:

writeScrollableFetch_ in class ClientResultSet

Throws:

SqlException

readScrollableFetch_

public void readScrollableFetch_()
                          throws SqlException

Specified by:

readScrollableFetch_ in class ClientResultSet

Throws:

SqlException

writePositioningFetch_

public void writePositioningFetch_(Section section,
 int orientation,
 long rowToFetch)
                            throws SqlException

Specified by:

writePositioningFetch_ in class ClientResultSet

Throws:

SqlException

readPositioningFetch_

public void readPositioningFetch_()
                           throws SqlException

Specified by:

readPositioningFetch_ in class ClientResultSet

Throws:

SqlException

writeCursorClose_

public void writeCursorClose_(Section section)
                       throws SqlException

Specified by:

writeCursorClose_ in class ClientResultSet

Throws:

SqlException

readCursorClose_

public void readCursorClose_()
                      throws SqlException

Specified by:

readCursorClose_ in class ClientResultSet

Throws:

SqlException

preClose_

protected void preClose_()
                  throws SqlException

Method that is invoked by closeX() before the result set is actually being closed. If QRYCLSIMP is enabled on the cursor, scan data buffer for end of data (SQL state 02000). If end of data is received, the result set is closed on the server.

Specified by:

preClose_ in class ClientResultSet

Throws:

SqlException

flowFetch

void flowFetch()
        throws DisconnectException,
SqlException

Throws:

DisconnectException

SqlException