Struct AsyncTransaction 

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

An async RAII transaction guard.

Created via AsyncConnection::transaction(). This exclusively borrows the connection for the lifetime of the transaction, preventing any other code from using the raw connection while the transaction is active. Always explicitly call commit() or rollback() — the Drop implementation cannot issue async rollback and will only emit a warning.

Example

let txn = conn.transaction().await?;
txn.execute_command("INSERT INTO users VALUES (1, 'Alice')").await?;
txn.commit().await?;

Implementations

impl<'conn> AsyncTransaction<'conn>

pub async fn commit(self) -> Result<()>

Commits the transaction.

Errors

Forwards the error from AsyncConnection::commit. The transaction is marked completed regardless, so the drop guard will not warn.

pub async fn rollback(self) -> Result<()>

Rolls back the transaction explicitly.

Errors

Forwards the error from AsyncConnection::rollback. The transaction is marked completed regardless.

pub fn connection(&self) -> &AsyncConnection

Returns a reference to the underlying async connection.

pub async fn execute_command(&self, sql: &str) -> Result<u64>

Executes a SQL command within this transaction.

Errors

Forwards the error from AsyncConnection::execute_command.

pub async fn execute_query(&self, query: &str) -> Result<AsyncRowset<'_>>

Executes a streaming query within this transaction.

Errors

Forwards the error from AsyncConnection::execute_query.

pub async fn fetch_one<Q: AsRef<str>>(&self, query: Q) -> Result<Row>

Fetches a single row, erroring if zero rows are returned.

Errors

Forwards the error from AsyncConnection::fetch_one.

pub async fn fetch_optional<Q: AsRef<str>>( &self, query: Q, ) -> Result<Option<Row>>

Fetches a single row or None.

Errors

Forwards the error from AsyncConnection::fetch_optional.

pub async fn fetch_all<Q: AsRef<str>>(&self, query: Q) -> Result<Vec<Row>>

Fetches all rows from the query.

Errors

Forwards the error from AsyncConnection::fetch_all.

pub async fn fetch_scalar<T, Q>(&self, query: Q) -> Result<T>

where T: RowValue, Q: AsRef<str>,

Fetches a single non-NULL scalar; errors if empty or NULL.

Errors

Forwards the error from AsyncConnection::fetch_scalar.

pub async fn fetch_optional_scalar<T, Q>(&self, query: Q) -> Result<Option<T>>

where T: RowValue, Q: AsRef<str>,

Fetches a single scalar, allowing NULL as None.

Errors

Forwards the error from AsyncConnection::fetch_optional_scalar.

pub async fn query_count(&self, query: &str) -> Result<i64>

Returns a count from a SELECT COUNT(*) style query.

Errors

Forwards the error from AsyncConnection::query_count.

pub async fn query_params( &self, query: &str, params: &[&dyn ToSqlParam], ) -> Result<AsyncRowset<'_>>

Executes a parameterized query within this transaction.

Errors

Forwards the error from AsyncConnection::query_params.

pub async fn command_params( &self, query: &str, params: &[&dyn ToSqlParam], ) -> Result<u64>

Executes a parameterized command within this transaction.

Errors

Forwards the error from AsyncConnection::command_params.

Trait Implementations

impl<'conn> Debug for AsyncTransaction<'conn>

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

Formats the value using the given formatter.

impl Drop for AsyncTransaction<'_>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.