Package | Description |
---|---|
io.reactiverse.pgclient | |
io.reactiverse.pgclient.pubsub | |
io.reactiverse.reactivex.pgclient | |
io.reactiverse.rxjava.pgclient |
Modifier and Type | Method and Description |
---|---|
PgConnection |
PgConnection.cancelRequest(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
Send a request cancellation message to tell the server to cancel processing request in this connection.
|
PgConnection |
PgConnection.closeHandler(io.vertx.core.Handler<Void> handler)
Set an handler called when the connection is closed.
|
PgConnection |
PgConnection.exceptionHandler(io.vertx.core.Handler<Throwable> handler)
Set an handler called with connection errors.
|
PgConnection |
PgConnection.notificationHandler(io.vertx.core.Handler<PgNotification> handler)
Set an handler called when the connection receives notification on a channel.
|
PgConnection |
PgConnection.prepare(String sql,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgPreparedQuery>> handler)
Create a prepared query.
|
<R> PgConnection |
PgConnection.preparedBatch(String sql,
List<Tuple> batch,
Collector<Row,?,R> collector,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgResult<R>>> handler) |
PgConnection |
PgConnection.preparedBatch(String sql,
List<Tuple> batch,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler) |
<R> PgConnection |
PgConnection.preparedQuery(String sql,
Collector<Row,?,R> collector,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgResult<R>>> handler) |
PgConnection |
PgConnection.preparedQuery(String sql,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler) |
<R> PgConnection |
PgConnection.preparedQuery(String sql,
Tuple arguments,
Collector<Row,?,R> collector,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgResult<R>>> handler) |
PgConnection |
PgConnection.preparedQuery(String sql,
Tuple arguments,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler) |
<R> PgConnection |
PgConnection.query(String sql,
Collector<Row,?,R> collector,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgResult<R>>> handler) |
PgConnection |
PgConnection.query(String sql,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler) |
Modifier and Type | Method and Description |
---|---|
static void |
PgClient.connect(io.vertx.core.Vertx vertx,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)
Like
PgClient.connect(Vertx, PgConnectOptions, Handler) with options build from the environment variables. |
static void |
PgClient.connect(io.vertx.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 |
PgClient.connect(io.vertx.core.Vertx vertx,
String connectionUri,
io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)
Like
PgClient.connect(Vertx, PgConnectOptions, Handler) with options build from connectionUri . |
void |
PgPool.getConnection(io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)
Get a connection from the pool.
|
Modifier and Type | Method and Description |
---|---|
PgConnection |
PgSubscriber.actualConnection() |
Modifier and Type | Method and Description |
---|---|
PgConnection |
PgConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static PgConnection |
PgConnection.newInstance(PgConnection arg) |
Constructor and Description |
---|
PgConnection(PgConnection delegate) |
Modifier and Type | Method and Description |
---|---|
PgConnection |
PgConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static PgConnection |
PgConnection.newInstance(PgConnection arg) |
Constructor and Description |
---|
PgConnection(PgConnection delegate) |
Copyright © 2019 Eclipse. All rights reserved.