public class PgConnection extends SqlConnection
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<PgConnection> |
__TYPE_ARG |
Constructor and Description |
---|
PgConnection(Object delegate) |
PgConnection(PgConnection delegate) |
begin, close, databaseMetadata, isSSL, newInstance
newInstance, preparedQuery, query
public static final io.vertx.lang.rx.TypeArg<PgConnection> __TYPE_ARG
public PgConnection(PgConnection delegate)
public PgConnection(Object delegate)
public String toString()
toString
in class SqlConnection
public boolean equals(Object o)
equals
in class SqlConnection
public int hashCode()
hashCode
in class SqlConnection
public PgConnection getDelegate()
getDelegate
in class SqlConnection
public static void connect(Vertx vertx, PgConnectOptions options, Handler<AsyncResult<PgConnection>> handler)
vertx
- the vertx instanceoptions
- the connect optionshandler
- the handler called with the connection or the failurepublic static Single<PgConnection> rxConnect(Vertx vertx, PgConnectOptions options)
vertx
- the vertx instanceoptions
- the connect optionspublic static void connect(Vertx vertx, Handler<AsyncResult<PgConnection>> handler)
connect(io.vertx.rxjava.core.Vertx, io.vertx.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.pgclient.PgConnection>>)
with options build from the environment variables.vertx
- handler
- public static Single<PgConnection> rxConnect(Vertx vertx)
connect(io.vertx.rxjava.core.Vertx, io.vertx.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.pgclient.PgConnection>>)
with options build from the environment variables.vertx
- public static void connect(Vertx vertx, String connectionUri, Handler<AsyncResult<PgConnection>> handler)
connect(io.vertx.rxjava.core.Vertx, io.vertx.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.pgclient.PgConnection>>)
with options build from connectionUri
.vertx
- connectionUri
- handler
- public static Single<PgConnection> rxConnect(Vertx vertx, String connectionUri)
connect(io.vertx.rxjava.core.Vertx, io.vertx.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.pgclient.PgConnection>>)
with options build from connectionUri
.vertx
- connectionUri
- public PgConnection notificationHandler(Handler<PgNotification> handler)
PgNotification
and has access to the channel name
and the notification payload.handler
- the handlerpublic PgConnection cancelRequest(Handler<AsyncResult<Void>> handler)
handler
- the handler notified if cancelling request is sentpublic int processId()
public int secretKey()
public PgConnection prepare(String sql, Handler<AsyncResult<PreparedStatement>> handler)
SqlConnection
prepare
in class SqlConnection
sql
- handler
- public Single<PreparedStatement> rxPrepare(String sql)
SqlConnection
rxPrepare
in class SqlConnection
sql
- public PgConnection exceptionHandler(Handler<Throwable> handler)
SqlConnection
exceptionHandler
in class SqlConnection
handler
- public PgConnection closeHandler(Handler<Void> handler)
SqlConnection
closeHandler
in class SqlConnection
handler
- the handlerpublic static PgConnection newInstance(PgConnection arg)
Copyright © 2023 Eclipse. All rights reserved.