Struct TransactionManager 

pub struct TransactionManager<'c> { /* private fields */ }

事务管理器

提供了事务的自动提交和回滚功能。

示例

use baichun_framework_db::{DbPool, TransactionManager};

async fn example(pool: &DbPool) -> Result<()> {
    let tx = pool.begin().await?;
    let mut tm = TransactionManager::new(tx);

    tm.execute(|tx| Box::pin(async move {
        tx.execute("INSERT INTO users (name) VALUES ('Alice')").await?;
        tx.execute("UPDATE users SET status = 'active' WHERE name = 'Alice'").await?;
        Ok(())
    })).await?;

    Ok(())
}

Implementations

impl<'c> TransactionManager<'c>

pub fn new(tx: Transaction<'c, MySql>) -> Self

创建新的事务管理器

pub async fn execute<F, T, E>(&mut self, f: F) -> Result<T>

where F: for<'a> FnOnce(&'a mut Transaction<'c, MySql>) -> Pin<Box<dyn Future<Output = Result<T, E>> + Send + 'a>>, E: Into<Error>, T: Send,

在事务中执行操作

如果操作成功，事务将被提交；如果操作失败，事务将被回滚。