public class PgConnection extends SqlConnection
The connection object supports all the operations defined in the interface, it also provides additional support:
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, begin, close, close, databaseMetadata, isSSL, newInstance, prepare, prepare, rxBegin, rxClose, rxPreparenewInstance, preparedQuery, preparedQuery, querypublic static final io.vertx.lang.rx.TypeArg<PgConnection> __TYPE_ARG
public PgConnection(PgConnection delegate)
public PgConnection(Object delegate)
public String toString()
toString in class SqlConnectionpublic boolean equals(Object o)
equals in class SqlConnectionpublic int hashCode()
hashCode in class SqlConnectionpublic PgConnection getDelegate()
getDelegate in class SqlConnectionpublic 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 void connect(Vertx vertx, PgConnectOptions options)
vertx - the vertx instanceoptions - the connect optionspublic 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.reactivex.core.Vertx, io.vertx.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.pgclient.PgConnection>>) with options build from the environment variables.vertx - handler - public static void connect(Vertx vertx)
connect(io.vertx.reactivex.core.Vertx, io.vertx.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.pgclient.PgConnection>>) with options build from the environment variables.vertx - public static Single<PgConnection> rxConnect(Vertx vertx)
connect(io.vertx.reactivex.core.Vertx, io.vertx.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.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.reactivex.core.Vertx, io.vertx.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.pgclient.PgConnection>>) with options build from connectionUri.vertx - connectionUri - handler - public static void connect(Vertx vertx, String connectionUri)
connect(io.vertx.reactivex.core.Vertx, io.vertx.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.pgclient.PgConnection>>) with options build from connectionUri.vertx - connectionUri - public static Single<PgConnection> rxConnect(Vertx vertx, String connectionUri)
connect(io.vertx.reactivex.core.Vertx, io.vertx.pgclient.PgConnectOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.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)
SqlConnectionsql string.prepare in class SqlConnectionsql - handler - public PgConnection prepare(String sql)
SqlConnectionsql string.prepare in class SqlConnectionsql - public Single<PreparedStatement> rxPrepare(String sql)
SqlConnectionsql string.rxPrepare in class SqlConnectionsql - public PgConnection exceptionHandler(Handler<Throwable> handler)
SqlConnectionexceptionHandler in class SqlConnectionhandler - public PgConnection closeHandler(Handler<Void> handler)
SqlConnectioncloseHandler in class SqlConnectionhandler - public static PgConnection cast(SqlConnection sqlConnection)
PgConnection.
This is mostly useful for Vert.x generated APIs like RxJava/Mutiny.sqlConnection - the connection to castinstancepublic static PgConnection newInstance(PgConnection arg)
Copyright © 2021 Eclipse. All rights reserved.