Struct DatabaseStorageBackend 

pub struct DatabaseStorageBackend { /* private fields */ }

Concrete implementation of StorageBackend backed by sochdb_storage::Database.

This bridges the query optimizer to the actual storage engine, enabling cost-based query plans to execute against real data.

Thread Safety

Database is always Arc<Database> and is Send + Sync. This struct holds an Arc clone and can be shared across threads.

Transaction Management

Each query operation creates a read-only transaction for MVCC snapshot isolation. Transactions are automatically cleaned up on completion.

Implementations

impl DatabaseStorageBackend

pub fn new(db: Arc<Database>) -> Self

Create a new storage backend wrapping a Database instance.

pub fn database(&self) -> &Arc<Database>

Get a reference to the underlying database.

Trait Implementations

impl StorageBackend for DatabaseStorageBackend

fn table_scan( &self, table: &str, columns: &[String], predicate: Option<&str>, ) -> Result<Vec<HashMap<String, QuerySochValue>>>

Execute a full table scan

fn primary_key_lookup( &self, table: &str, key: &QuerySochValue, ) -> Result<Option<HashMap<String, QuerySochValue>>>

Execute a primary key lookup

fn secondary_index_seek( &self, table: &str, index: &str, key: &QuerySochValue, ) -> Result<Vec<HashMap<String, QuerySochValue>>>

Execute a secondary index seek

fn time_index_scan( &self, table: &str, start_us: u64, end_us: u64, ) -> Result<Vec<HashMap<String, QuerySochValue>>>

Execute a time range scan

fn vector_search( &self, table: &str, query: &[f32], k: usize, ) -> Result<Vec<(f32, HashMap<String, QuerySochValue>)>>

Execute a vector similarity search

fn row_count(&self, table: &str) -> usize

Get table row count (for optimization)