Package | Description |
---|---|
io.vertx.rxjava.jdbcclient | |
io.vertx.rxjava.sqlclient |
Modifier and Type | Field and Description |
---|---|
static PropertyKind<Row> |
JDBCPool.GENERATED_KEYS
The property to be used to retrieve the generated keys
|
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.rxjava.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 © 2021 Eclipse. All rights reserved.