Struct Db 

pub struct Db { /* private fields */ }

Db 门面 —— 配置驱动的数据库访问入口

封装 PostgreSQL/MySQL/SQLite 三种后端，提供统一的 CRUD 接口。 通过 factory::create_db() 从 DatabaseConfig 自动创建并连接测试。

示例

let db = create_db(&config.database).await?;
let user = db.find_by_id("user", 1).await?;

Implementations

impl Db

pub fn postgres(pool: PgPool) -> Self

从 PostgreSQL 连接池创建 Db 实例

pub fn mysql(pool: MySqlPool) -> Self

从 MySQL 连接池创建 Db 实例

pub fn sqlite(pool: SqlitePool) -> Self

从 SQLite 连接池创建 Db 实例

pub fn pg_pool(&self) -> &PgPool

获取 PostgreSQL 连接池引用（非 PG 则 panic）

pub fn mysql_pool(&self) -> &MySqlPool

获取 MySQL 连接池引用（非 MySQL 则 panic）

pub fn sqlite_pool(&self) -> &SqlitePool

获取 SQLite 连接池引用（非 SQLite 则 panic）

pub async fn find_by_id( &self, table: &str, id: impl Into<Value>, ) -> DbResult<Option<Row>>

按主键 ID 查询单条记录（主键默认 id）

自动识别 ID 类型（UUID / 整数 / 字符串），添加正确的 SQL 类型转换后缀。

参数

• table: 表名
• id: 主键值（支持 i64、&str、Uuid 等实现了 Into<Value> 的类型）

返回值

• Ok(Some(row)): 记录存在
• Ok(None): 记录不存在
• Err(_): 数据库错误

pub async fn query_one( &self, sql: &str, params: &[&str], ) -> DbResult<Option<Row>>

执行原始 SQL 查询（单条），返回 Option<Row>

参数使用 $1、$2 占位符，按顺序绑定。

pub async fn query(&self, sql: &str, params: &[&str]) -> DbResult<Vec<Row>>

执行原始 SQL 查询（多条），返回 Vec<Row>

pub async fn query_page( &self, sql: &str, params: &[&str], page: &PageQuery, ) -> DbResult<(Vec<Row>, u64)>

分页查询：自动包裹 COUNT 和 LIMIT/OFFSET

返回 (数据列表, 总条数)。传入的 SQL 应为无 LIMIT/OFFSET 的完整查询。

pub async fn count(&self, sql: &str, params: &[&str]) -> DbResult<u64>

执行 COUNT 查询，返回行数（自动转换为 u64）

pub async fn insert(&self, row: &Row) -> DbResult<Row>

插入单条记录（Row 需设置 table 和字段值）

PostgreSQL 使用 RETURNING * 直接返回插入后的完整行； MySQL/SQLite 插入后通过主键回查。

错误

• Row 缺少表名 → Argument 错误
• 没有变更字段 → Argument 错误

pub async fn batch_insert(&self, rows: &[Row]) -> DbResult<u64>

批量插入记录，返回受影响行数

所有 Row 必须来自同一张表且变更字段一致。

pub async fn update(&self, row: &Row) -> DbResult<Option<Row>>

更新单条记录（根据 Row 的 changes 和主键）

仅更新 changes 中标记的字段，主键必须存在于 data 中。 PostgreSQL 使用 RETURNING * 返回更新后的行。

pub async fn batch_update( &self, table: &str, sets: &Row, where_sql: &str, where_params: &[&str], ) -> DbResult<u64>

批量更新（按 WHERE 条件），返回受影响行数

• sets: 要更新的字段值（Row 含 changes）
• where_sql: WHERE 子句（不含 WHERE 关键字），参数使用 $1 占位符
• where_params: WHERE 子句的参数值

pub async fn delete_by_id( &self, table: &str, id: impl Into<Value>, ) -> DbResult<bool>

按主键删除记录，返回是否成功删除

pub async fn batch_delete_by_ids( &self, table: &str, ids: &[impl AsRef<str>], ) -> DbResult<u64>

批量按主键删除，返回受影响行数

pub async fn execute(&self, sql: &str, params: &[&str]) -> DbResult<u64>

执行 INSERT/UPDATE/DELETE 等写操作，返回受影响行数

pub async fn transaction<F, Fut, T>(&self, f: F) -> DbResult<T>

where F: FnOnce(ActiveTx) -> Fut + Send, Fut: Future<Output = (ActiveTx, DbResult<T>)> + Send, T: Send,

在事务闭包中执行操作，自动 BEGIN/COMMIT/ROLLBACK

闭包返回 Ok 则 COMMIT，返回 Err 则 ROLLBACK。 可通过 ActiveTx::set_rollback_only() 强制回滚。

示例

db.transaction(|mut tx| async move {
    let user = Row::table("user").id(1);
    tx.execute("UPDATE user SET name=$1 WHERE id=$2", &["Alice", "1"]).await?;
    (tx, Ok(()))
}).await?;

Trait Implementations

impl Clone for Db

fn clone(&self) -> Db

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.