Struct PgConnection 

pub struct PgConnection { /* private fields */ }

A wrapper around a PostgreSQL connection with statement caching.

Implementations

impl PgConnection

pub async fn query( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> PgResult<Vec<Row>>

Execute a query and return all rows.

pub async fn query_one( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> PgResult<Row>

Execute a query and return exactly one row.

pub async fn query_opt( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> PgResult<Option<Row>>

Execute a query and return zero or one row.

pub async fn execute( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> PgResult<u64>

Execute a statement and return the number of affected rows.

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

Execute a batch of statements in a single round-trip.

pub async fn transaction(&mut self) -> PgResult<PgTransaction<'_>>

Begin a transaction.

pub fn inner(&self) -> &Object

Get the underlying tokio-postgres client.

This is useful for advanced operations not covered by this wrapper.

pub async fn query_cached( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> PgResult<Vec<Row>>

Execute a query using the prepared statement cache.

This is an alias for query that makes it explicit that statement caching is being used. All query methods already use prepared statement caching, but this method name makes it more explicit for benchmark comparisons.

pub async fn query_raw( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> PgResult<Vec<Row>>

Execute a raw query without using the prepared statement cache.

This is useful for one-off queries where the overhead of preparing a statement isn’t worth it.

pub async fn query_opt_raw( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> PgResult<Option<Row>>

Execute a raw query and return zero or one row without using statement cache.