Struct SqliteDb 

pub struct SqliteDb { /* private fields */ }

SQLite-backed items database

Implementations

impl SqliteDb

pub fn open<P: AsRef<Path>>(path: P) -> Result<Self, Error>

Open or create the database

pub fn open_in_memory() -> Result<Self, Error>

Open an in-memory database (for testing)

pub fn get_setting(&self, key: &str) -> RepoResult<Option<String>>

Get a setting value

pub fn set_setting(&self, key: &str, value: &str) -> RepoResult<()>

Set a setting value

pub fn get_or_create_salt(&self) -> RepoResult<String>

Get the source salt, generating one if it doesn’t exist

pub fn get_distinct_sources(&self) -> RepoResult<Vec<String>>

Get all distinct sources from the database

impl SqliteDb

pub fn get_all_values_bulk( &self, serials: &[&str], ) -> RepoResult<Vec<ItemValue>>

Get all item_values for multiple serials (bulk fetch)

Trait Implementations

impl ImportExportRepository for SqliteDb

fn import_from_dir(&self, dir: &Path) -> RepoResult<String>

Import an item from a directory

fn export_to_dir(&self, serial: &str, dir: &Path) -> RepoResult<()>

Export an item to a directory

impl ItemsRepository for SqliteDb

fn init(&self) -> RepoResult<()>

Initialize the database schema

fn add_item(&self, serial: &str) -> RepoResult<()>

Add a new item with just its serial

fn get_item(&self, serial: &str) -> RepoResult<Option<Item>>

Get an item by serial

fn update_item(&self, serial: &str, update: &ItemUpdate) -> RepoResult<()>

Update item metadata

fn list_items(&self, filter: &ItemFilter) -> RepoResult<Vec<Item>>

List items with optional filters

fn delete_item(&self, serial: &str) -> RepoResult<bool>

Delete an item

fn set_verification_status( &self, serial: &str, status: VerificationStatus, notes: Option<&str>, ) -> RepoResult<()>

Set verification status for an item

fn set_legal(&self, serial: &str, legal: bool) -> RepoResult<()>

Set legal status for an item

fn set_all_legal(&self, legal: bool) -> RepoResult<usize>

Set legal status for all items

fn set_item_type(&self, serial: &str, item_type: &str) -> RepoResult<()>

Set item type

fn set_source(&self, serial: &str, source: &str) -> RepoResult<()>

Set source for an item

fn set_source_for_null(&self, source: &str) -> RepoResult<usize>

Set source for items without one

fn set_source_where(&self, source: &str, condition: &str) -> RepoResult<usize>

Set source for items matching a condition (SQL WHERE clause) WARNING: condition is inserted directly into SQL - do not use with untrusted input

fn get_parts(&self, serial: &str) -> RepoResult<Vec<ItemPart>>

Get parts for an item

fn set_value( &self, serial: &str, field: &str, value: &str, source: ValueSource, source_detail: Option<&str>, confidence: Confidence, ) -> RepoResult<()>

Set a field value with source attribution

fn get_values(&self, serial: &str, field: &str) -> RepoResult<Vec<ItemValue>>

Get all values for a field across sources

fn get_best_value( &self, serial: &str, field: &str, ) -> RepoResult<Option<ItemValue>>

Get the best value for a field

fn get_all_values(&self, serial: &str) -> RepoResult<Vec<ItemValue>>

Get all values for an item

fn get_best_values(&self, serial: &str) -> RepoResult<HashMap<String, String>>

Get best value for each field as a map

fn get_all_items_best_values( &self, ) -> RepoResult<HashMap<String, HashMap<String, String>>>

Get best values for all items (bulk query)

fn stats(&self) -> RepoResult<DbStats>

Get database statistics

fn migrate_column_values(&self, dry_run: bool) -> RepoResult<MigrationStats>

Migrate column values to item_values table