Package org.apache.derby.client.net
Class NetResultSet
- java.lang.Object
-
- org.apache.derby.client.am.ClientResultSet
-
- org.apache.derby.client.net.NetResultSet
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,java.sql.ResultSet
,java.sql.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 NetAgent
netAgent_
private NetConnection
netConnection_
(package private) NetCursor
netCursor_
private NetStatement
netStatement_
-
Fields inherited from class org.apache.derby.client.am.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_
-
-
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
flowFetch()
(package private) void
flowFetchToCompleteRowset()
protected void
parseRowset_()
protected void
preClose_()
Method that is invoked bycloseX()
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 org.apache.derby.client.am.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
-
-
-
-
Field Detail
-
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 Detail
-
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 Detail
-
parseRowset_
protected void parseRowset_() throws SqlException
- Specified by:
parseRowset_
in classClientResultSet
- Throws:
SqlException
-
setFetchSize_
public void setFetchSize_(int rows)
- Specified by:
setFetchSize_
in classClientResultSet
-
flowFetchToCompleteRowset
void flowFetchToCompleteRowset() throws DisconnectException
- Throws:
DisconnectException
-
writeFetch_
public void writeFetch_(Section section) throws SqlException
- Specified by:
writeFetch_
in classClientResultSet
- Throws:
SqlException
-
readFetch_
public void readFetch_() throws SqlException
- Specified by:
readFetch_
in classClientResultSet
- Throws:
SqlException
-
writeScrollableFetch_
public void writeScrollableFetch_(Section section, int fetchSize, int orientation, long rowToFetch, boolean resetQueryBlocks) throws SqlException
- Specified by:
writeScrollableFetch_
in classClientResultSet
- Throws:
SqlException
-
readScrollableFetch_
public void readScrollableFetch_() throws SqlException
- Specified by:
readScrollableFetch_
in classClientResultSet
- Throws:
SqlException
-
writePositioningFetch_
public void writePositioningFetch_(Section section, int orientation, long rowToFetch) throws SqlException
- Specified by:
writePositioningFetch_
in classClientResultSet
- Throws:
SqlException
-
readPositioningFetch_
public void readPositioningFetch_() throws SqlException
- Specified by:
readPositioningFetch_
in classClientResultSet
- Throws:
SqlException
-
writeCursorClose_
public void writeCursorClose_(Section section) throws SqlException
- Specified by:
writeCursorClose_
in classClientResultSet
- Throws:
SqlException
-
readCursorClose_
public void readCursorClose_() throws SqlException
- Specified by:
readCursorClose_
in classClientResultSet
- Throws:
SqlException
-
preClose_
protected void preClose_() throws SqlException
Method that is invoked bycloseX()
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 classClientResultSet
- Throws:
SqlException
-
flowFetch
void flowFetch() throws DisconnectException, SqlException
- Throws:
DisconnectException
SqlException
-
-