Struct AnyConnection 

pub struct AnyConnection { /* private fields */ }

后端无关的连接

Implementations

impl AnyConnection

pub fn backend(&self) -> AnyBackend

获取后端类型

Trait Implementations

impl Connection for AnyConnection

fn db_type(&self) -> Option<DbType>

连接所属数据库类型（方言）

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

执行 SQL（INSERT/UPDATE/DELETE），返回影响行数

fn query<'a>( &'a mut self, sql: &'a str, ) -> 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 in_transaction(&self) -> bool

连接是否处于未提交事务中

fn session_reset_sql(&self) -> Option<&'static str>

归还连接时用于复位会话状态的 SQL 语句（None = 该适配器无复位语句）

fn is_connected(&self) -> bool

判断连接是否仍然有效

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

发送 PING 检测连接存活

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_with_params<'a>( &'a mut self, sql: &'a str, params: &'a [Value], ) -> Pin<Box<dyn Future<Output = Result<QueryRows, DbError>> + Send + 'a>>

参数绑定查询（SELECT）

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 take_session_dirty(&mut self) -> bool

R5 优化（v10.13.1）：连接自报「本次租用是否污染过会话状态」，池据此决定 是否执行 session_reset_sql。默认 true（保守：始终复位，与旧行为一致）。

fn mark_session_clean(&mut self)

复位语句执行成功后由池调用：清除脏标记。 注意复位 SQL 本身是 SET ...，实现方的执行路径会再次置脏， 必须依赖本方法统一复位。

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 多次参数绑定执行）