public class PgClient extends Object
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<PgClient> |
__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
static void |
connect(io.vertx.rxjava.core.Vertx vertx,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)
Like
connect(io.vertx.rxjava.core.Vertx, io.reactiverse.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.reactiverse.rxjava.pgclient.PgConnection>>) with options build from the environment variables. |
static void |
connect(io.vertx.rxjava.core.Vertx vertx,
PgConnectOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)
Connects to the database and returns the connection if that succeeds.
|
static void |
connect(io.vertx.rxjava.core.Vertx vertx,
String connectionUri,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)
Like
connect(io.vertx.rxjava.core.Vertx, io.reactiverse.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.reactiverse.rxjava.pgclient.PgConnection>>) with options build from connectionUri . |
boolean |
equals(Object o) |
PgClient |
getDelegate() |
int |
hashCode() |
static PgClient |
newInstance(PgClient arg) |
static PgPool |
pool()
Like
pool() with options build from the environment variables. |
static PgPool |
pool(PgPoolOptions options)
Create a connection pool to the database configured with the given
options . |
static PgPool |
pool(String connectionUri)
Like
pool() with options build from connectionUri . |
static PgPool |
pool(io.vertx.rxjava.core.Vertx vertx)
Like
pool() with options build from the environment variables. |
static PgPool |
pool(io.vertx.rxjava.core.Vertx vertx,
PgPoolOptions options)
Like
pool() with a specific instance. |
static PgPool |
pool(io.vertx.rxjava.core.Vertx vertx,
String connectionUri)
Like
pool() with options build from connectionUri . |
PgClient |
preparedBatch(String sql,
List<Tuple> batch,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
Prepare and execute a createBatch.
|
PgClient |
preparedQuery(String sql,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
Prepare and execute a query.
|
PgClient |
preparedQuery(String sql,
Tuple arguments,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
Prepare and execute a query.
|
PgClient |
query(String sql,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
Execute a simple query.
|
static Single<PgConnection> |
rxConnect(io.vertx.rxjava.core.Vertx vertx)
Like
connect(io.vertx.rxjava.core.Vertx, io.reactiverse.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.reactiverse.rxjava.pgclient.PgConnection>>) with options build from the environment variables. |
static Single<PgConnection> |
rxConnect(io.vertx.rxjava.core.Vertx vertx,
PgConnectOptions options)
Connects to the database and returns the connection if that succeeds.
|
static Single<PgConnection> |
rxConnect(io.vertx.rxjava.core.Vertx vertx,
String connectionUri)
Like
connect(io.vertx.rxjava.core.Vertx, io.reactiverse.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.reactiverse.rxjava.pgclient.PgConnection>>) with options build from connectionUri . |
Single<PgRowSet> |
rxPreparedBatch(String sql,
List<Tuple> batch)
Prepare and execute a createBatch.
|
Single<PgRowSet> |
rxPreparedQuery(String sql)
Prepare and execute a query.
|
Single<PgRowSet> |
rxPreparedQuery(String sql,
Tuple arguments)
Prepare and execute a query.
|
Single<PgRowSet> |
rxQuery(String sql)
Execute a simple query.
|
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<PgClient> __TYPE_ARG
public PgClient(PgClient delegate)
public PgClient getDelegate()
public static PgPool pool()
pool()
with options build from the environment variables.public static PgPool pool(String connectionUri)
pool()
with options build from connectionUri
.connectionUri
- public static PgPool pool(io.vertx.rxjava.core.Vertx vertx)
pool()
with options build from the environment variables.vertx
- public static PgPool pool(io.vertx.rxjava.core.Vertx vertx, String connectionUri)
pool()
with options build from connectionUri
.vertx
- connectionUri
- public static PgPool pool(PgPoolOptions options)
options
.options
- the options for creating the poolpublic static PgPool pool(io.vertx.rxjava.core.Vertx vertx, PgPoolOptions options)
pool()
with a specific instance.vertx
- options
- public static void connect(io.vertx.rxjava.core.Vertx vertx, PgConnectOptions options, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)
vertx
- the vertx instanceoptions
- the connect optionshandler
- the handler called with the connection or the failurepublic static Single<PgConnection> rxConnect(io.vertx.rxjava.core.Vertx vertx, PgConnectOptions options)
vertx
- the vertx instanceoptions
- the connect optionspublic static void connect(io.vertx.rxjava.core.Vertx vertx, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)
connect(io.vertx.rxjava.core.Vertx, io.reactiverse.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.reactiverse.rxjava.pgclient.PgConnection>>)
with options build from the environment variables.vertx
- handler
- public static Single<PgConnection> rxConnect(io.vertx.rxjava.core.Vertx vertx)
connect(io.vertx.rxjava.core.Vertx, io.reactiverse.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.reactiverse.rxjava.pgclient.PgConnection>>)
with options build from the environment variables.vertx
- public static void connect(io.vertx.rxjava.core.Vertx vertx, String connectionUri, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)
connect(io.vertx.rxjava.core.Vertx, io.reactiverse.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.reactiverse.rxjava.pgclient.PgConnection>>)
with options build from connectionUri
.vertx
- connectionUri
- handler
- public static Single<PgConnection> rxConnect(io.vertx.rxjava.core.Vertx vertx, String connectionUri)
connect(io.vertx.rxjava.core.Vertx, io.reactiverse.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.reactiverse.rxjava.pgclient.PgConnection>>)
with options build from connectionUri
.vertx
- connectionUri
- public PgClient query(String sql, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
sql
- the query SQLhandler
- the handler notified with the execution resultpublic Single<PgRowSet> rxQuery(String sql)
sql
- the query SQLpublic PgClient preparedQuery(String sql, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
sql
- the prepared query SQLhandler
- the handler notified with the execution resultpublic Single<PgRowSet> rxPreparedQuery(String sql)
sql
- the prepared query SQLpublic PgClient preparedQuery(String sql, Tuple arguments, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
sql
- the prepared query SQLarguments
- the list of argumentshandler
- the handler notified with the execution resultpublic Single<PgRowSet> rxPreparedQuery(String sql, Tuple arguments)
sql
- the prepared query SQLarguments
- the list of argumentspublic PgClient preparedBatch(String sql, List<Tuple> batch, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
sql
- the prepared query SQLbatch
- the batch of tupleshandler
- the handler notified with the execution resultpublic Single<PgRowSet> rxPreparedBatch(String sql, List<Tuple> batch)
sql
- the prepared query SQLbatch
- the batch of tuplesCopyright © 2019 Eclipse. All rights reserved.