PostgresConnection

Topics

Structures

• struct Configuration
  A configuration object for a connection.

Instance Properties

• var closeFuture: EventLoopFuture<Void>
• var eventLoop: any EventLoop
  The underlying EventLoop of both the connection and its channel.
• let id: PostgresConnection.ID
  The connection’s identifier. The identifier is passed to the connection factory method and must stay attached to the connection at all times. It must not change during the connection’s lifetime.
• var isClosed: Bool
• var logger: Logger
  A logger to use for background events.

Instance Methods

• func addListener(channel: String, handler: (PostgresListenContext, PostgresMessage.NotificationResponse) -> Void) -> PostgresListenContext
  Add a handler for NotificationResponse messages on a certain channel. This is used in conjunction with PostgreSQL’s LISTEN/NOTIFY support: to listen on a channel, you add a listener using this method to handle the NotificationResponse messages, then issue a LISTEN query to instruct PostgreSQL to begin sending NotificationResponse messages.
• func authenticate(username: String, database: String?, password: String?, logger: Logger) -> EventLoopFuture<Void>
• func closeGracefully() async throws
  Closes the connection to the server, after all queries that have been created on this connection have been run.
• func copyFrom(table: String, columns: [String], format: PostgresCopyFromFormat, logger: Logger, file: String, line: Int, writeData: nonisolated(nonsending) (PostgresCopyFromWriter) async throws -> Void) async throws
  Copy data into a table using a COPY <table name> FROM STDIN query.
• func copyFromBinary(table: String, columns: [String], options: PostgresCopyFromFormat.BinaryOptions, bufferSize: Int, logger: Logger, file: String, line: Int, writeData: nonisolated(nonsending) (inout PostgresBinaryCopyFromWriter) async throws -> Void) async throws
  Copy data into a table using a COPY <table name> FROM STDIN query, transferring data in a binary format.
• func execute(_:logger:file:line:)
  Execute a prepared statement, taking care of the preparation when necessary.
• func listen(String) async throws -> PostgresNotificationSequence
  Start listening for a channel.
• func listen<Value>(on: String, consume: nonisolated(nonsending) (PostgresNotificationSequence) async throws -> Value) async throws -> Value
  Listen to a channel and run closure with PostgresNotificationSequence.
• func query(_:logger:file:line:)
  Run a query on the Postgres server the connection is connected to.
• func query(PostgresQuery, logger: Logger, file: String, line: Int, (PostgresRow) throws -> ()) -> EventLoopFuture<PostgresQueryMetadata>
  Run a query on the Postgres server the connection is connected to and iterate the rows in a callback.
• func withTransaction<Result>(logger: Logger, file: String, line: Int, isolation: isolated (any Actor)?, nonisolated(nonsending) (PostgresConnection) async throws -> sending Result) async throws -> sending Result
  Puts the connection into an open transaction state, for the provided closure’s lifetime.

Type Aliases

• typealias ID
  A Postgres connection ID.

Type Properties

• static var defaultEventLoopGroup: any EventLoopGroup
  Returns the default EventLoopGroup singleton, automatically selecting the best for the platform.

Type Methods

• static connect(on:configuration:id:logger:)
  Creates a new connection to a Postgres server.
• static func connect(to: SocketAddress, tlsConfiguration: TLSConfiguration?, serverHostname: String?, logger: Logger, on: any EventLoop) -> EventLoopFuture<PostgresConnection>

Default Implementations

• PooledConnection Implementations
• PostgresDatabase Implementations