public interface SQLRowStream extends ReadStream<JsonArray>
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the stream/underlying cursor(s).
|
void |
close(Handler<AsyncResult<Void>> handler)
Closes the stream/underlying cursor(s).
|
int |
column(String name)
Will convert the column name to the json array index.
|
List<String> |
columns()
Returns all column names available in the underlying resultset.
|
SQLRowStream |
endHandler(Handler<Void> endHandler)
Set an end handler.
|
SQLRowStream |
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
SQLRowStream |
handler(Handler<JsonArray> handler)
Set a data handler.
|
void |
moreResults()
Request for more results if available
|
SQLRowStream |
pause()
Pause the
ReadStream , it sets the buffer in fetch mode and clears the actual demand. |
SQLRowStream |
resultSetClosedHandler(Handler<Void> handler)
Event handler when a resultset is closed.
|
SQLRowStream |
resume()
Resume reading, and sets the buffer in
flowing mode. |
fetch, pipe, pipeTo, pipeTo
SQLRowStream exceptionHandler(Handler<Throwable> handler)
ReadStream
exceptionHandler
in interface ReadStream<JsonArray>
exceptionHandler
in interface StreamBase
handler
- the exception handlerSQLRowStream handler(Handler<JsonArray> handler)
ReadStream
handler
in interface ReadStream<JsonArray>
SQLRowStream pause()
ReadStream
ReadStream
, it sets the buffer in fetch
mode and clears the actual demand.
While it's paused, no data will be sent to the data handler
.
pause
in interface ReadStream<JsonArray>
SQLRowStream resume()
ReadStream
flowing
mode.
If the ReadStream
has been paused, reading will recommence on it.resume
in interface ReadStream<JsonArray>
SQLRowStream endHandler(Handler<Void> endHandler)
ReadStream
endHandler
in interface ReadStream<JsonArray>
int column(String name)
name
- the column nameList<String> columns()
SQLRowStream resultSetClosedHandler(Handler<Void> handler)
handler
- called when the current result set is closedvoid moreResults()
void close()
void close(Handler<AsyncResult<Void>> handler)
handler
- called when the stream/underlying cursor(s) is(are) closedCopyright © 2022 Eclipse. All rights reserved.