Struct AsyncPgConnection

pub struct AsyncPgConnection { /* private fields */ }

Available on crate feature postgres only.

A connection to a PostgreSQL database.

Connection URLs should be in the form postgres://[user[:password]@]host/database_name

Checkout the documentation of the tokio_postgres crate for details about the format

Implementations

impl AsyncPgConnection

pub async fn try_from(conn: Client) -> ConnectionResult<Self>

Construct a new AsyncPgConnection instance from an existing tokio_postgres::Client

pub fn cancel_token(&self) -> CancelToken

Constructs a cancellation token that can later be used to request cancellation of a query running on the connection associated with this client.

Trait Implementations

impl AsyncConnection for AsyncPgConnection

async fn establish(database_url: &str) -> ConnectionResult<Self>

Establishes a new connection to the database

fn is_broken(&self) -> bool

Checks if the connection is broken

impl AsyncExecute for AsyncPgConnection

A transaction on a PostgreSQL database.

Supports nested transactions.

type Stream<'conn> = Pin<Box<dyn Stream<Item = Result<PgRow, Error>> + Send + 'conn>>

The inner stream returned by AsyncConnection::load

type Row<'conn> = PgRow

The row type used by the stream returned by AsyncConnection::load

type Backend = Pg

The backend this type connects to

async fn batch_execute(&mut self, query: &str) -> QueryResult<()>

Execute multiple SQL statements within the same string.

impl AsyncTransactional for AsyncPgConnection

type Transaction<'a> = AsyncPgTransaction<'a> where Self: 'a

The associated transaction type for this connection

async fn begin_transaction(&mut self) -> QueryResult<Self::Transaction<'_>>

Begins a new transaction

fn transaction<'a, R, E, F>( &'a mut self, callback: F, ) -> impl Future<Output = Result<R, E>>

where F: for<'t> FnOnce(&'t mut Self::Transaction<'a>) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 't>>, E: From<Error>,

Executes the given function inside of a database transaction

impl<Changes, Output, Tab, V> UpdateAndFetchResults<Changes, Output> for AsyncPgConnection

where Output: Send, Changes: Copy + AsChangeset<Target = Tab> + Send + Identifiable<Table = Tab>, Tab: Table + FindDsl<Changes::Id>, Find<Tab, Changes::Id>: IntoUpdateTarget<Table = Tab, WhereClause = V>, UpdateStatement<Tab, V, Changes::Changeset>: AsQuery, Update<Changes, Changes>: LoadQuery<Self, Output>, V: Send, Changes::Changeset: Send, Tab::FromClause: Send,

async fn update_and_fetch(&mut self, changeset: Changes) -> QueryResult<Output>

See the traits documentation.