Struct MockConnection 

pub struct MockConnection { /* private fields */ }

Mock 数据库连接

用于单元测试，预设 SQL 查询的预期结果，无需真实数据库。

事务模拟

MockConnection 会跟踪 begin/commit/rollback 调用状态， 可通过 was_committed() / was_rolled_back() 断言事务行为。

Implementations

impl MockConnection

pub fn new() -> Self

创建新的空 MockConnection

pub fn with_fallback(self, behavior: FallbackBehavior) -> Self

设置无匹配期望时的行为

pub fn expect_query( &mut self, sql: impl Into<String>, ) -> QueryExpectationBuilder<'_>

预设一个查询期望

返回 QueryExpectationBuilder 用于链式配置结果。

示例

mock.expect_query("SELECT * FROM users WHERE id = ?")
    .with_rows(vec![vec![("id", Value::from(1i64))]]);

pub fn expect_any(&mut self) -> QueryExpectationBuilder<'_>

预设一个匹配任意 SQL 的 fallback 期望

pub fn expect_execute(&mut self, sql: impl Into<String>, rows_affected: u64)

预设 execute 的影响行数

pub fn in_transaction(&self) -> bool

是否处于事务中

pub fn was_committed(&self) -> bool

是否已提交

pub fn was_rolled_back(&self) -> bool

是否已回滚

pub fn executed_sql(&self) -> &[String]

获取已执行的 SQL 列表（用于断言）

pub fn assert_executed_count(&self, sql: &str, count: usize)

断言某 SQL 被执行了恰好 n 次

Trait Implementations

impl Connection for MockConnection

fn execute<'a>( &'a mut self, sql: &'a str, ) -> Pin<Box<dyn Future<Output = Result<u64, DbError>> + Send + 'a>>

fn query<'a>( &'a mut self, sql: &'a str, ) -> Pin<Box<dyn Future<Output = Result<QueryRows, DbError>> + Send + 'a>>

fn query_with_params<'a>( &'a mut self, sql: &'a str, _params: &'a [Value], ) -> Pin<Box<dyn Future<Output = Result<QueryRows, DbError>> + Send + 'a>>

参数绑定查询（SELECT）

fn begin_transaction<'a>( &'a mut self, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'a>>

fn commit<'a>( &'a mut self, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'a>>

fn rollback<'a>( &'a mut self, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'a>>

fn is_connected(&self) -> bool

fn ping<'a>(&'a mut self) -> Pin<Box<dyn Future<Output = bool> + Send + 'a>>

fn close<'a>( &'a mut self, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'a>>

fn execute_with_params<'a>( &'a mut self, sql: &'a str, params: &'a [Value], ) -> Pin<Box<dyn Future<Output = Result<u64, DbError>> + Send + 'a>>

参数绑定执行（INSERT/UPDATE/DELETE）

fn query_values<'a>( &'a mut self, sql: &'a str, ) -> Pin<Box<dyn Future<Output = Result<QueryValues, DbError>> + Send + 'a>>

位置式查询（SELECT）：返回 (列名, 按列顺序的值矩阵)

fn query_values_with_params<'a>( &'a mut self, sql: &'a str, params: &'a [Value], ) -> Pin<Box<dyn Future<Output = Result<QueryValues, DbError>> + Send + 'a>>

参数绑定位置式查询（SELECT）：叠加 prepared statement + 位置式映射双重优化

fn query_stream<'a>( &'a mut self, sql: &'a str, ) -> Pin<Box<dyn Stream<Item = QueryStreamItem> + Send + 'a>>

流式查询：返回逐行结果流

fn query_stream_cursor<'a>( &'a mut self, sql: &'a str, _batch_size: usize, ) -> Pin<Box<dyn Stream<Item = QueryStreamItem> + Send + 'a>>

游标式流式查询（P1-2）：按 batch_size 分批拉取，避免大结果集内存峰值。

fn execute_batch<'a>( &'a mut self, sqls: &'a [String], ) -> Pin<Box<dyn Future<Output = Result<u64, DbError>> + Send + 'a>>

批量执行多条 SQL（按顺序执行，返回累计影响行数）

fn execute_batch_params<'a>( &'a mut self, sql: &'a str, params_batch: &'a [Vec<Value>], ) -> Pin<Box<dyn Future<Output = Result<u64, DbError>> + Send + 'a>>

批量插入（单条 SQL 多次参数绑定执行）

impl Default for MockConnection

fn default() -> Self

Returns the “default value” for a type.