mylibsql 0.1.2

A personal take on libsql, enabling SQLite replication with application-controlled checkpointing—no dedicated server required
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

use anyhow::Result;
use futures::FutureExt;
use mylibsql::Snapshot;

/// cargo run --bin generate_test_data
#[tokio::main]
async fn main() -> Result<()> {
    let (snapshot, log) = mylibsql::init(|conn| {
        let sql = std::fs::read_to_string("tests/data/acme/0.sql")?;
        conn.execute_batch(&sql)?;
        Ok(())
    })
    .await?;

    snapshot.move_to("tests/data/acme/0.db").await?;
    log.copy_to("tests/data/acme/0.log").await?;

    let snapshot = Snapshot::open("tests/data/acme/0.db").await?;
    let primary = mylibsql::Primary::open(&snapshot, &[]).await?;

    for epoch in 1..=3 {
        let sql = std::fs::read_to_string(format!("tests/data/acme/{epoch}.sql"))?;
        let _ = primary
            .with_connection(move |conn| Ok(conn.execute_batch(&sql)?))
            .await?;
        primary
            .checkpoint(move |log| {
                async move {
                    log.copy_to(format!("tests/data/acme/{epoch}.log"))
                        .await
                        .unwrap();
                }
                .boxed()
            })
            .await?
            .await;
    }

    Ok(())
}