| Package | Description | 
|---|---|
| io.vertx.reactivex.sqlclient | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<Row> | 
Row.__TYPE_ARG  | 
| Modifier and Type | Method and Description | 
|---|---|
static Row | 
Row.newInstance(Row arg)  | 
| Modifier and Type | Method and Description | 
|---|---|
RowStream<Row> | 
PreparedStatement.createStream(int fetch)
Like  
PreparedStatement.createStream(int) but with empty arguments. | 
RowStream<Row> | 
PreparedStatement.createStream(int fetch,
            Tuple args)
Execute the prepared query with a cursor and createStream the result. 
 | 
PreparedQuery<RowSet<Row>> | 
Pool.preparedQuery(String sql)
A connection is borrowed from the connection pool when the query is executed and then immediately returned
 to the pool after it completes. 
 | 
PreparedQuery<RowSet<Row>> | 
SqlClient.preparedQuery(String sql)
Create a prepared query, one of the  
Query.execute(io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>) or PreparedQuery.executeBatch(java.util.List<io.vertx.reactivex.sqlclient.Tuple>, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>)
 methods must be called to execute the query. | 
PreparedQuery<RowSet<Row>> | 
PreparedStatement.query()
Create a prepared query for this statement. 
 | 
Query<RowSet<Row>> | 
Pool.query(String sql)
A connection is borrowed from the connection pool when the query is executed and then immediately returned
 to the pool after it completes. 
 | 
Query<RowSet<Row>> | 
SqlClient.query(String sql)
Create a query, the  
Query.execute(io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>) method must be called to execute the query. | 
Single<RowSet<Row>> | 
Cursor.rxRead(int count)
Read rows from the cursor, the result is provided asynchronously to the  
handler. | 
| Modifier and Type | Method and Description | 
|---|---|
<U> PreparedQuery<RowSet<U>> | 
PreparedQuery.mapping(java.util.function.Function<Row,U> mapper)
 | 
<U> Query<RowSet<U>> | 
Query.mapping(java.util.function.Function<Row,U> mapper)
 | 
void | 
Cursor.read(int count,
    Handler<AsyncResult<RowSet<Row>>> handler)
Read rows from the cursor, the result is provided asynchronously to the  
handler. | 
Copyright © 2020 Eclipse. All rights reserved.