Struct SqlxSqliteConnection 

pub struct SqlxSqliteConnection { /* private fields */ }

Trait Implementations

impl Connection for SqlxSqliteConnection

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

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

使用 sqlx prepared statement 绑定参数，避免 SQL 注入与字符串转义开销。 对 Value::Bool/I8..=I64/U8..=U64/F32/F64/String/Bytes 直接 bind； 其他类型（Date/DateTime/Json/Array/Object）回退为 to_string() 后以 TEXT 绑定。

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

SQLite 参数绑定查询（SELECT，HashMap 映射）

使用 sqlx prepared statement 绑定参数，结果按预解析 ColType 解码为 HashMap<String, Value>。与 query 的区别仅在于参数绑定路径。

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

SQLite 位置式查询（SELECT，无参数）

绕过 HashMap<String, Value> 行映射，返回 (列名列表, 按列序号的值矩阵)。 列名与 ColType 仅 to_string/解析一次，后续行复用；每行值按列序号直接 Vec::push， 无哈希计算与字符串克隆。适用于 SELECT ALL 大结果集场景。

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>>

SQLite 参数绑定位置式查询（SELECT）

叠加 prepared statement + 位置式映射 + ColType 预解析三重优化。

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

SQLite 流式查询：逐行返回结果，避免大结果集 fetch_all 内存峰值

使用 sqlx::query::fetch 获取行流，逐行映射为 HashMap<String, Value>。 流正常消费完毕后连接归还 self.conn；若提前 drop 流，连接通过 PoolConnection::drop 归还到 sqlx 池，但 self.conn 变为 None。

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<Vec<HashMap<String, Value>>, DbError>> + Send + 'a>>

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

查询连接当前是否处于未提交事务中。

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 Drop for SqlxSqliteConnection

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.