Struct InMemoryDataSource 

pub struct InMemoryDataSource { /* private fields */ }

A simple in-memory data source for testing and simple use cases.

Implementations

impl InMemoryDataSource

pub fn new() -> Self

Creates a new empty in-memory data source.

pub fn add_table( &mut self, name: impl Into<String>, rows: Vec<Row>, column_count: usize, )

Adds a table with the given rows.

pub fn create_index( &mut self, table: &str, index_name: impl Into<String>, column_index: usize, ) -> ExecutionResult<()>

Creates an index on a table column.

Trait Implementations

impl DataSource for InMemoryDataSource

fn get_table_rows(&self, table: &str) -> ExecutionResult<Vec<Rc<Row>>>

Returns all rows from a table.

fn get_index_range( &self, table: &str, index: &str, range_start: Option<&Value>, range_end: Option<&Value>, include_start: bool, include_end: bool, ) -> ExecutionResult<Vec<Rc<Row>>>

Returns rows from an index scan with a key range.

fn get_index_range_with_limit( &self, table: &str, index: &str, range_start: Option<&Value>, range_end: Option<&Value>, include_start: bool, include_end: bool, limit: Option<usize>, offset: usize, reverse: bool, ) -> ExecutionResult<Vec<Rc<Row>>>

Returns rows from an index scan with a key range, limit, offset, and reverse option. This enables true pushdown of LIMIT to the storage layer.

fn get_index_point( &self, table: &str, index: &str, key: &Value, ) -> ExecutionResult<Vec<Rc<Row>>>

Returns rows from an index point lookup.

fn get_column_count(&self, table: &str) -> ExecutionResult<usize>

Returns the column count for a table.

fn get_index_point_with_limit( &self, table: &str, index: &str, key: &Value, limit: Option<usize>, ) -> ExecutionResult<Vec<Rc<Row>>>

Returns rows from an index point lookup with limit.

fn get_gin_index_rows( &self, table: &str, index: &str, key: &str, value: &str, ) -> ExecutionResult<Vec<Rc<Row>>>

Returns rows from a GIN index lookup by key-value pair. Used for JSONB path equality queries like $.category = 'Electronics'.

fn get_gin_index_rows_by_key( &self, table: &str, index: &str, key: &str, ) -> ExecutionResult<Vec<Rc<Row>>>

Returns rows from a GIN index lookup by key existence. Used for JSONB key existence queries.

fn get_gin_index_rows_multi( &self, table: &str, index: &str, pairs: &[(&str, &str)], ) -> ExecutionResult<Vec<Rc<Row>>>

Returns rows from a GIN index lookup by multiple key-value pairs (AND query). Used for combined JSONB path equality queries like $.category = 'A' AND $.status = 'active'.

impl Default for InMemoryDataSource

fn default() -> InMemoryDataSource

Returns the “default value” for a type.