Package org.mariadb.jdbc.client.result
Class StreamingResult
java.lang.Object
org.mariadb.jdbc.client.result.Result
org.mariadb.jdbc.client.result.StreamingResult
- All Implemented Interfaces:
AutoCloseable
,ResultSet
,Wrapper
,Completion
,ServerMessage
-
Field Summary
FieldsFields inherited from class org.mariadb.jdbc.client.result.Result
closed, context, data, dataSize, exceptionFactory, loaded, maxRows, metadataList, outputParameter, reader, resultSetType, row, rowPointer, statement
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
ConstructorsConstructorDescriptionStreamingResult
(Statement stmt, boolean binaryProtocol, long maxRows, ColumnDefinitionPacket[] metadataList, PacketReader reader, Context context, int fetchSize, ReentrantLock lock, int resultSetType, boolean closeOnCompletion, boolean traceEnable) -
Method Summary
Modifier and TypeMethodDescriptionboolean
absolute
(int idx) private void
void
void
void
When protocol has a current Streaming result (this) fetch all to permit another query is executing.boolean
first()
int
int
getRow()
boolean
boolean
isFirst()
boolean
isLast()
boolean
last()
boolean
next()
private void
This permit to replace current stream results by next ones.boolean
previous()
boolean
relative
(int rows) void
setFetchSize
(int fetchSize) boolean
Methods inherited from class org.mariadb.jdbc.client.result.Result
abort, addRowData, cancelRowUpdates, checkClose, checkNotForwardOnly, clearWarnings, close, closeFromStmtClose, deleteRow, findColumn, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBigDecimal, getBigDecimal, getBigInteger, getBigInteger, getBinaryStream, getBinaryStream, getBlob, getBlob, getBoolean, getBoolean, getByte, getByte, getBytes, getBytes, getCharacterStream, getCharacterStream, getClob, getClob, getConcurrency, getCurrentRowData, getCursorName, getDate, getDate, getDate, getDate, getDouble, getDouble, getFetchDirection, getFloat, getFloat, getHoldability, getInt, getInt, 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, getType, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, insertRow, isBeforeFirst, isClosed, isOutputParameter, isWrapperFor, loaded, moveToCurrentRow, moveToInsertRow, readNext, refreshRow, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setStatement, skipRemaining, 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, updateObject, updateObject, updateObject, updateObject, updateRef, updateRef, updateRow, updateRowData, updateRowId, updateRowId, updateShort, updateShort, updateSQLXML, updateSQLXML, updateString, updateString, updateTime, updateTime, updateTimestamp, updateTimestamp, useAliasAsName, wasNull
-
Field Details
-
lock
-
dataFetchTime
private int dataFetchTime -
fetchSize
private int fetchSize
-
-
Constructor Details
-
StreamingResult
public StreamingResult(Statement stmt, boolean binaryProtocol, long maxRows, ColumnDefinitionPacket[] metadataList, PacketReader reader, Context context, int fetchSize, ReentrantLock lock, int resultSetType, boolean closeOnCompletion, boolean traceEnable) throws SQLException - Throws:
SQLException
-
-
Method Details
-
streaming
public boolean streaming() -
nextStreamingValue
This permit to replace current stream results by next ones.- Throws:
SQLException
- if server return an unexpected error
-
addStreamingValue
- Throws:
SQLException
-
fetchRemaining
When protocol has a current Streaming result (this) fetch all to permit another query is executing.- Specified by:
fetchRemaining
in classResult
- Throws:
SQLException
- if any error occur
-
next
- Specified by:
next
in interfaceResultSet
- Specified by:
next
in classResult
- Throws:
SQLException
-
isAfterLast
- Specified by:
isAfterLast
in interfaceResultSet
- Specified by:
isAfterLast
in classResult
- Throws:
SQLException
-
isFirst
- Specified by:
isFirst
in interfaceResultSet
- Specified by:
isFirst
in classResult
- Throws:
SQLException
-
isLast
- Specified by:
isLast
in interfaceResultSet
- Specified by:
isLast
in classResult
- Throws:
SQLException
-
beforeFirst
- Specified by:
beforeFirst
in interfaceResultSet
- Specified by:
beforeFirst
in classResult
- Throws:
SQLException
-
afterLast
- Specified by:
afterLast
in interfaceResultSet
- Specified by:
afterLast
in classResult
- Throws:
SQLException
-
first
- Specified by:
first
in interfaceResultSet
- Specified by:
first
in classResult
- Throws:
SQLException
-
last
- Specified by:
last
in interfaceResultSet
- Specified by:
last
in classResult
- Throws:
SQLException
-
getRow
- Specified by:
getRow
in interfaceResultSet
- Specified by:
getRow
in classResult
- Throws:
SQLException
-
absolute
- Specified by:
absolute
in interfaceResultSet
- Specified by:
absolute
in classResult
- Throws:
SQLException
-
relative
- Specified by:
relative
in interfaceResultSet
- Specified by:
relative
in classResult
- Throws:
SQLException
-
previous
- Specified by:
previous
in interfaceResultSet
- Specified by:
previous
in classResult
- Throws:
SQLException
-
getFetchSize
public int getFetchSize() -
setFetchSize
- Throws:
SQLException
-