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, rxPrepare, transaction
newInstance, preparedQuery, 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 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.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 void connect(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 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 void connect(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 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 noticeHandler(Handler<PgNotice> handler)
handler
- public 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
sql
string.prepare
in class SqlConnection
sql
- handler
- public PgConnection prepare(String sql)
SqlConnection
sql
string.prepare
in class SqlConnection
sql
- public Single<PreparedStatement> rxPrepare(String sql)
SqlConnection
sql
string.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
- public static PgConnection cast(SqlConnection sqlConnection)
PgConnection
.
This is mostly useful for Vert.x generated APIs like RxJava/Mutiny.sqlConnection
- the connection to castinstance
public static PgConnection newInstance(PgConnection arg)
Copyright © 2023 Eclipse. All rights reserved.