Class PgConnection

java.lang.Object
io.vertx.rxjava3.sqlclient.SqlClient
io.vertx.rxjava3.sqlclient.SqlConnection
io.vertx.rxjava3.pgclient.PgConnection
All Implemented Interfaces:
io.vertx.lang.rx.RxDelegate
public class PgConnection extends SqlConnection implements io.vertx.lang.rx.RxDelegate
A connection to Postgres.

The connection object supports all the operations defined in the interface, it also provides additional support:

  • Notification
  • Request Cancellation

NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

  • Field Details

    • __TYPE_ARG

      public static final io.vertx.lang.rx.TypeArg<PgConnection> __TYPE_ARG

  • Constructor Details

    • PgConnection

      public PgConnection(PgConnection delegate)

    • PgConnection

      public PgConnection(Object delegate)

  • Method Details

    • toString

      public String toString()
      Overrides:
      toString in class SqlConnection

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class SqlConnection

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class SqlConnection

    • getDelegate

      public PgConnection getDelegate()
      Specified by:
      getDelegate in interface io.vertx.lang.rx.RxDelegate
      Overrides:
      getDelegate in class SqlConnection

    • connect

      public static Single<PgConnection> connect(Vertx vertx, PgConnectOptions options)
      Connects to the database and returns the connection if that succeeds.

      The connection interracts directly with the database is not a proxy, so closing the connection will close the underlying connection to the database.

      Parameters:
      vertx - the vertx instance
      options - the connect options
      Returns:
      a future notified with the connection or the failure

    • rxConnect

      public static Single<PgConnection> rxConnect(Vertx vertx, PgConnectOptions options)
      Connects to the database and returns the connection if that succeeds.

      The connection interracts directly with the database is not a proxy, so closing the connection will close the underlying connection to the database.

      Parameters:
      vertx - the vertx instance
      options - the connect options
      Returns:
      a future notified with the connection or the failure

    • connect

      public static Single<PgConnection> connect(Vertx vertx)
      Like connect(Vertx, PgConnectOptions) with options build from the environment variables.
      Parameters:
      vertx -
      Returns:

    • rxConnect

      public static Single<PgConnection> rxConnect(Vertx vertx)
      Like connect(Vertx, PgConnectOptions) with options build from the environment variables.
      Parameters:
      vertx -
      Returns:

    • connect

      public static Single<PgConnection> connect(Vertx vertx, String connectionUri)
      Like connect(Vertx, PgConnectOptions) with options build from connectionUri.
      Parameters:
      vertx -
      connectionUri -
      Returns:

    • rxConnect

      public static Single<PgConnection> rxConnect(Vertx vertx, String connectionUri)
      Like connect(Vertx, PgConnectOptions) with options build from connectionUri.
      Parameters:
      vertx -
      connectionUri -
      Returns:

    • notificationHandler

      public PgConnection notificationHandler(Handler<PgNotification> handler)
      Set a handler called when the connection receives notification on a channel.

      The handler is called with the PgNotification and has access to the channel name and the notification payload.

      Parameters:
      handler - the handler
      Returns:
      the transaction instance

    • noticeHandler

      public PgConnection noticeHandler(Handler<PgNotice> handler)
      Set a handler called when the connection receives a notice from the server.
      Parameters:
      handler -
      Returns:

    • cancelRequest

      public Completable cancelRequest()
      Send a request cancellation message to tell the server to cancel processing request in this connection.
      Note: Use this with caution because the cancellation signal may or may not have any effect.
      Returns:
      a future notified if cancelling request is sent

    • rxCancelRequest

      public Completable rxCancelRequest()
      Send a request cancellation message to tell the server to cancel processing request in this connection.
      Note: Use this with caution because the cancellation signal may or may not have any effect.
      Returns:
      a future notified if cancelling request is sent

    • processId

      public int processId()
      Returns:
      The process ID of the target backend

    • secretKey

      public int secretKey()
      Returns:
      The secret key for the target backend

    • exceptionHandler

      public PgConnection exceptionHandler(Handler<Throwable> handler)
      Description copied from class: SqlConnection
      Set an handler called with connection errors.
      Overrides:
      exceptionHandler in class SqlConnection
      Parameters:
      handler -
      Returns:

    • closeHandler

      public PgConnection closeHandler(Handler<Void> handler)
      Description copied from class: SqlConnection
      Set an handler called when the connection is closed.
      Overrides:
      closeHandler in class SqlConnection
      Parameters:
      handler -
      Returns:

    • cast

      public static PgConnection cast(SqlConnection sqlConnection)
      Cast a to PgConnection. This is mostly useful for Vert.x generated APIs like RxJava/Mutiny.
      Parameters:
      sqlConnection - the connection to cast
      Returns:
      a instance

    • newInstance

      public static PgConnection newInstance(PgConnection arg)