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(PgConnection delegate) |
begin, close, isSSL, newInstancenewInstancepublic static final io.vertx.lang.rx.TypeArg<PgConnection> __TYPE_ARG
public PgConnection(PgConnection 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 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 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 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<PreparedQuery>> handler)
SqlConnectionprepare in class SqlConnectionsql - the sqlhandler - the handler notified with the prepared query asynchronouslypublic Single<PreparedQuery> rxPrepare(String sql)
SqlConnectionrxPrepare in class SqlConnectionsql - the sqlpublic PgConnection exceptionHandler(Handler<Throwable> handler)
SqlConnectionexceptionHandler in class SqlConnectionhandler - the handlerpublic PgConnection closeHandler(Handler<Void> handler)
SqlConnectioncloseHandler in class SqlConnectionhandler - the handlerpublic PgConnection preparedQuery(String sql, Handler<AsyncResult<RowSet<Row>>> handler)
SqlClientpreparedQuery in class SqlConnectionsql - the prepared query SQLhandler - the handler notified with the execution resultpublic Single<RowSet<Row>> rxPreparedQuery(String sql)
SqlClientrxPreparedQuery in class SqlConnectionsql - the prepared query SQLpublic PgConnection query(String sql, Handler<AsyncResult<RowSet<Row>>> handler)
SqlClientquery in class SqlConnectionsql - the query SQLhandler - the handler notified with the execution resultpublic Single<RowSet<Row>> rxQuery(String sql)
SqlClientrxQuery in class SqlConnectionsql - the query SQLpublic PgConnection preparedQuery(String sql, Tuple arguments, Handler<AsyncResult<RowSet<Row>>> handler)
SqlClientpreparedQuery in class SqlConnectionsql - the prepared query SQLarguments - the list of argumentshandler - the handler notified with the execution resultpublic Single<RowSet<Row>> rxPreparedQuery(String sql, Tuple arguments)
SqlClientrxPreparedQuery in class SqlConnectionsql - the prepared query SQLarguments - the list of argumentspublic PgConnection preparedBatch(String sql, List<Tuple> batch, Handler<AsyncResult<RowSet<Row>>> handler)
SqlClientpreparedBatch in class SqlConnectionsql - the prepared query SQLbatch - the batch of tupleshandler - the handler notified with the execution resultpublic Single<RowSet<Row>> rxPreparedBatch(String sql, List<Tuple> batch)
SqlClientrxPreparedBatch in class SqlConnectionsql - the prepared query SQLbatch - the batch of tuplespublic static PgConnection newInstance(PgConnection arg)
Copyright © 2019 Eclipse. All rights reserved.