Struct MemRelationalExecutor 

pub struct MemRelationalExecutor<S: WriteSetApplicator> { /* private fields */ }

Implementations

impl<S: WriteSetApplicator> MemRelationalExecutor<S>

pub fn new(store: Arc<RelationalStore>, tx_mgr: Arc<TxManager<S>>) -> Self

pub fn scan_with_tx( &self, tx: Option<TxId>, table: &str, snapshot: SnapshotId, ) -> Result<Vec<VersionedRow>>

pub fn scan_filter_with_tx( &self, tx: Option<TxId>, table: &str, snapshot: SnapshotId, predicate: &dyn Fn(&VersionedRow) -> bool, ) -> Result<Vec<VersionedRow>>

pub fn point_lookup_with_tx( &self, tx: Option<TxId>, table: &str, col: &str, value: &Value, snapshot: SnapshotId, ) -> Result<Option<VersionedRow>>

pub fn insert_with_tx( &self, tx: TxId, table: &str, values: HashMap<ColName, Value>, snapshot: SnapshotId, ) -> Result<RowId>

pub fn upsert_with_tx( &self, tx: TxId, table: &str, conflict_col: &str, values: HashMap<ColName, Value>, snapshot: SnapshotId, ) -> Result<UpsertResult>

Trait Implementations

impl<S: WriteSetApplicator> RelationalExecutor for MemRelationalExecutor<S>

fn scan(&self, table: &str, snapshot: SnapshotId) -> Result<Vec<VersionedRow>>

fn scan_filter( &self, table: &str, snapshot: SnapshotId, predicate: &dyn Fn(&VersionedRow) -> bool, ) -> Result<Vec<VersionedRow>>

fn point_lookup( &self, table: &str, col: &str, value: &Value, snapshot: SnapshotId, ) -> Result<Option<VersionedRow>>

fn insert( &self, tx: TxId, table: &str, values: HashMap<ColName, Value>, ) -> Result<RowId>

fn upsert( &self, tx: TxId, table: &str, conflict_col: &str, values: HashMap<ColName, Value>, snapshot: SnapshotId, ) -> Result<UpsertResult>

fn delete(&self, tx: TxId, table: &str, row_id: RowId) -> Result<()>