Struct Transaction 

pub struct Transaction<'a> { /* private fields */ }

事务包装器 - 使用 trait object 实现泛型

Implementations

impl<'a> Transaction<'a>

pub fn new(engine: &'a mut dyn StorageEngine) -> Self

创建新事务（默认启用回滚日志）

pub fn with_rollback_log( engine: &'a mut dyn StorageEngine, enable_log: bool, ) -> Self

创建新事务（带回滚日志开关）

pub fn commit(&mut self) -> DbResult<()>

提交事务

pub fn rollback(&mut self) -> DbResult<()>

回滚事务

反向应用所有写操作：

• Inserted: 删除该行
• Updated: 恢复旧值
• Deleted: 重新插入该行

pub fn insert( &mut self, table: &str, values: Vec<(&str, DbValue)>, ) -> DbResult<RowId>

插入数据

pub fn engine(&self) -> &dyn StorageEngine

获取引擎的不可变引用（用于查询等操作）

pub fn engine_mut(&mut self) -> &mut dyn StorageEngine

获取引擎的可变引用

pub fn query_all(&self, table: &str) -> DbResult<Vec<Row>>

查询表中所有行（简化查询接口）

pub fn with_engine<F, R>(&self, f: F) -> R

where F: FnOnce(&dyn StorageEngine) -> R,

直接访问底层引擎执行操作（不记录回滚日志） 适用于查询等只读操作

pub fn with_engine_mut<F, R>(&mut self, f: F) -> R

where F: FnOnce(&mut dyn StorageEngine) -> R,

直接访问底层引擎执行操作（可变）

pub fn update<F>( &mut self, table: &str, condition: F, updates: Vec<(&str, DbValue)>, ) -> DbResult<usize>

where F: Fn(&Row) -> bool,

更新操作（带条件）

pub fn delete<F>(&mut self, table: &str, condition: F) -> DbResult<usize>

where F: Fn(&Row) -> bool,

删除操作（带条件）