libsql 0.9.30

The libSQL database library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use crate::{
    connection::Conn,
    params::Params,
    transaction::Tx, Result, TransactionBehavior,
};

use super::connection::SyncedConnection;

pub struct SyncedTx(SyncedConnection);

impl SyncedTx {
    pub(crate) async fn begin(
        conn: SyncedConnection,
        tx_behavior: TransactionBehavior,
    ) -> Result<Self> {
        conn.execute(
            match tx_behavior {
                TransactionBehavior::Deferred => "BEGIN DEFERRED",
                TransactionBehavior::Immediate => "BEGIN IMMEDIATE",
                TransactionBehavior::Exclusive => "BEGIN EXCLUSIVE",
                TransactionBehavior::ReadOnly => "BEGIN READONLY",
            },
            Params::None,
        )
        .await?;
        Ok(Self(conn.clone()))
    }
}

#[async_trait::async_trait]
impl Tx for SyncedTx {
    async fn commit(&mut self) -> Result<()> {
        self.0.execute("COMMIT", Params::None).await?;
        Ok(())
    }

    async fn rollback(&mut self) -> Result<()> {
        self.0.execute("ROLLBACK", Params::None).await?;
        Ok(())
    }
}