Struct PostgresConnection 

pub struct PostgresConnection { /* private fields */ }

PostgreSQL connection.

Trait Implementations

impl Connection for PostgresConnection

async fn connect( driver: &PostgresDriver, url: Cow<'static, str>, ) -> Result<Self>

Establishes a connection (or pool) to the database specified by the URL.

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

Starts a new transaction on this connection.

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

Closes the connection and releases any session resources.

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

where Self: Sized,

Validates and normalizes the connection URL, handling special cases like in-memory databases.

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<PostgresDriver>>

Internal hook for implementing prepared statement support.

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

Executes a query and streams the results (rows or affected counts).

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

Executes a query and streams the resulting rows, ignoring affected counts.

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,

Efficiently inserts a collection of entities bypassing regular SQL execution when supported by the driver.

fn accepts_multiple_statements(&self) -> bool

Checks if the driver supports multiple SQL statements in a single request.

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

where Self: Sized,

Returns the driver instance associated with this executor.

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

Prepares a query for execution, returning a handle to the prepared statement.

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

Executes a query and returns the total number of affected rows.