public class PreparedStatement extends Object
From a prepared statement you can
query()
to create and execute a PreparedQuery
cursor()
to create a Cursor
createStream(int)
to create a RowStream
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<PreparedStatement> |
__TYPE_ARG |
Constructor and Description |
---|
PreparedStatement(Object delegate) |
PreparedStatement(PreparedStatement delegate) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Like
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but notifies the completionHandler when it's closed. |
void |
close(Handler<AsyncResult<Void>> completionHandler)
Like
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but notifies the completionHandler when it's closed. |
RowStream<Row> |
createStream(int fetch)
Like
createStream(int) but with empty arguments. |
RowStream<Row> |
createStream(int fetch,
Tuple args)
Execute the prepared query with a cursor and createStream the result.
|
Cursor |
cursor()
Like
cursor() but with empty arguments. |
Cursor |
cursor(Tuple args)
Create a cursor with the provided
arguments . |
boolean |
equals(Object o) |
PreparedStatement |
getDelegate() |
int |
hashCode() |
static PreparedStatement |
newInstance(PreparedStatement arg) |
PreparedQuery<RowSet<Row>> |
query()
Create a prepared query for this statement.
|
Single<Void> |
rxClose()
Like
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but notifies the completionHandler when it's closed. |
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<PreparedStatement> __TYPE_ARG
public PreparedStatement(PreparedStatement delegate)
public PreparedStatement(Object delegate)
public PreparedStatement getDelegate()
public PreparedQuery<RowSet<Row>> query()
public Cursor cursor(Tuple args)
arguments
.args
- the list of argumentspublic RowStream<Row> createStream(int fetch)
createStream(int)
but with empty arguments.fetch
- public 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 void close(Handler<AsyncResult<Void>> completionHandler)
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but notifies the completionHandler
when it's closed.completionHandler
- public void close()
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but notifies the completionHandler
when it's closed.public Single<Void> rxClose()
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but notifies the completionHandler
when it's closed.public static PreparedStatement newInstance(PreparedStatement arg)
Copyright © 2021 Eclipse. All rights reserved.