| Modifier and Type | Field and Description |
|---|---|
static io.vertx.lang.rx.TypeArg<PreparedQuery> |
__TYPE_ARG |
| Constructor and Description |
|---|
PreparedQuery(PreparedQuery delegate) |
| Modifier and Type | Method and Description |
|---|---|
PreparedQuery |
batch(List<Tuple> argsList,
Handler<AsyncResult<RowSet<Row>>> handler)
Execute a batch.
|
void |
close()
Close the prepared query and release its resources.
|
void |
close(Handler<AsyncResult<Void>> completionHandler)
Like
close() but notifies the completionHandler when it's closed. |
RowStream<Row> |
createStream(int fetch,
Tuple args)
Execute the prepared query with a cursor and createStream the result.
|
Cursor |
cursor() |
Cursor |
cursor(Tuple args)
Create a cursor with the provided
arguments. |
boolean |
equals(Object o) |
PreparedQuery |
execute(Handler<AsyncResult<RowSet<Row>>> handler)
Calls
execute(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.sqlclient.RowSet<io.vertx.reactivex.sqlclient.Row>>>) with an empty tuple argument. |
PreparedQuery |
execute(Tuple args,
Handler<AsyncResult<RowSet<Row>>> handler)
Create a cursor with the provided
arguments. |
PreparedQuery |
getDelegate() |
int |
hashCode() |
static PreparedQuery |
newInstance(PreparedQuery arg) |
Single<RowSet<Row>> |
rxBatch(List<Tuple> argsList)
Execute a batch.
|
Completable |
rxClose()
Like
close() but notifies the completionHandler when it's closed. |
Single<RowSet<Row>> |
rxExecute()
Calls
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>> |
rxExecute(Tuple args)
Create a cursor with the provided
arguments. |
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<PreparedQuery> __TYPE_ARG
public PreparedQuery(PreparedQuery delegate)
public PreparedQuery getDelegate()
public PreparedQuery execute(Handler<AsyncResult<RowSet<Row>>> handler)
execute(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.sqlclient.RowSet<io.vertx.reactivex.sqlclient.Row>>>) with an empty tuple argument.handler - public Single<RowSet<Row>> rxExecute()
execute(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.sqlclient.RowSet<io.vertx.reactivex.sqlclient.Row>>>) with an empty tuple argument.public PreparedQuery execute(Tuple args, Handler<AsyncResult<RowSet<Row>>> handler)
arguments.args - the list of argumentshandler - public Single<RowSet<Row>> rxExecute(Tuple args)
arguments.args - the list of argumentspublic Cursor cursor()
fetch size and empty argumentspublic Cursor cursor(Tuple args)
arguments.args - the list of argumentspublic RowStream<Row> createStream(int fetch, Tuple args)
fetch size to fetch the results.
Note: this requires to be in a transaction, since cursors require it.fetch - the cursor fetch sizeargs - the prepared query argumentspublic PreparedQuery batch(List<Tuple> argsList, Handler<AsyncResult<RowSet<Row>>> handler)
argsList - the list of tuple for the batchhandler - public Single<RowSet<Row>> rxBatch(List<Tuple> argsList)
argsList - the list of tuple for the batchpublic void close()
public void close(Handler<AsyncResult<Void>> completionHandler)
close() but notifies the completionHandler when it's closed.completionHandler - public Completable rxClose()
close() but notifies the completionHandler when it's closed.public static PreparedQuery newInstance(PreparedQuery arg)
Copyright © 2019 Eclipse. All rights reserved.