Struct PgAsyncConnection 

pub struct PgAsyncConnection { /* private fields */ }

Async PostgreSQL connection.

This connection uses asupersync’s TCP stream for non-blocking I/O and supports the extended query protocol for parameter binding.

Implementations

impl PgAsyncConnection

pub async fn connect(_cx: &Cx, config: PgConfig) -> Outcome<Self, Error>

Establish a new async connection to the PostgreSQL server.

pub async fn query_async( &mut self, cx: &Cx, sql: &str, params: &[Value], ) -> Outcome<Vec<Row>, Error>

Run a parameterized query and return all rows.

pub async fn execute_async( &mut self, cx: &Cx, sql: &str, params: &[Value], ) -> Outcome<u64, Error>

Execute a statement and return rows affected.

pub async fn insert_async( &mut self, cx: &Cx, sql: &str, params: &[Value], ) -> Outcome<i64, Error>

Execute an INSERT and return the inserted id.

PostgreSQL requires RETURNING to retrieve generated IDs. This method expects the SQL to return a single-row, single-column result set containing an integer id.

pub async fn ping_async(&mut self, cx: &Cx) -> Outcome<(), Error>

Ping the server.

pub async fn close_async(&mut self, cx: &Cx) -> Outcome<(), Error>

Close the connection.

pub async fn prepare_async( &mut self, cx: &Cx, sql: &str, ) -> Outcome<PreparedStatement, Error>

Prepare a server-side statement and return a reusable handle.

pub async fn query_prepared_async( &mut self, cx: &Cx, stmt: &PreparedStatement, params: &[Value], ) -> Outcome<Vec<Row>, Error>

pub async fn execute_prepared_async( &mut self, cx: &Cx, stmt: &PreparedStatement, params: &[Value], ) -> Outcome<u64, Error>

Trait Implementations

impl Debug for PgAsyncConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.