Struct Database 

pub struct Database<T>
where
    T: TableSchemaProvider,
{ /* private fields */ }

Database handle for a given table schema provider type

Implementations

impl<T> Database<T>

where T: TableSchemaProvider,

pub fn from_path(path: Option<PathBuf>) -> Self

Create a new database handle from an optional database path override.

pub fn with_connection<U>( &self, callback: impl FnOnce(&Connection) -> ApiResult<U>, ) -> ApiResult<U>

Executes a callback using the database path configured on this handle.

pub fn cache_ttl(&self) -> Duration

Get the cache TTL value from environment or use default.

pub fn migrate_table(&self, table: impl Into<Table>) -> ApiResult<()>

Create one table if it does not exist.

pub fn migrate(&self) -> ApiResult<()>

Create all tables defined by the variant provider type.

pub fn clear(&self, table: impl Into<Table>) -> ApiResult<usize>

Delete all rows from a table.

pub fn delete_expired_before( &self, table: impl Into<Table>, column: &str, cutoff: &str, ) -> ApiResult<usize>

Delete rows where a timestamp/text column is older than a cutoff value.

pub fn row_count(&self, table: impl Into<Table>) -> ApiResult<usize>

Count rows in a table.

pub fn trim_to_recent( &self, table: impl Into<Table>, id_column: &str, order_column: &str, limit: usize, ) -> ApiResult<usize>

Keep only the most recent limit rows using an id/order column pair.

pub fn cleanup_expired_cache(&self) -> ApiResult<usize>

Clean up expired link cache entries and trim validation history.

pub fn clear_cache(&self) -> ApiResult<usize>

Clear all cache-related tables.

pub fn reset(&self) -> ApiResult<usize>

Clear (reset) all data from all tables.

Trait Implementations

impl<T> Clone for Database<T>

where T: TableSchemaProvider + Clone,

fn clone(&self) -> Database<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for Database<T>

where T: TableSchemaProvider + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for Database<T>

where T: TableSchemaProvider,

fn default() -> Self

Returns the “default value” for a type.

impl<S> Operations for Database<S>

where S: TableSchemaProvider + Sync,

fn insert<R>(&self, value: R) -> ApiResult<usize>

where R: Row,

Insert a value (row) into the database

fn persist<'life0, 'async_trait, P>( &'life0 self, data: Option<P>, ) -> Pin<Box<dyn Future<Output = ApiResult<usize>> + Send + 'async_trait>>

where P: DatabasePersistence + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Save data to database

fn populate<'life0, 'async_trait>( &'life0 self, table: impl 'async_trait + TableSchemaProvider + Send, ) -> Pin<Box<dyn Future<Output = ApiResult<PersistStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Download and persist data for a table if the table is empty. Returns PersistStatus::Downloaded(n) if data was downloaded and persisted, or PersistStatus::AlreadyExists if the table already contained data.

fn select<T, P>(&self, _value: P) -> ApiResult<Option<T>>

where T: Into<Table>, P: Params,

Select a value from the database