Struct Database 

pub struct Database { /* private fields */ }

Database connection pool and operations.

Implementations

impl Database

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

Open a database at the given path.

pub fn with_config(config: DatabaseConfig) -> Result<Self>

Open a database with the given configuration.

pub fn conn(&self) -> Result<PooledConnection<SqliteConnectionManager>>

Get a connection from the pool.

pub fn initialize(&self) -> Result<()>

Initialize the database schema.

pub fn is_initialized(&self) -> Result<bool>

Check if the database is initialized.

pub fn migrate_if_needed(&self) -> Result<()>

Migrate the database schema if needed.

Call this on an existing database to upgrade it to the current schema version.

pub fn begin_transaction(&self) -> Result<Transaction>

Begin a transaction for bulk operations.

pub fn insert_record(&self, record: &UlsRecord) -> Result<()>

Insert a ULS record into the database.

pub fn get_license_by_callsign(&self, callsign: &str) -> Result<Option<License>>

Look up a license by call sign.

pub fn get_licenses_by_frn(&self, frn: &str) -> Result<Vec<License>>

Look up all licenses by FRN (FCC Registration Number).

pub fn get_stats(&self) -> Result<LicenseStats>

Get database statistics.

pub fn count_by_service(&self, service_codes: &[&str]) -> Result<u64>

Count licenses by radio service code(s). Pass service codes like [“HA”, “HV”] for amateur or [“ZA”] for GMRS.

pub fn set_last_updated(&self, timestamp: &str) -> Result<()>

Set the last updated timestamp.

pub fn get_imported_etag(&self, service: &str) -> Result<Option<String>>

Get the ETag of the last imported file for a service.

pub fn set_imported_etag(&self, service: &str, etag: &str) -> Result<()>

Set the ETag of the last imported file for a service.

pub fn has_record_type(&self, service: &str, record_type: &str) -> Result<bool>

Check if a record type has been imported for a service.

pub fn get_imported_types(&self, service: &str) -> Result<Vec<String>>

Get list of imported record types for a service.

pub fn mark_imported( &self, service: &str, record_type: &str, count: usize, ) -> Result<()>

Mark record type as imported for a service.

pub fn clear_import_status(&self, service: &str) -> Result<()>

Clear import status for a service (used when doing full re-import).

pub fn get_imported_count( &self, service: &str, record_type: &str, ) -> Result<Option<usize>>

Get record count for an imported record type.

pub fn get_last_updated(&self) -> Result<Option<String>>

Get the last updated timestamp for a service.

pub fn get_freshness( &self, service: &str, threshold_days: i64, ) -> Result<DataFreshness>

Get data freshness information for a service.

pub fn is_stale(&self, service: &str, threshold_days: i64) -> Result<bool>

Check if data for a service is stale.

pub fn record_applied_patch( &self, service: &str, patch_date: NaiveDate, weekday: &str, etag: Option<&str>, record_count: Option<usize>, ) -> Result<()>

Record that a daily patch has been applied.

pub fn get_applied_patches(&self, service: &str) -> Result<Vec<AppliedPatch>>

Get all applied patches for a service since last weekly.

pub fn clear_applied_patches(&self, service: &str) -> Result<()>

Clear applied patches for a service (called when new weekly is imported).

pub fn set_last_weekly_date(&self, service: &str, date: NaiveDate) -> Result<()>

Set the date of the last weekly import for a service.

pub fn get_last_weekly_date(&self, service: &str) -> Result<Option<NaiveDate>>

Get the date of the last weekly import for a service.