Struct SharedMySqlTransaction 

pub struct SharedMySqlTransaction<'conn> { /* private fields */ }

Transaction type for SharedMySqlConnection.

This transaction holds a clone of the Arc to the connection and executes transaction operations by acquiring the mutex lock for each operation. The transaction must be committed or rolled back explicitly.

Warning: Uncommitted Transactions

If a transaction is dropped without calling commit() or rollback(), the underlying MySQL transaction will remain open until the connection is closed or a new transaction is started. This is because Rust’s Drop trait cannot perform async operations.

Always explicitly call commit() or rollback() before dropping.

Note: The lifetime parameter is required by the Connection trait but the actual implementation holds an owned Arc, so the transaction can outlive the reference to SharedMySqlConnection if needed.

Trait Implementations

impl<'conn> Drop for SharedMySqlTransaction<'conn>

fn drop(&mut self)

Executes the destructor for this type.

impl<'conn> TransactionOps for SharedMySqlTransaction<'conn>

fn query( &self, cx: &Cx, sql: &str, params: &[Value], ) -> impl Future<Output = Outcome<Vec<Row>, Error>> + Send

Execute a query within this transaction.

fn query_one( &self, cx: &Cx, sql: &str, params: &[Value], ) -> impl Future<Output = Outcome<Option<Row>, Error>> + Send

Execute a query and return the first row, if any.

fn execute( &self, cx: &Cx, sql: &str, params: &[Value], ) -> impl Future<Output = Outcome<u64, Error>> + Send

Execute a statement within this transaction.

fn savepoint( &self, cx: &Cx, name: &str, ) -> impl Future<Output = Outcome<(), Error>> + Send

Create a savepoint within this transaction.

fn rollback_to( &self, cx: &Cx, name: &str, ) -> impl Future<Output = Outcome<(), Error>> + Send

Rollback to a previously created savepoint.

fn release( &self, cx: &Cx, name: &str, ) -> impl Future<Output = Outcome<(), Error>> + Send

Release a savepoint, making the changes permanent within the transaction.

fn commit(self, cx: &Cx) -> impl Future<Output = Outcome<(), Error>> + Send

Commit the transaction, making all changes permanent.

fn rollback(self, cx: &Cx) -> impl Future<Output = Outcome<(), Error>> + Send

Rollback the transaction, discarding all changes.