Struct SqlxTx 

pub struct SqlxTx { /* private fields */ }

A transaction on a pooled connection, which goes back to the pool when this is committed or dropped.

sqlx cannot pipeline, so Tx::queued statements run one after another ahead of the next statement – the round trips they always took. On a pool next to the database each is a fraction of a millisecond.

Trait Implementations

impl Tx for SqlxTx

async fn execute( &mut self, sql: &str, params: &[SqlParam], ) -> Result<u64, DbError>

Run a statement for its effect. Returns the rows it affected.

async fn fetch_json( &mut self, sql: &str, params: &[SqlParam], ) -> Result<Vec<Value>, DbError>

Every row as a JSON object keyed by column name, each column decoded by its PostgreSQL type – see row_json::row_to_json for the rules, which every driver has to follow exactly.

async fn fetch_values( &mut self, sql: &str, params: &[SqlParam], ) -> Result<Vec<Vec<Value>>, DbError>

Every row as its columns in order, decoded by the same rules as Tx::fetch_json. For statements whose columns are read by position: a count, a plan, a pair of JSON values.

async fn fetch_raw( &mut self, sql: &str, params: &[SqlParam], count_column: &str, ) -> Result<RawRows, DbError>

The result of a statement whose first column is a body to send as it is: a media type the schema renders itself. See RawRows.

async fn commit(self) -> Result<(), DbError>

Commit the transaction.

fn queue(&mut self, sql: &str, params: &[SqlParam])

Run a statement for its effect, but not yet: it is sent with the next statement, ahead of it, and a failure is reported as that statement’s.

async fn fetch_json_then( &mut self, sql: &str, params: &[SqlParam], then: &str, ) -> FetchedThen

Tx::fetch_json, and then then – a statement with no parameters, whose columns are read by position, as by Tx::fetch_values.

async fn fetch_json_and_commit( self, sql: &str, params: &[SqlParam], ) -> Result<Vec<Value>, DbError>

Tx::fetch_json as the transaction’s last statement, and Tx::commit.

fn fetch_json_then_and_commit( self, sql: &str, params: &[SqlParam], then: &str, ) -> impl Future<Output = FetchedThen> + MaybeSend

where Self: Sized,

Tx::fetch_json_then as the transaction’s last statements, and Tx::commit.