Struct PgTransactionExecutor 

pub struct PgTransactionExecutor { /* private fields */ }

A transaction owns one checked-out pooled connection for its complete lifetime. Using SQL BEGIN/COMMIT avoids a self-referential wrapper around tokio_postgres::Transaction while preserving connection affinity.

Trait Implementations

impl SqlTransaction for PgTransactionExecutor

type Error = MutationExecutorError

async fn commit_sql(self) -> Result<(), Self::Error>

async fn rollback_sql(self) -> Result<(), Self::Error>

impl SqlTransport for PgTransactionExecutor

type Error = MutationExecutorError

async fn fetch_all_compact_sql( &self, query: &CompiledQuery, ) -> Result<Vec<CompactRow>, Self::Error>

async fn execute_sql(&self, query: &CompiledQuery) -> Result<u64, Self::Error>

fn fetch_repeated_compact_sql( &self, template: &CompiledQuery, param_index: usize, values: &[Value], ) -> impl Future<Output = Result<Vec<CompactRow>, Self::Error>> + Send