| Package | Description |
|---|---|
| io.vertx.reactivex.mysqlclient | |
| io.vertx.reactivex.pgclient | |
| io.vertx.reactivex.sqlclient |
| Modifier and Type | Method and Description |
|---|---|
Single<RowSet<Row>> |
MySQLPool.rxPreparedBatch(String sql,
List<Tuple> batch) |
Single<RowSet<Row>> |
MySQLConnection.rxPreparedQuery(String sql) |
Single<RowSet<Row>> |
MySQLPool.rxPreparedQuery(String sql) |
Single<RowSet<Row>> |
MySQLConnection.rxPreparedQuery(String sql,
Tuple arguments) |
Single<RowSet<Row>> |
MySQLPool.rxPreparedQuery(String sql,
Tuple arguments) |
Single<RowSet<Row>> |
MySQLConnection.rxQuery(String sql) |
Single<RowSet<Row>> |
MySQLPool.rxQuery(String sql) |
| Modifier and Type | Method and Description |
|---|---|
MySQLPool |
MySQLPool.preparedBatch(String sql,
List<Tuple> batch,
Handler<AsyncResult<RowSet<Row>>> handler) |
MySQLConnection |
MySQLConnection.preparedQuery(String sql,
Handler<AsyncResult<RowSet<Row>>> handler) |
MySQLPool |
MySQLPool.preparedQuery(String sql,
Handler<AsyncResult<RowSet<Row>>> handler) |
MySQLConnection |
MySQLConnection.preparedQuery(String sql,
Tuple arguments,
Handler<AsyncResult<RowSet<Row>>> handler) |
MySQLPool |
MySQLPool.preparedQuery(String sql,
Tuple arguments,
Handler<AsyncResult<RowSet<Row>>> handler) |
MySQLConnection |
MySQLConnection.query(String sql,
Handler<AsyncResult<RowSet<Row>>> handler) |
MySQLPool |
MySQLPool.query(String sql,
Handler<AsyncResult<RowSet<Row>>> handler) |
| Modifier and Type | Method and Description |
|---|---|
Single<RowSet<Row>> |
PgConnection.rxPreparedBatch(String sql,
List<Tuple> batch) |
Single<RowSet<Row>> |
PgPool.rxPreparedBatch(String sql,
List<Tuple> batch) |
Single<RowSet<Row>> |
PgConnection.rxPreparedQuery(String sql) |
Single<RowSet<Row>> |
PgPool.rxPreparedQuery(String sql) |
Single<RowSet<Row>> |
PgConnection.rxPreparedQuery(String sql,
Tuple arguments) |
Single<RowSet<Row>> |
PgPool.rxPreparedQuery(String sql,
Tuple arguments) |
Single<RowSet<Row>> |
PgConnection.rxQuery(String sql) |
Single<RowSet<Row>> |
PgPool.rxQuery(String sql) |
| Modifier and Type | Method and Description |
|---|---|
PgConnection |
PgConnection.preparedBatch(String sql,
List<Tuple> batch,
Handler<AsyncResult<RowSet<Row>>> handler) |
PgPool |
PgPool.preparedBatch(String sql,
List<Tuple> batch,
Handler<AsyncResult<RowSet<Row>>> handler) |
PgConnection |
PgConnection.preparedQuery(String sql,
Handler<AsyncResult<RowSet<Row>>> handler) |
PgPool |
PgPool.preparedQuery(String sql,
Handler<AsyncResult<RowSet<Row>>> handler) |
PgConnection |
PgConnection.preparedQuery(String sql,
Tuple arguments,
Handler<AsyncResult<RowSet<Row>>> handler) |
PgPool |
PgPool.preparedQuery(String sql,
Tuple arguments,
Handler<AsyncResult<RowSet<Row>>> handler) |
PgConnection |
PgConnection.query(String sql,
Handler<AsyncResult<RowSet<Row>>> handler) |
PgPool |
PgPool.query(String sql,
Handler<AsyncResult<RowSet<Row>>> handler) |
| Modifier and Type | Field and Description |
|---|---|
static io.vertx.lang.rx.TypeArg<RowSet> |
RowSet.__TYPE_ARG |
| Modifier and Type | Method and Description |
|---|---|
static <R> RowSet<R> |
RowSet.newInstance(RowSet arg) |
static <R> RowSet<R> |
RowSet.newInstance(RowSet arg,
io.vertx.lang.rx.TypeArg<R> __typeArg_R) |
RowSet<R> |
RowSet.next() |
RowSet<R> |
RowSet.value()
Get the result value.
|
| Modifier and Type | Method and Description |
|---|---|
Single<RowSet<Row>> |
PreparedQuery.rxBatch(List<Tuple> argsList)
Execute a batch.
|
Single<RowSet<Row>> |
PreparedQuery.rxExecute()
Calls
PreparedQuery.execute(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.sqlclient.RowSet<io.vertx.reactivex.sqlclient.Row>>>) with an empty tuple argument. |
Single<RowSet<Row>> |
PreparedQuery.rxExecute(Tuple args)
Create a cursor with the provided
arguments. |
Single<RowSet<Row>> |
SqlConnection.rxPreparedBatch(String sql,
List<Tuple> batch) |
Single<RowSet<Row>> |
Pool.rxPreparedBatch(String sql,
List<Tuple> batch) |
Single<RowSet<Row>> |
SqlClient.rxPreparedBatch(String sql,
List<Tuple> batch)
Prepare and execute a createBatch.
|
Single<RowSet<Row>> |
Transaction.rxPreparedBatch(String sql,
List<Tuple> batch) |
Single<RowSet<Row>> |
SqlConnection.rxPreparedQuery(String sql) |
Single<RowSet<Row>> |
Pool.rxPreparedQuery(String sql) |
Single<RowSet<Row>> |
SqlClient.rxPreparedQuery(String sql)
Prepare and execute a query.
|
Single<RowSet<Row>> |
Transaction.rxPreparedQuery(String sql) |
Single<RowSet<Row>> |
SqlConnection.rxPreparedQuery(String sql,
Tuple arguments) |
Single<RowSet<Row>> |
Pool.rxPreparedQuery(String sql,
Tuple arguments) |
Single<RowSet<Row>> |
SqlClient.rxPreparedQuery(String sql,
Tuple arguments)
Prepare and execute a query.
|
Single<RowSet<Row>> |
Transaction.rxPreparedQuery(String sql,
Tuple arguments) |
Single<RowSet<Row>> |
SqlConnection.rxQuery(String sql) |
Single<RowSet<Row>> |
Pool.rxQuery(String sql) |
Single<RowSet<Row>> |
SqlClient.rxQuery(String sql)
Execute a simple query.
|
Single<RowSet<Row>> |
Transaction.rxQuery(String sql) |
Single<RowSet<Row>> |
Cursor.rxRead(int count)
Read rows from the cursor, the result is provided asynchronously to the
handler. |
Copyright © 2019 Eclipse. All rights reserved.