Struct Database 

pub struct Database { /* private fields */ }

Database wrapper that provides access to storage and catalog.

Implementations

impl Database

pub fn open(data_path: &Path) -> Result<Self, Error>

Open a database at the given path.

pub fn open_with_retention( data_path: &Path, retention_policy: RetentionPolicy, ) -> Result<Self, Error>

Open a database with a specific retention policy.

pub fn storage(&self) -> &StorageEngine

Get a reference to the storage engine.

pub fn storage_arc(&self) -> Arc<StorageEngine>

Get an Arc reference to the storage engine.

pub fn catalog(&self) -> &Catalog

Get a reference to the catalog.

pub fn statistics(&self) -> &TableStatistics

Get a reference to the table statistics.

pub fn refresh_statistics_if_stale( &self, threshold: Duration, ) -> Result<bool, Error>

Refresh statistics if stale, returning true if a refresh ran.

pub fn plan_cache(&self) -> &PlanCache

Get a reference to the plan cache.

pub fn columnar(&self) -> &ColumnarStore

Get a reference to the columnar store.

pub fn changelog(&self) -> &ChangeLog

Get a reference to the changelog.

pub fn executor(&self) -> QueryExecutor<'_>

Create a query executor for this database.

pub fn executor_with_metrics( &self, metrics: SharedMetricsRegistry, ) -> QueryExecutor<'_>

Create a query executor with metrics tracking.

pub fn schema_version(&self) -> u64

Get the current schema version.

pub fn flush(&self) -> Result<(), Error>

Flush all pending writes to disk.

pub fn compact(&self) -> CompactionResult

Run a single compaction cycle manually.

pub fn compaction_engine(&self) -> CompactionEngine

Create a compaction engine for this database.

pub fn retention_policy(&self) -> &RetentionPolicy

Get the retention policy.