Struct PostgresConnection 

pub struct PostgresConnection { /* private fields */ }

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<()>

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

Underlying driver type supplying SQL dialect + I/O.

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

Access the driver instance.

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

Prepare a query (e.g. statement caching / parameter binding) returning a Query.

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

Run an already prepared query, streaming heterogeneous QueryResult items.

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

Run a query and stream only labeled rows, filtering out non-row results.

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

Execute a query and return a single aggregated RowsAffected.

fn append<'a, E, It>( &mut self, entities: It, ) -> impl Future<Output = Result<RowsAffected, Error>> + Send

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

Append entities to a table.