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, id: u64) -> Result<Transaction<'a, Client>>

pub async fn execute(&self, stmt: impl Into<Statement>) -> Result<ResultSet>

Executes a statement within the current transaction.

Example

  let mut db = libsql_client::new_client().await?;
  let tx = db.transaction().await?;
  tx.execute(Statement::with_args("INSERT INTO users (name) VALUES (?)", args!["John"])).await?;
  let res = tx.execute(Statement::with_args("INSERT INTO users (name) VALUES (?)", args!["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.