Struct libsql_client::transaction::Transaction

pub struct Transaction<'a, Client: DatabaseClient + ?Sized> { /* private fields */ }

Implementations

impl<'a, Client: DatabaseClient + ?Sized> Transaction<'a, Client>

pub async fn new(client: &'a Client) -> Result<Transaction<'a, Client>>

Creates a new transaction.

pub async fn execute(&mut self, stmt: Statement) -> Result<StmtResult>

Executes a statement within the current transaction.

Example

  let mut db = libsql_client::new_client().await?;
  let mut tx = db.transaction().await?;
  tx.execute(Statement::with_params("INSERT INTO users (name) VALUES (?)", params!["John"])).await?;
  let res = tx.execute(Statement::with_params("INSERT INTO users (name) VALUES (?)", params!["Jane"])).await;
  if res.is_err() {
    tx.rollback().await?;
  } else {
    tx.commit().await?;
  }

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

Commits the transaction to the database.

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

Rolls back the transaction, cancelling any of its side-effects.