Skip to main content

PgConnection

Struct PgConnection 

Source
pub struct PgConnection { /* private fields */ }
Expand description

A raw PostgreSQL connection.

Implementations§

Source§

impl PgConnection

Source

pub fn get_cancel_key_bytes(&self) -> (i32, &[u8])

Get the full cancel key bytes for this connection.

Source

pub async fn cancel_query_bytes( host: &str, port: u16, process_id: i32, secret_key: &[u8], ) -> PgResult<()>

Cancel a running query using bytes-native cancel key.

Source§

impl PgConnection

Source

pub async fn connect( host: &str, port: u16, user: &str, database: &str, ) -> PgResult<Self>

Connect to PostgreSQL server without authentication (trust mode).

§Arguments
  • host — PostgreSQL server hostname or IP.
  • port — TCP port (typically 5432).
  • user — PostgreSQL role name.
  • database — Target database name.
Source

pub async fn connect_with_password( host: &str, port: u16, user: &str, database: &str, password: Option<&str>, ) -> PgResult<Self>

Connect to PostgreSQL server with optional password authentication. Includes a default 10-second timeout covering TCP connect + handshake.

Startup requests protocol 3.2 by default and performs a one-shot retry with protocol 3.0 only when startup fails due to explicit protocol-version rejection from the server.

Source

pub async fn connect_with_options( host: &str, port: u16, user: &str, database: &str, password: Option<&str>, options: ConnectOptions, ) -> PgResult<Self>

Connect to PostgreSQL with explicit enterprise options.

Negotiation preface order follows libpq:

  1. If gss_enc_mode != Disable → try GSSENCRequest on fresh TCP
  2. If GSSENC rejected/unavailable and tls_mode != Disable → try SSLRequest
  3. If both rejected/unavailable → plain StartupMessage

The StartupMessage protocol version behavior is the same as connect_with_password: request protocol 3.2 first, then retry once with 3.0 only on explicit protocol-version rejection.

Source

pub async fn connect_with_password_and_auth( host: &str, port: u16, user: &str, database: &str, password: Option<&str>, auth_settings: AuthSettings, ) -> PgResult<Self>

Connect to PostgreSQL server with optional password authentication and auth policy.

Source

pub async fn connect_tls( host: &str, port: u16, user: &str, database: &str, password: Option<&str>, ) -> PgResult<Self>

Connect to PostgreSQL server with TLS encryption. Includes a default 10-second timeout covering TCP connect + TLS + handshake.

Source

pub async fn connect_tls_with_auth( host: &str, port: u16, user: &str, database: &str, password: Option<&str>, auth_settings: AuthSettings, ca_cert_pem: Option<&[u8]>, ) -> PgResult<Self>

Connect to PostgreSQL over TLS with explicit auth policy and optional custom CA bundle.

Source

pub async fn connect_mtls( host: &str, port: u16, user: &str, database: &str, config: TlsConfig, ) -> PgResult<Self>

Connect with mutual TLS (client certificate authentication).

§Arguments
  • host - PostgreSQL server hostname
  • port - PostgreSQL server port
  • user - Database user
  • database - Database name
  • config - TLS configuration with client cert/key
§Example
let config = TlsConfig {
    client_cert_pem: include_bytes!("client.crt").to_vec(),
    client_key_pem: include_bytes!("client.key").to_vec(),
    ca_cert_pem: Some(include_bytes!("ca.crt").to_vec()),
};
let conn = PgConnection::connect_mtls("localhost", 5432, "user", "db", config).await?;
Source

pub async fn connect_mtls_with_password_and_auth( host: &str, port: u16, user: &str, database: &str, password: Option<&str>, config: TlsConfig, auth_settings: AuthSettings, ) -> PgResult<Self>

Connect with mutual TLS and optional password fallback.

Source

pub async fn connect_unix( socket_path: &str, user: &str, database: &str, password: Option<&str>, ) -> PgResult<Self>

Connect to PostgreSQL server via Unix domain socket.

Source§

impl PgConnection

Source

pub async fn close(self) -> PgResult<()>

Gracefully close the connection by sending a Terminate message. This tells the server we’re done and allows proper cleanup.

Source§

impl PgConnection

Source

pub fn requested_protocol_minor(&self) -> u16

Startup protocol minor requested by this connection.

Source

pub fn negotiated_protocol_minor(&self) -> u16

Startup protocol minor negotiated with the server.

Source

pub fn transport_backend(&self) -> &'static str

Active transport backend label for this connection.

Returns "tokio" or "io_uring" for plain TCP connections, and "tokio" for TLS/Unix/GSSENC paths.

Source§

impl PgConnection

Source

pub async fn copy_in_raw( &mut self, table: &str, columns: &[String], data: &[u8], ) -> PgResult<u64>

Fastest bulk insert using COPY protocol with pre-encoded data. Accepts raw COPY text format bytes, no encoding needed. Use when caller has already encoded rows to COPY format.

§Format

Data should be tab-separated rows with newlines: 1\thello\t3.14\n2\tworld\t2.71\n

Source

pub async fn copy_export(&mut self, cmd: &Qail) -> PgResult<Vec<Vec<String>>>

Export data using COPY TO STDOUT (AST-native). Takes a Qail::Export and returns rows as Vec<Vec<String>>.

§Example
let cmd = Qail::export("users")
    .columns(["id", "name"]);
let rows = conn.copy_export(&cmd).await?;
Source

pub async fn copy_export_stream_raw<F, Fut>( &mut self, cmd: &Qail, on_chunk: F, ) -> PgResult<()>
where F: FnMut(Vec<u8>) -> Fut, Fut: Future<Output = PgResult<()>>,

Stream COPY TO STDOUT chunks using an AST-native Qail::Export command.

Chunks are forwarded as they arrive from PostgreSQL, so memory usage stays bounded by network frame size and callback processing.

Source

pub async fn copy_export_stream_rows<F>( &mut self, cmd: &Qail, on_row: F, ) -> PgResult<()>
where F: FnMut(Vec<String>) -> PgResult<()>,

Stream COPY TO STDOUT rows using an AST-native Qail::Export command.

Parses PostgreSQL COPY text lines into Vec<String> rows and invokes on_row for each row without buffering the full result.

Source§

impl PgConnection

Source

pub async fn send(&mut self, msg: FrontendMessage) -> PgResult<()>

Send a frontend message.

Source

pub async fn recv(&mut self) -> PgResult<BackendMessage>

Loops until a complete message is available. Automatically buffers NotificationResponse messages for LISTEN/NOTIFY.

Source

pub async fn send_bytes(&mut self, bytes: &[u8]) -> PgResult<()>

Send raw bytes to the stream. Includes flush for TLS safety — TLS buffers internally and needs flush to push encrypted data to the underlying TCP socket.

Source

pub fn buffer_bytes(&mut self, bytes: &[u8])

Buffer bytes for later flush (NO SYSCALL). Use flush_write_buf() to send all buffered data.

Source

pub async fn flush_write_buf(&mut self) -> PgResult<()>

Flush the write buffer to the stream (single write_all + flush). The flush is critical for TLS connections.

Source§

impl PgConnection

Source

pub async fn listen(&mut self, channel: &str) -> PgResult<()>

Subscribe to a notification channel.

conn.listen("price_calendar_changed").await?;
Source

pub async fn unlisten(&mut self, channel: &str) -> PgResult<()>

Unsubscribe from a notification channel.

Source

pub async fn unlisten_all(&mut self) -> PgResult<()>

Unsubscribe from all notification channels.

Source

pub fn poll_notifications(&mut self) -> Vec<Notification>

Drain all buffered notifications without blocking.

Notifications arrive asynchronously from PostgreSQL and are buffered whenever recv() encounters a NotificationResponse. This method returns all currently buffered notifications.

Source

pub async fn recv_notification(&mut self) -> PgResult<Notification>

Wait for the next notification, blocking until one arrives.

Unlike recv(), this does NOT use the 30-second Slowloris timeout guard. LISTEN connections idle for long periods — that’s normal, not a DoS attack.

Useful for a dedicated LISTEN connection in a background task.

Source§

impl PgConnection

Source

pub async fn query_pipeline( &mut self, queries: &[(&str, &[Option<Vec<u8>>])], ) -> PgResult<Vec<Vec<Vec<Option<Vec<u8>>>>>>

Execute multiple SQL queries in a single network round-trip (PIPELINING).

Source

pub async fn query_pipeline_count( &mut self, queries: &[(&str, &[Option<Vec<u8>>])], ) -> PgResult<usize>

Execute multiple uncached SQL queries in one round-trip and drain completion without materializing rows.

Source

pub async fn query_pipeline_visit_bytes_rows<F>( &mut self, queries: &[(&str, &[Option<Vec<u8>>])], on_row: F, ) -> PgResult<usize>
where F: FnMut(&PgBytesRow) -> PgResult<()>,

Execute multiple uncached SQL queries in one round-trip and stream result rows through a zero-copy visitor.

Source

pub async fn query_pipeline_visit_first_column_bytes<F>( &mut self, queries: &[(&str, &[Option<Vec<u8>>])], on_value: F, ) -> PgResult<usize>
where F: FnMut(Option<&[u8]>) -> PgResult<()>,

Execute multiple uncached SQL queries in one round-trip and stream only the first column of each row.

Source

pub async fn pipeline_execute_rows_ast( &mut self, cmds: &[Qail], ) -> PgResult<Vec<Vec<Vec<Option<Vec<u8>>>>>>

Execute multiple Qail ASTs in a single network round-trip.

Source

pub async fn pipeline_execute_count_ast_oneshot( &mut self, cmds: &[Qail], ) -> PgResult<usize>

FAST AST pipeline - returns only query count, no result parsing.

Source

pub async fn pipeline_execute_count_ast_with_mode( &mut self, cmds: &[Qail], mode: AstPipelineMode, ) -> PgResult<usize>

Execute AST pipeline with explicit strategy mode.

Auto uses a lightweight batch-size heuristic:

  • < 8 queries: one-shot path (pipeline_execute_count_ast_oneshot)
  • >= 8 queries: cached path (pipeline_execute_count_ast_cached)
Source

pub async fn pipeline_execute_count_wire( &mut self, wire_bytes: &[u8], expected_queries: usize, ) -> PgResult<usize>

FASTEST extended query pipeline - takes pre-encoded wire bytes.

Source

pub async fn pipeline_execute_count_simple_ast( &mut self, cmds: &[Qail], ) -> PgResult<usize>

Simple query protocol pipeline - uses ‘Q’ message.

Source

pub async fn pipeline_execute_count_simple_wire( &mut self, wire_bytes: &[u8], expected_queries: usize, ) -> PgResult<usize>

FASTEST simple query pipeline - takes pre-encoded bytes.

Source

pub async fn pipeline_execute_count_ast_cached( &mut self, cmds: &[Qail], ) -> PgResult<usize>

CACHED PREPARED STATEMENT pipeline - Parse once, Bind+Execute many.

  1. Generate SQL template with $1, $2, etc. placeholders
  2. Parse template ONCE (cached in PostgreSQL)
  3. Send Bind+Execute for each instance (params differ per query)
Source

pub async fn pipeline_execute_prepared_count( &mut self, stmt: &PreparedStatement, params_batch: &[Vec<Option<Vec<u8>>>], ) -> PgResult<usize>

ZERO-LOOKUP prepared statement pipeline.

  • Hash computation per query
  • HashMap lookup per query
  • String allocation for stmt_name
§Example
// Prepare once (outside timing loop):
let stmt = PreparedStatement::from_sql("SELECT id, name FROM harbors LIMIT $1");
let params_batch: Vec<Vec<Option<Vec<u8>>>> = (1..=1000)
    .map(|i| vec![Some(i.to_string().into_bytes())])
    .collect();
// Execute many (no hash, no lookup!):
conn.pipeline_execute_prepared_count(&stmt, &params_batch).await?;
Source

pub async fn prepare(&mut self, sql: &str) -> PgResult<PreparedStatement>

Prepare a statement and return a handle for fast execution. PreparedStatement handle for use with pipeline_execute_prepared_count.

Source

pub async fn pipeline_execute_prepared_rows( &mut self, stmt: &PreparedStatement, params_batch: &[Vec<Option<Vec<u8>>>], ) -> PgResult<Vec<Vec<Vec<Option<Vec<u8>>>>>>

Execute a prepared statement pipeline and return all row data.

Source

pub async fn pipeline_execute_prepared_rows_bytes( &mut self, stmt: &PreparedStatement, params_batch: &[Vec<Option<Vec<u8>>>], ) -> PgResult<Vec<Vec<Vec<Option<Bytes>>>>>

ZERO-COPY pipeline execution with Bytes for column data.

Source

pub async fn pipeline_execute_prepared_visit_rows<F>( &mut self, stmt: &PreparedStatement, params_batch: &[Vec<Option<Vec<u8>>>], on_row: F, ) -> PgResult<usize>
where F: FnMut(&[Option<Vec<u8>>]) -> PgResult<()>,

Pipeline execution with row visitor.

Rows are streamed to on_row as owned column buffers, avoiding materializing the full result set.

Source

pub async fn pipeline_execute_prepared_visit_bytes_rows<F>( &mut self, stmt: &PreparedStatement, params_batch: &[Vec<Option<Vec<u8>>>], on_row: F, ) -> PgResult<usize>
where F: FnMut(&PgBytesRow) -> PgResult<()>,

Pipeline execution with zero-copy row visitor.

Rows are backed by one shared payload buffer plus column offsets, avoiding per-cell byte copies during receive.

Source

pub async fn pipeline_execute_prepared_visit_first_column_bytes<F>( &mut self, stmt: &PreparedStatement, params_batch: &[Vec<Option<Vec<u8>>>], on_value: F, ) -> PgResult<usize>
where F: FnMut(Option<&[u8]>) -> PgResult<()>,

Pipeline execution with first-column visitor for scalar result sets.

Source

pub async fn pipeline_execute_prepared_visit_first_four_columns_bytes<F>( &mut self, stmt: &PreparedStatement, params_batch: &[Vec<Option<Vec<u8>>>], on_row: F, ) -> PgResult<usize>
where F: FnMut([Option<&[u8]>; 4]) -> PgResult<()>,

Pipeline execution with fixed 4-column visitor for scalar result sets.

Source

pub async fn pipeline_execute_prepared_rows_2cols_bytes( &mut self, stmt: &PreparedStatement, params_batch: &[Vec<Option<Vec<u8>>>], ) -> PgResult<Vec<Vec<(Bytes, Bytes)>>>

ULTRA-FAST pipeline for 2-column SELECT queries.

Source§

impl PgConnection

Source

pub async fn query_count( &mut self, sql: &str, params: &[Option<Vec<u8>>], ) -> PgResult<()>

Execute an uncached query and drain completion without materializing rows.

Source

pub async fn query_count_with_param_types( &mut self, sql: &str, param_types: &[u32], params: &[Option<Vec<u8>>], ) -> PgResult<()>

Execute an uncached query with explicit PostgreSQL parameter type OIDs and drain completion without materializing rows.

Source

pub async fn query_rows( &mut self, sql: &str, params: &[Option<Vec<u8>>], ) -> PgResult<Vec<PgRow>>

Execute a query with bind parameters and return rows with column metadata.

Uses the Extended Query Protocol without prepared statement caching. This is intended for raw SQL compatibility paths that still need PgRow + ColumnInfo for name-aware JSON conversion.

Source

pub async fn query_rows_with_result_format( &mut self, sql: &str, params: &[Option<Vec<u8>>], result_format: i16, ) -> PgResult<Vec<PgRow>>

Execute a query with bind parameters and explicit result-column format, returning rows with column metadata.

Source

pub async fn query_visit_bytes_rows_with_result_format<F>( &mut self, sql: &str, params: &[Option<Vec<u8>>], result_format: i16, on_row: F, ) -> PgResult<usize>
where F: FnMut(&PgBytesRow) -> PgResult<()>,

Execute an uncached query and stream zero-copy rows to on_row.

This is the lowest-allocation raw-SQL path for large result sets when the caller does not need PgRow materialization or column-name metadata.

Source

pub async fn query_visit_first_column_bytes_with_result_format<F>( &mut self, sql: &str, params: &[Option<Vec<u8>>], result_format: i16, on_value: F, ) -> PgResult<usize>
where F: FnMut(Option<&[u8]>) -> PgResult<()>,

Execute an uncached query and stream only the first column of each row.

Source

pub async fn query_rows_with_param_types_and_result_format( &mut self, sql: &str, param_types: &[u32], params: &[Option<Vec<u8>>], result_format: i16, ) -> PgResult<Vec<PgRow>>

Execute a query with explicit PostgreSQL parameter type OIDs and return rows with column metadata.

Source

pub async fn query_visit_bytes_rows_with_param_types_and_result_format<F>( &mut self, sql: &str, param_types: &[u32], params: &[Option<Vec<u8>>], result_format: i16, on_row: F, ) -> PgResult<usize>
where F: FnMut(&PgBytesRow) -> PgResult<()>,

Execute an uncached query with explicit PostgreSQL parameter types and stream zero-copy rows to on_row.

Rows are backed by one shared payload buffer plus column offsets, so the callback must not hold references past the current invocation.

Source

pub async fn query_visit_first_column_bytes_with_param_types_and_result_format<F>( &mut self, sql: &str, param_types: &[u32], params: &[Option<Vec<u8>>], result_format: i16, on_value: F, ) -> PgResult<usize>
where F: FnMut(Option<&[u8]>) -> PgResult<()>,

Execute an uncached query with explicit PostgreSQL parameter types and stream only the first column of each row.

Source

pub async fn probe_query_with_param_types( &mut self, sql: &str, param_types: &[u32], params: &[Option<Vec<u8>>], ) -> PgResult<()>

Validate a query with explicit PostgreSQL parameter type OIDs without executing it. Uses Parse + Bind + Describe(Portal) + Sync.

Source

pub async fn query_cached( &mut self, sql: &str, params: &[Option<Vec<u8>>], ) -> PgResult<Vec<Vec<Option<Vec<u8>>>>>

Execute a query with cached prepared statement. Like query(), but reuses prepared statements across calls. The statement name is derived from a hash of the SQL text. OPTIMIZED: Pre-allocated buffer + ultra-fast encoders.

Source

pub async fn query_cached_with_result_format( &mut self, sql: &str, params: &[Option<Vec<u8>>], result_format: i16, ) -> PgResult<Vec<Vec<Option<Vec<u8>>>>>

Execute a query with cached prepared statement and explicit result-column format.

Source

pub async fn execute_simple(&mut self, sql: &str) -> PgResult<()>

Execute a simple SQL statement (no parameters).

Source

pub async fn simple_query(&mut self, sql: &str) -> PgResult<Vec<PgRow>>

Execute a simple SQL query and return rows (Simple Query Protocol).

Unlike execute_simple, this collects and returns data rows. Used for branch management and other administrative queries.

SECURITY: Capped at 10,000 rows to prevent OOM from unbounded results.

Source

pub async fn query_prepared_single( &mut self, stmt: &PreparedStatement, params: &[Option<Vec<u8>>], ) -> PgResult<Vec<Vec<Option<Vec<u8>>>>>

ZERO-HASH sequential query using pre-computed PreparedStatement. This is the FASTEST sequential path because it skips:

  • SQL generation from AST (done once outside loop)
  • Hash computation for statement name (pre-computed in PreparedStatement)
  • HashMap lookup for is_new check (statement already prepared)
§Example
let stmt = conn.prepare("SELECT * FROM users WHERE id = $1").await?;
for id in 1..10000 {
    let rows = conn.query_prepared_single(&stmt, &[Some(id.to_string().into_bytes())]).await?;
}
Source

pub async fn query_prepared_single_count( &mut self, stmt: &PreparedStatement, params: &[Option<Vec<u8>>], ) -> PgResult<()>

ZERO-HASH sequential prepared execution that drains rows without materializing them.

Useful for throughput-focused paths where only protocol completion matters and result payload is intentionally ignored.

Source

pub async fn query_prepared_single_with_result_format( &mut self, stmt: &PreparedStatement, params: &[Option<Vec<u8>>], result_format: i16, ) -> PgResult<Vec<Vec<Option<Vec<u8>>>>>

ZERO-HASH sequential query with explicit result-column format.

Source

pub async fn query_prepared_single_reuse_with_result_format( &mut self, stmt: &PreparedStatement, params: &[Option<Vec<u8>>], result_format: i16, ) -> PgResult<Vec<Vec<Option<Vec<u8>>>>>

ZERO-HASH sequential query with explicit result-column format using reusable connection buffers (avoids per-call BytesMut allocation).

Source

pub async fn query_prepared_single_reuse_visit_rows_with_result_format<F>( &mut self, stmt: &PreparedStatement, params: &[Option<Vec<u8>>], result_format: i16, on_row: F, ) -> PgResult<usize>
where F: FnMut(&[Option<Vec<u8>>]) -> PgResult<()>,

Sequential prepared query using reusable connection buffers and row visitor.

Rows are streamed to on_row as owned column buffers, avoiding materializing the full result set.

Source

pub async fn query_prepared_single_reuse_visit_bytes_rows_with_result_format<F>( &mut self, stmt: &PreparedStatement, params: &[Option<Vec<u8>>], result_format: i16, on_row: F, ) -> PgResult<usize>
where F: FnMut(&PgBytesRow) -> PgResult<()>,

Sequential prepared query using reusable connection buffers and zero-copy row visitor.

Rows are backed by a shared payload buffer plus column offsets, avoiding per-cell byte copies during receive.

Source

pub async fn query_prepared_single_reuse_visit_first_column_bytes_with_result_format<F>( &mut self, stmt: &PreparedStatement, params: &[Option<Vec<u8>>], result_format: i16, on_value: F, ) -> PgResult<usize>
where F: FnMut(Option<&[u8]>) -> PgResult<()>,

Sequential prepared query using reusable buffers and first-column visitor.

Source

pub async fn query_prepared_single_reuse_visit_first_four_columns_bytes_with_result_format<F>( &mut self, stmt: &PreparedStatement, params: &[Option<Vec<u8>>], result_format: i16, on_row: F, ) -> PgResult<usize>
where F: FnMut([Option<&[u8]>; 4]) -> PgResult<()>,

Sequential prepared query using reusable buffers and fixed 4-column visitor.

Source

pub async fn query_prepared_single_encoded_visit_bytes_rows<F>( &mut self, wire: &[u8], on_row: F, ) -> PgResult<usize>
where F: FnMut(&PgBytesRow) -> PgResult<()>,

Sequential prepared query from pre-encoded Bind/Execute/Sync wire bytes.

wire must contain exactly one prepared-statement execution.

Source

pub async fn query_prepared_single_encoded_visit_bytes_rows_profiled<F>( &mut self, wire: &[u8], on_row: F, ) -> PgResult<(usize, Duration, Duration)>
where F: FnMut(&PgBytesRow) -> PgResult<()>,

Sequential prepared query from pre-encoded Bind/Execute/Sync wire bytes.

Returns (rows, send_elapsed, consume_elapsed).

Source

pub async fn query_prepared_single_encoded_visit_first_column_bytes<F>( &mut self, wire: &[u8], on_value: F, ) -> PgResult<usize>
where F: FnMut(Option<&[u8]>) -> PgResult<()>,

Sequential prepared query from pre-encoded Bind/Execute/Sync wire bytes.

Source

pub async fn query_prepared_single_encoded_visit_first_column_bytes_profiled<F>( &mut self, wire: &[u8], on_value: F, ) -> PgResult<(usize, Duration, Duration)>
where F: FnMut(Option<&[u8]>) -> PgResult<()>,

Sequential prepared query from pre-encoded Bind/Execute/Sync wire bytes.

Returns (rows, send_elapsed, consume_elapsed).

Source

pub async fn query_prepared_single_encoded_visit_first_four_columns_bytes<F>( &mut self, wire: &[u8], on_row: F, ) -> PgResult<usize>
where F: FnMut([Option<&[u8]>; 4]) -> PgResult<()>,

Sequential prepared query from pre-encoded Bind/Execute/Sync wire bytes.

Source

pub async fn query_prepared_single_encoded_visit_first_four_columns_bytes_profiled<F>( &mut self, wire: &[u8], on_row: F, ) -> PgResult<(usize, Duration, Duration)>
where F: FnMut([Option<&[u8]>; 4]) -> PgResult<()>,

Sequential prepared query from pre-encoded Bind/Execute/Sync wire bytes.

Returns (rows, send_elapsed, consume_elapsed).

Source§

impl PgConnection

Source

pub async fn identify_system(&mut self) -> PgResult<IdentifySystem>

Run IDENTIFY_SYSTEM on a replication connection.

Source

pub async fn create_logical_replication_slot( &mut self, slot_name: &str, output_plugin: &str, temporary: bool, two_phase: bool, ) -> PgResult<ReplicationSlotInfo>

Create a logical replication slot.

slot_name and output_plugin are strict SQL identifiers.

Source

pub async fn drop_replication_slot( &mut self, slot_name: &str, wait: bool, ) -> PgResult<()>

Drop a replication slot.

wait=true uses DROP_REPLICATION_SLOT <slot> WAIT.

Source

pub async fn start_logical_replication( &mut self, slot_name: &str, start_lsn: &str, options: &[ReplicationOption], ) -> PgResult<ReplicationStreamStart>

Start logical replication in CopyBoth mode.

Requires a connection started with replication=database.

Source

pub async fn recv_replication_message( &mut self, ) -> PgResult<ReplicationStreamMessage>

Receive the next logical replication stream message.

Uses a no-timeout read path so idle periods do not fail the stream.

Source

pub async fn send_standby_status_update( &mut self, write_lsn: u64, flush_lsn: u64, apply_lsn: u64, reply_requested: bool, ) -> PgResult<()>

Send a standby status update (CopyData('r' ...)) to the server.

Source§

impl PgConnection

Source

pub async fn begin_transaction(&mut self) -> PgResult<()>

Begin a new transaction. After calling this, all queries run within the transaction until commit() or rollback() is called.

Source

pub async fn commit(&mut self) -> PgResult<()>

Commit the current transaction. Makes all changes since begin_transaction() permanent.

Source

pub async fn rollback(&mut self) -> PgResult<()>

Rollback the current transaction. Discards all changes since begin_transaction().

Source

pub async fn savepoint(&mut self, name: &str) -> PgResult<()>

Create a named savepoint within the current transaction. Savepoints allow partial rollback within a transaction. Use rollback_to() to return to this savepoint.

Source

pub async fn rollback_to(&mut self, name: &str) -> PgResult<()>

Rollback to a previously created savepoint. Discards all changes since the named savepoint was created, but keeps the transaction open.

Source

pub async fn release_savepoint(&mut self, name: &str) -> PgResult<()>

Release a savepoint (free resources, if no longer needed).

Trait Implementations§

Source§

impl Drop for PgConnection

Drop implementation sends Terminate packet if possible. This ensures proper cleanup even without explicit close() call.

Source§

fn drop(&mut self)

Executes the destructor for this type. Read more
Source§

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)
Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> ColumnValue<Value> for T

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more