Struct Transaction 

pub struct Transaction { /* private fields */ }

数据库事务

Implementations

impl Transaction

pub async fn commit(self) -> Result<(), DbError>

提交事务

pub async fn rollback(self) -> Result<(), DbError>

回滚事务

pub async fn execute(&mut self, sql: &str) -> Result<u64, DbError>

执行原生 SQL

pub fn table(&mut self, table_name: &str) -> TransactionQueryBuilder<'_>

选择表，返回事务中的查询构建器

参数

• table_name: 表名

返回

• TransactionQueryBuilder: 事务查询构建器

示例

use yang_db::Database;
use serde_json::json;

let db = Database::connect("mysql://root:password@localhost/test").await?;
let mut tx = db.transaction().await?;

// 在事务中插入数据
let user_data = json!({"name": "张三", "email": "zhangsan@example.com"});
let user_id = tx.table("users").insert(&user_data).await?;

// 在事务中更新数据
let update_data = json!({"status": 1});
tx.table("users")
    .where_and("id", "=", user_id)
    .update(&update_data)
    .await?;

// 提交事务
tx.commit().await?;