Trait StorageEngine 

pub trait StorageEngine {
    // Required methods
    fn create_table(&mut self, schema: TableSchema) -> DbResult<()>;
    fn drop_table(&mut self, name: &str) -> DbResult<()>;
    fn has_table(&self, name: &str) -> bool;
    fn get_schema(&self, name: &str) -> DbResult<TableSchema>;
    fn insert(&mut self, table: &str, row: Row) -> DbResult<RowId>;
    fn get(&self, table: &str, row_id: RowId) -> DbResult<Option<Row>>;
    fn update(
        &mut self,
        table: &str,
        row_id: RowId,
        values: Row,
    ) -> DbResult<()>;
    fn delete(&mut self, table: &str, row_id: RowId) -> DbResult<Option<Row>>;
    fn scan(&self, table: &str) -> DbResult<Vec<(RowId, Row)>>;
}

存储引擎 trait

Required Methods

fn create_table(&mut self, schema: TableSchema) -> DbResult<()>

创建表

fn drop_table(&mut self, name: &str) -> DbResult<()>

删除表

fn has_table(&self, name: &str) -> bool

检查表是否存在

fn get_schema(&self, name: &str) -> DbResult<TableSchema>

获取表 schema（返回克隆，支持锁守卫场景）

fn insert(&mut self, table: &str, row: Row) -> DbResult<RowId>

插入行

fn get(&self, table: &str, row_id: RowId) -> DbResult<Option<Row>>

获取行（返回克隆，支持锁守卫场景）

fn update(&mut self, table: &str, row_id: RowId, values: Row) -> DbResult<()>

更新行

fn delete(&mut self, table: &str, row_id: RowId) -> DbResult<Option<Row>>

删除行

fn scan(&self, table: &str) -> DbResult<Vec<(RowId, Row)>>

扫描全表（返回克隆，支持锁守卫场景）

Implementors

impl StorageEngine for PersistedEngine

impl StorageEngine for MemoryEngine