Struct SqliteProjectionStore

Source

pub struct SqliteProjectionStore { /* private fields */ }

Expand description

SQLite-backed projection store

Implementations§

Source §

impl SqliteProjectionStore

Source

pub fn conn(&self) -> &Arc<Mutex<Connection>>

Get the underlying connection (for migrations and custom queries)

Returns an Arc to the Mutex-protected SQLite connection. Users should lock the mutex to access the connection.

Source

pub async fn query_async<F, R>(&self, f: F) -> Result<R>
where F: FnOnce(&Connection) -> Result<R> + Send + 'static, R: Send + 'static,

Execute a read-only SQL query asynchronously

This method runs the query on a separate thread to avoid blocking, making it safe to call from async contexts.

§Example

let balance: i64 = store.query_async(|conn| {
    conn.query_row("SELECT balance FROM accounts WHERE id = ?1", [account_id], |row| row.get(0))
}).await?;

Source

pub fn query<F, R>(&self, f: F) -> Result<R>
where F: FnOnce(&Connection) -> Result<R>,

Execute a read-only SQL query synchronously

This is a convenience method for non-async contexts. For async contexts, prefer query_async.

§Example

let balance: i64 = store.query(|conn| {
    conn.query_row("SELECT balance FROM accounts WHERE id = ?1", [account_id], |row| row.get(0))
})?;

Source

pub async fn execute_async<F>(&self, f: F) -> Result<()>
where F: FnOnce(&Connection) -> Result<()> + Send + 'static,

Execute arbitrary SQL statements (DDL/DML) asynchronously

Useful for creating tables, indexes, or performing bulk updates.

§Example

store.execute_async(|conn| {
    conn.execute("CREATE TABLE IF NOT EXISTS balances (id INTEGER PRIMARY KEY, amount INTEGER)", [])?;
    conn.execute("CREATE INDEX IF NOT EXISTS idx_amount ON balances(amount)", [])?;
    Ok(())
}).await?;

Source

pub fn execute<F>(&self, f: F) -> Result<()>
where F: FnOnce(&Connection) -> Result<()>,

Execute arbitrary SQL statements (DDL/DML) synchronously

§Example

store.execute(|conn| {
    conn.execute("CREATE TABLE IF NOT EXISTS balances (id INTEGER PRIMARY KEY, amount INTEGER)", [])?;
    Ok(())
})?;

Source

pub fn transaction<F>(&self, f: F) -> Result<()>
where F: FnOnce(&Transaction<'_>) -> Result<()>,

Execute a transaction with multiple SQL statements

The closure receives a transaction object and can execute multiple statements atomically. If the closure returns an error, the transaction is rolled back.

§Example

store.transaction(|tx| {
    tx.execute("INSERT INTO accounts (id, balance) VALUES (?1, ?2)", params![1, 100])?;
    tx.execute("INSERT INTO accounts (id, balance) VALUES (?1, ?2)", params![2, 200])?;
    Ok(())
})?;