Struct PostgresConnection 

pub struct PostgresConnection { /* private fields */ }

Connection wrapper for Postgres/Tokio Postgres client.

Manages the client handle and background task used to drive the connection and implements Executor for running queries against Postgres.

Trait Implementations

impl Connection for PostgresConnection

async fn connect(url: Cow<'static, str>) -> Result<PostgresConnection>

Create a connection (or pool) with at least one underlying session established to the given URL.

fn begin(&mut self) -> impl Future<Output = Result<PostgresTransaction<'_>>>

Begin a transaction scope tied to the current connection.

async fn disconnect(self) -> Result<()>

Disconnect and release the underlying session(s).

fn sanitize_url(url: Cow<'static, str>) -> Result<Url, Error>

where Self: Sized,

impl Debug for PostgresConnection

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

Formats the value using the given formatter.

impl Executor for PostgresConnection

type Driver = PostgresDriver

Associated driver.

async fn do_prepare(&mut self, sql: String) -> Result<Query<Self::Driver>>

Prepare a query for later execution.

fn run<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Stream<Item = Result<QueryResult>> + Send

Run a query, streaming QueryResult items.

fn fetch<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Stream<Item = Result<RowLabeled>> + Send

Stream only labeled rows (filters non-row results).

async fn append<'a, E, It>(&mut self, entities: It) -> Result<RowsAffected>

where E: Entity + 'a, It: IntoIterator<Item = &'a E> + Send, <It as IntoIterator>::IntoIter: Send,

Insert many entities efficiently.

fn accepts_multiple_statements(&self) -> bool

Returns true if the executor accepts multiple SQL statements in a single request (e.g. CREATE; INSERT; SELECT). Defaults to true.

fn driver(&self) -> Self::Driver

where Self: Sized,

Driver instance.

fn prepare<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Future<Output = Result<Query<Self::Driver>, Error>> + Send

Prepare a query for later execution.

fn execute<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Future<Output = Result<RowsAffected, Error>> + Send

Execute and aggregate affected rows.