01
use fsqlite::Connection;02
use fsqlite_types::value::SqliteValue;03
use std::thread;04 05
fn main() -> fsqlite_error::Result<()> {06    
let db = Connection::open("concurrent.db")?;07    db.execute("CREATE TABLE counters (id INTEGER PRIMARY KEY, val INTEGER)")?;08    db.execute("INSERT INTO counters VALUES (1, 0), (2, 0), (3, 0), (4, 0)")?;09 10    
let handles: Vec<_> = (1..=4).map(|id| {11        thread::spawn(
move || {12            
let conn = Connection::open("concurrent.db").unwrap();13            
for _ 
in 0..1000 {14                conn.execute_with_params(15                    "UPDATE counters SET val = val + 1 WHERE id = ?1",16                    &[SqliteValue::Integer(id)],17                ).unwrap();18            }19        })20    }).collect();21 22    
for h 
in handles { h.join().unwrap(); }23    // Each counter is exactly 1000 — no SQLITE_BUSY, no lost updates.24    Ok(())25}

01
use fsqlite::Connection;02 03
fn main() -> fsqlite_error::Result<()> {04    
let db = Connection::open("history.db")?;05    db.execute("CREATE TABLE prices (item TEXT, price REAL)")?;06    db.execute("INSERT INTO prices VALUES ('widget', 9.99)")?;07 08    // Record the commit sequence number09    
let csn_before = db.query_scalar("SELECT fsqlite_current_csn()")?;10 11    db.execute("UPDATE prices SET price = 14.99 WHERE item = 'widget'")?;12 13    // Query the current state14    
let current = db.prepare("SELECT price FROM prices WHERE item = 'widget'")?;15    // => 14.9916 17    // Time-travel: query the database as it was before the update18    
let historical = db.prepare(19        "SELECT price FROM prices FOR SYSTEM_TIME AS OF ?1 WHERE item = 'widget'",20    )?;21    
let rows = historical.query_with_params(&[csn_before])?;22    // => 9.99 — the price before the update23 24    Ok(())25}

01
use fsqlite::Connection;02
use fsqlite_types::value::SqliteValue;03 04
fn main() -> fsqlite_error::Result<()> {05    
let db = Connection::open("secure.db")?;06 07    // Switch to native ECS format for maximum durability08    db.execute("PRAGMA fsqlite.mode = native")?;09 10    // Enable page-level encryption (XChaCha20-Poly1305 + Argon2id KDF)11    db.execute("PRAGMA fsqlite.key = 'hunter2-but-stronger'")?;12 13    // Configure RaptorQ repair symbol ratio (default: 0.1 = 10% overhead)14    db.execute("PRAGMA fsqlite.repair_ratio = 0.2")?; // 20% for extra safety15 16    // Business as usual — the API is identical17    db.execute("CREATE TABLE secrets (id INTEGER PRIMARY KEY, data BLOB)")?;18    db.execute_with_params(19        "INSERT INTO secrets (data) VALUES (?1)",20        &[SqliteValue::Blob(b"classified".to_vec())],21    )?;22 23    // Every page is encrypted at rest + protected by RaptorQ repair symbols.24    // Even if the disk suffers corruption, data is recoverable.25    Ok(())26}