Interface OracleCommonResultSet
-
- All Superinterfaces:
java.lang.AutoCloseable,java.sql.ResultSet,java.sql.Wrapper
- All Known Subinterfaces:
OracleResultSet
public interface OracleCommonResultSet extends java.sql.ResultSetInterface that defines common methods.- Since:
- 23
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <T> java.util.concurrent.Flow.Publisher<T>publisherOracle(java.util.function.Function<? super OracleRow,T> rowMappingFunction)Returns aPublisherthat publishes the rows of thisResultSetbeginning with the first row.-
Methods inherited from interface java.sql.ResultSet
absolute, afterLast, beforeFirst, cancelRowUpdates, clearWarnings, close, deleteRow, findColumn, first, 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, 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, getRowId, getRowId, getShort, getShort, getSQLXML, getSQLXML, getStatement, getString, getString, getTime, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getTimestamp, getType, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, insertRow, isAfterLast, isBeforeFirst, isClosed, isFirst, isLast, last, moveToCurrentRow, moveToInsertRow, next, previous, refreshRow, relative, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setFetchSize, 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, updateRowId, updateRowId, updateShort, updateShort, updateSQLXML, updateSQLXML, updateString, updateString, updateTime, updateTime, updateTimestamp, updateTimestamp, wasNull
-
-
-
-
Method Detail
-
publisherOracle
<T> java.util.concurrent.Flow.Publisher<T> publisherOracle(java.util.function.Function<? super OracleRow,T> rowMappingFunction) throws java.sql.SQLException
Returns a
Publisherthat publishes the rows of thisResultSetbeginning with the first row. ArowMappingFunctiondefines the typeTwhich rows are published as. EachOracleRowis valid only for the duration of the call to therowMappingFunction.OracleRow.clone()will create a new instance ofOracleRowwhich persists after therowMappingFunctionreturns. An unchecked exception thrown by the row mapping function is emitted as anonErrorsignal to subscribers.The returned
Publishersupports multipleSubscribers.Subscriberswhich subscribe after some rows are published will not see the already published rows. It may be the case that rows are published only when all subscribers have requested additional rows.This method closes the
ResultSet.- Parameters:
rowMappingFunction- Function applied to each row which produces the published typeT.- Returns:
- a
Publisherof the rows of thisResultSet - Throws:
java.sql.SQLException- If a database error occurs, if this method is called on a closedResultSet, or if thisResultSet's cursor has been moved from its initial position before the first row.- Since:
- 20
-
-