vertx / io.vertx.reactivex.ext.sql / SQLRowStream

SQLRowStream

open class SQLRowStream : ReadStream<JsonArray>

A ReadStream of Rows from the underlying RDBMS. This class follows the ReadStream semantics and will automatically close the underlying resources if all returned rows are returned. For cases where the results are ignored before the full processing of the returned rows is complete the close method **MUST** be called in order to release underlying resources. The interface is minimal in order to support all SQL clients not just JDBC. NOTE: This class has been automatically generated from the io.vertx.ext.sql.SQLRowStream non RX-ified interface using Vert.x codegen.

Constructors

<init>

SQLRowStream(delegate: SQLRowStream)

Properties

__TYPE_ARG

static val __TYPE_ARG: TypeArg<SQLRowStream>

Functions

close

open fun close(): Unit
open fun close(handler: Handler<AsyncResult<Void>>): Unit

Closes the stream/underlying cursor(s). The actual close happens asynchronously.

column

open fun column(name: String): Int

Will convert the column name to the json array index.

columns

open fun columns(): MutableList<String>

Returns all column names available in the underlying resultset. One needs to carefully use this method since in contrast to the singular version it does not perform case insensitive lookups or takes alias in consideration on the column names.

endHandler

open fun endHandler(endHandler: Handler<Void>): SQLRowStream

equals

open fun equals(other: Any?): Boolean

exceptionHandler

open fun exceptionHandler(handler: Handler<Throwable>): SQLRowStream

getDelegate

open fun getDelegate(): SQLRowStream

handler

open fun handler(handler: Handler<JsonArray>): SQLRowStream

hashCode

open fun hashCode(): Int

moreResults

open fun moreResults(): Unit

Request for more results if available

newInstance

open static fun newInstance(arg: SQLRowStream): SQLRowStream

pause

open fun pause(): SQLRowStream

resultSetClosedHandler

open fun resultSetClosedHandler(handler: Handler<Void>): SQLRowStream

Event handler when a resultset is closed. This is useful to request for more results.

resume

open fun resume(): SQLRowStream

rxClose

open fun rxClose(): Completable

Closes the stream/underlying cursor(s). The actual close happens asynchronously.

toFlowable

open fun toFlowable(): Flowable<JsonArray>

toObservable

open fun toObservable(): Observable<JsonArray>

toString

open fun toString(): String