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