Struct PgConnection 

pub struct PgConnection<State> { /* private fields */ }

Typestate wrapper around a pooled Postgres client.

Implementations

impl PgConnection<Idle>

pub async fn from_pool( pool: &Pool<PgManager>, ) -> Result<Self, SqlMiddlewareDbError>

Checkout a connection from the pool.

Errors

Returns SqlMiddlewareDbError if acquiring the connection fails.

impl PgConnection<Idle>

pub async fn execute_batch( &mut self, sql: &str, ) -> Result<(), SqlMiddlewareDbError>

Auto-commit batch (BEGIN/COMMIT around it).

Errors

Returns SqlMiddlewareDbError if the batch execution fails.

pub async fn dml( &mut self, query: &str, params: &[RowValues], ) -> Result<usize, SqlMiddlewareDbError>

Auto-commit DML.

Errors

Returns SqlMiddlewareDbError if executing the DML fails.

impl PgConnection<InTx>

pub async fn execute_batch( &mut self, sql: &str, ) -> Result<(), SqlMiddlewareDbError>

Execute batch inside the open transaction.

Errors

Returns SqlMiddlewareDbError if executing the batch fails.

pub async fn dml( &mut self, query: &str, params: &[RowValues], ) -> Result<usize, SqlMiddlewareDbError>

Execute DML inside the open transaction.

Errors

Returns SqlMiddlewareDbError if executing the DML fails.

impl PgConnection<Idle>

pub async fn select( &mut self, query: &str, params: &[RowValues], ) -> Result<ResultSet, SqlMiddlewareDbError>

Auto-commit SELECT.

Errors

Returns SqlMiddlewareDbError if executing the select fails.

pub fn query<'a>(&'a mut self, sql: &'a str) -> QueryBuilder<'a, 'a>

Start a query builder (auto-commit per operation).

impl PgConnection<InTx>

pub async fn select( &mut self, query: &str, params: &[RowValues], ) -> Result<ResultSet, SqlMiddlewareDbError>

Execute SELECT inside the open transaction.

Errors

Returns SqlMiddlewareDbError if executing the select fails.

pub fn query<'a>(&'a mut self, sql: &'a str) -> QueryBuilder<'a, 'a>

Start a query builder within the open transaction.

impl PgConnection<Idle>

pub async fn begin(self) -> Result<PgConnection<InTx>, SqlMiddlewareDbError>

Begin an explicit transaction.

Errors

Returns SqlMiddlewareDbError if starting the transaction fails.

impl PgConnection<InTx>

pub async fn commit(self) -> Result<PgConnection<Idle>, SqlMiddlewareDbError>

Commit and return to idle.

Errors

Returns SqlMiddlewareDbError if the commit fails.

pub async fn rollback(self) -> Result<PgConnection<Idle>, SqlMiddlewareDbError>

Rollback and return to idle.

Errors

Returns SqlMiddlewareDbError if the rollback fails.

Trait Implementations

impl BeginTx for PgConnection<Idle>

type Tx = PgConnection<InTx>

fn begin(self) -> impl Future<Output = Result<Self::Tx, SqlMiddlewareDbError>>

impl<State> Drop for PgConnection<State>

fn drop(&mut self)

Executes the destructor for this type.

impl Queryable for PgConnection<Idle>

fn query<'a>(&'a mut self, sql: &'a str) -> QueryBuilder<'a, 'a>

impl Queryable for PgConnection<InTx>

fn query<'a>(&'a mut self, sql: &'a str) -> QueryBuilder<'a, 'a>

impl TxConn for PgConnection<InTx>

type Idle = PgConnection<Idle>

fn commit( self, ) -> impl Future<Output = Result<Self::Idle, SqlMiddlewareDbError>>

fn rollback( self, ) -> impl Future<Output = Result<Self::Idle, SqlMiddlewareDbError>>

impl TypedConnOps for PgConnection<Idle>

fn execute_batch( &mut self, sql: &str, ) -> impl Future<Output = Result<(), SqlMiddlewareDbError>>

fn dml( &mut self, query: &str, params: &[RowValues], ) -> impl Future<Output = Result<usize, SqlMiddlewareDbError>>

fn select( &mut self, query: &str, params: &[RowValues], ) -> impl Future<Output = Result<ResultSet, SqlMiddlewareDbError>>

impl TypedConnOps for PgConnection<InTx>

fn execute_batch( &mut self, sql: &str, ) -> impl Future<Output = Result<(), SqlMiddlewareDbError>>

fn dml( &mut self, query: &str, params: &[RowValues], ) -> impl Future<Output = Result<usize, SqlMiddlewareDbError>>

fn select( &mut self, query: &str, params: &[RowValues], ) -> impl Future<Output = Result<ResultSet, SqlMiddlewareDbError>>