Struct Transaction 

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

An RAII transaction guard that automatically rolls back on drop if not committed.

Created via Connection::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. This is enforced at compile time by Rust’s borrow checker.

Example

// Transaction auto-rolls back if commit() is not called
let txn = conn.transaction()?;
txn.execute_command("INSERT INTO users VALUES (1, 'Alice')")?;
txn.execute_command("INSERT INTO users VALUES (2, 'Bob')")?;
txn.commit()?;

Implementations

impl<'conn> Transaction<'conn>

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

Commits the transaction.

Errors

Returns the error from Connection::commit. The transaction is marked completed regardless, so the drop guard will not re-issue a rollback.

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

Rolls back the transaction explicitly.

Errors

Returns the error from Connection::rollback. The transaction is marked completed regardless.

pub fn connection(&self) -> &Connection

Returns a reference to the underlying connection.

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

Executes a SQL command within this transaction.

Errors

Forwards the error from Connection::execute_command.

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

Executes a query and returns streaming results within this transaction.

Errors

Forwards the error from Connection::execute_query.

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

Fetches a single row from a query.

Errors

Forwards the error from Connection::fetch_one.

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

Fetches an optional single row from a query.

Errors

Forwards the error from Connection::fetch_optional.

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

Fetches all rows from a query.

Errors

Forwards the error from Connection::fetch_all.

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

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

Fetches a single scalar value from a query.

Errors

Forwards the error from Connection::fetch_scalar.

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

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

Fetches an optional scalar value from a query.

Errors

Forwards the error from Connection::fetch_optional_scalar.

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

Queries for a count value, defaulting to 0 if NULL.

Errors

Forwards the error from Connection::query_count.

Trait Implementations

impl<'conn> Debug for Transaction<'conn>

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

Formats the value using the given formatter.

impl Drop for Transaction<'_>

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.