Struct SqliteDatabase 

pub struct SqliteDatabase { /* private fields */ }

SQLite-backed database for collections and key-value storage. Uses a connection pool for concurrent reads and spawn_blocking to keep the async runtime responsive.

Implementations

impl SqliteDatabase

pub fn open(path: impl AsRef<Path>) -> Result<Self>

Open or create a SQLite database at the given path. Creates a connection pool with WAL mode for concurrent reads.

pub fn in_memory() -> Result<Self>

Create an in-memory database (for testing). Uses pool_size=1 since in-memory DBs are per-connection.

pub fn import_json_collection(&self, name: &str, items: &[Value])

Synchronous import of JSON items into a collection (for store.json migration). Only inserts if the collection table is currently empty.

pub async fn get_collection(&self, name: &str) -> Result<Vec<Value>>

Get all items from a collection

pub async fn query_collection( &self, name: &str, query: &CollectionQuery, ) -> Result<Vec<Value>>

Query a collection with sort, filter, search, limit, offset

pub async fn find_by( &self, collection: &str, field: &str, value: &Value, ) -> Result<Vec<Value>>

Find items by a field value

pub async fn find_one_by( &self, collection: &str, field: &str, value: &Value, ) -> Result<Option<Value>>

Find a single item by field value

pub async fn create(&self, collection: &str, item: Value) -> Result<Value>

Create an item in a collection

pub async fn update( &self, collection: &str, id: &Value, updates: Value, ) -> Result<Option<Value>>

Update an item by ID

pub async fn delete(&self, collection: &str, id: &Value) -> Result<bool>

Delete an item by ID

pub async fn set(&self, key: &str, value: Value) -> Result<()>

Set a key-value pair

pub async fn get(&self, key: &str) -> Result<Option<Value>>

Get a value by key

pub async fn as_context(&self) -> Result<HashMap<String, Value>>

Get all data as template context

pub async fn set_collection(&self, name: &str, items: Vec<Value>) -> Result<()>

Replace an entire collection

pub async fn atomic_modify<F>(&self, key: &str, f: F) -> Result<Value>

where F: FnOnce(Option<&Value>) -> Value + Send + 'static,

Atomically modify a key-value pair

pub async fn remove(&self, key: &str) -> Result<Option<Value>>

Delete a key-value pair

Trait Implementations

impl Clone for SqliteDatabase

fn clone(&self) -> SqliteDatabase

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.