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 pool with at least one connection established to the given URL

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

impl Executor for PostgresConnection

type Driver = PostgresDriver

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

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

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

General method to send any query and return any result type (either row or count)

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

Execute the query and returns the rows.

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

Execute the query and return the total number of rows affected.

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. Defaults to insert query for drivers that do not support this feature.