Struct moonramp_migration::sea_orm::SqlxPostgresPoolConnection

pub struct SqlxPostgresPoolConnection { /* private fields */ }

Defines a sqlx PostgreSQL pool

Implementations

impl SqlxPostgresPoolConnection

pub async fn execute(&self, stmt: Statement) -> Result<ExecResult, DbErr>

Execute a Statement on a PostgreSQL backend

pub async fn query_one(
    &self,
    stmt: Statement
) -> Result<Option<QueryResult>, DbErr>

Get one result from a SQL query. Returns Option::None if no match was found

pub async fn query_all(
    &self,
    stmt: Statement
) -> Result<Vec<QueryResult, Global>, DbErr>

Get the results of a query returning them as a Vec<QueryResult>

pub async fn stream(&self, stmt: Statement) -> Result<QueryStream, DbErr>

Stream the results of executing a SQL query

pub async fn begin(&self) -> Result<DatabaseTransaction, DbErr>

Bundle a set of SQL statements that execute together.

pub async fn transaction<F, T, E>(
    &self,
    callback: F
) -> Result<T, TransactionError<E>> where
    F: for<'b> FnOnce(&'b DatabaseTransaction) -> Pin<Box<dyn Future<Output = Result<T, E>> + Send + 'b, Global>> + Send,
    T: Send,
    E: Error + Send, 

Create a PostgreSQL transaction

Trait Implementations

impl Clone for SqlxPostgresPoolConnection

fn clone(&self) -> SqlxPostgresPoolConnection

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqlxPostgresPoolConnection

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

Formats the value using the given formatter.