Package org.apache.jena.jdbc.results

Class StreamedResults<T>

java.lang.Object

org.apache.jena.jdbc.results.JenaResultSet

org.apache.jena.jdbc.results.QueryExecutionResults

org.apache.jena.jdbc.results.StreamedResults<T>

Type Parameters:

T - Type of the underlying result rows

All Implemented Interfaces:

AutoCloseable, ResultSet, Wrapper

Direct Known Subclasses:

SelectResults, TripleIteratorResults

public abstract class StreamedResults<T>
extends QueryExecutionResults

Represents a set of streamed results backed by some QueryExecution, streamed results are considered to be forward only

Field Summary

Fields inherited from interface java.sql.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
StreamedResults(JenaStatement statement, QueryExecution qe, boolean commit)	Creates new streamed results

Method Summary

Modifier and Type	Method	Description
final boolean	absolute(int row)
final void	afterLast()
final void	beforeFirst()
final boolean	first()
final int	getFetchDirection()
final int	getFetchSize()
final int	getRow()
final int	getType()
final boolean	isAfterLast()
final boolean	isBeforeFirst()
final boolean	isFirst()
final boolean	isLast()
final boolean	last()
final boolean	next()
final boolean	relative(int rows)
final void	setFetchDirection(int direction)
final void	setFetchSize(int rows)

Methods inherited from class org.apache.jena.jdbc.results.QueryExecutionResults

close, isClosed

Methods inherited from class org.apache.jena.jdbc.results.JenaResultSet

cancelRowUpdates, clearWarnings, deleteRow, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBigDecimal, getBigDecimal, getBinaryStream, getBinaryStream, getBlob, getBlob, getBoolean, getBoolean, getByte, getByte, getBytes, getBytes, getCharacterStream, getCharacterStream, getClob, getClob, getConcurrency, getCursorName, getDate, getDate, getDate, getDate, getDouble, getDouble, getFloat, getFloat, getHoldability, getInt, getInt, getJdbcCompatibilityLevel, getJenaStatement, getLong, getLong, getMetaData, getNCharacterStream, getNCharacterStream, getNClob, getNClob, getNString, getNString, getObject, getObject, getObject, getObject, getObject, getObject, getRef, getRef, getRowId, getRowId, getShort, getShort, getSQLXML, getSQLXML, getStatement, getString, getString, getTime, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getTimestamp, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, insertRow, isWrapperFor, moveToCurrentRow, moveToInsertRow, previous, refreshRow, rowDeleted, rowInserted, rowUpdated, 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, 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 java.lang.Object

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

Methods inherited from interface java.sql.ResultSet

findColumn, updateObject, updateObject, updateObject, updateObject

Constructor Details

StreamedResults

public StreamedResults(JenaStatement statement,
 QueryExecution qe,
 boolean commit)
                throws SQLException

Creates new streamed results

Parameters:

statement - Statement that created the result set

qe - Query Execution

commit - Whether a commit is necessary when the results are closed

Throws:

SQLException - Thrown if the arguments are invalid

Method Details

absolute

public final boolean absolute(int row)
                       throws SQLException

Throws:

SQLException

afterLast

public final void afterLast()
                     throws SQLException

Throws:

SQLException

beforeFirst

public final void beforeFirst()
                       throws SQLException

Throws:

SQLException

first

public final boolean first()
                    throws SQLException

Throws:

SQLException

getFetchDirection

public final int getFetchDirection()

getFetchSize

public final int getFetchSize()

getRow

public final int getRow()

getType

public final int getType()

isAfterLast

public final boolean isAfterLast()
                          throws SQLException

Throws:

SQLException

isBeforeFirst

public final boolean isBeforeFirst()
                            throws SQLException

Throws:

SQLException

isFirst

public final boolean isFirst()
                      throws SQLException

Throws:

SQLException

isLast

public final boolean isLast()
                     throws SQLException

Throws:

SQLException

last

public final boolean last()
                   throws SQLException

Throws:

SQLException

next

public final boolean next()
                   throws SQLException

Throws:

SQLException

relative

public final boolean relative(int rows)
                       throws SQLException

Throws:

SQLException

setFetchDirection

public final void setFetchDirection(int direction)
                             throws SQLException

Throws:

SQLException

setFetchSize

public final void setFetchSize(int rows)
                        throws SQLException

Throws:

SQLException