多子程序全局SQL回滚解决方案咨询——C#多存储过程调用的事务一致性问题

这个场景太典型了——原来的单过程独立事务没法满足“一损俱损”的原子性要求，得把事务的控制权从单个过程上收，改成全局统一事务来管理。分两种常见场景给你说具体实现：

一、所有操作都在同一个数据库实例 #

这是最常见的情况，不需要分布式事务，只需要共享同一个事务上下文即可：

核心思路 #

• 由上层代码统一创建数据库连接和事务对象
• 将事务对象传递给每个子过程，子过程不再单独开启/提交/回滚事务
• 上层统一判断：所有过程执行成功才提交事务，任意一个失败就回滚全部操作

代码示例 #

上层调用逻辑（事务管控中心）

using (var dbConn = new SqlConnection("你的数据库连接字符串"))
{
    dbConn.Open();
    // 开启全局事务
    using (var globalTran = dbConn.BeginTransaction())
    {
        try
        {
            // 依次调用8个过程，传入共享的连接和事务
            InsertDataProcess1(dbConn, globalTran);
            InsertDataProcess2(dbConn, globalTran);
            // ... 直到InsertDataProcess8(dbConn, globalTran);
            
            // 所有过程执行成功，才提交全局事务
            globalTran.Commit();
        }
        catch (Exception ex)
        {
            // 任意一个过程失败，立即回滚所有已执行的操作
            globalTran.Rollback();
            // 可以添加日志、异常包装等逻辑
            throw new InvalidOperationException("数据插入失败，已回滚所有操作", ex);
        }
    }
}

子过程改造（去掉独立事务）

原来的子过程可能自己创建连接和事务，现在改成接受外部传入的连接和事务：

private void InsertDataProcess1(SqlConnection conn, SqlTransaction tran)
{
    using (var cmd = new SqlCommand("SP_Insert_Table1", conn, tran))
    {
        cmd.CommandType = CommandType.StoredProcedure;
        // 添加存储过程所需参数
        // cmd.Parameters.Add("@Param1", SqlDbType.VarChar).Value = "xxx";
        
        // 执行存储过程，事务由上层管控
        cmd.ExecuteNonQuery();
    }
    // 注意：删除原来过程内部的tran.Rollback()和Commit()逻辑！
}

关键注意事项 #

• 所有子过程必须使用同一个SqlConnection和SqlTransaction，不能自己新建连接，否则事务无法共享
• 存储过程内部不要手动写BEGIN TRAN/COMMIT/ROLLBACK，否则会形成嵌套事务（SQL Server的嵌套事务是伪嵌套，会干扰全局事务的执行）

二、操作跨多个数据库/资源（比如同时操作DB和MQ） #

如果你的8个过程涉及不同数据库，甚至混合其他资源（如消息队列），就得用分布式事务，推荐用.NET自带的TransactionScope：

核心思路 #

• 用TransactionScope包裹所有操作，它会自动协调参与事务的所有资源
• 每个子过程可以正常使用自己的数据库连接，TransactionScope会自动把连接纳入全局事务
• 只有所有操作成功后调用scope.Complete()，才会提交所有事务；否则自动回滚

代码示例 #

// 可以指定事务隔离级别，默认是Serializable，根据业务调整
var tranOptions = new TransactionOptions
{
    IsolationLevel = IsolationLevel.ReadCommitted,
    Timeout = TimeSpan.FromMinutes(5)
};

using (var globalScope = new TransactionScope(TransactionScopeOption.Required, tranOptions))
{
    try
    {
        // 子过程可以正常使用自己的连接（哪怕是不同数据库）
        InsertDataProcess1(); // 内部自己创建连接执行存储过程
        InsertDataProcess2();
        // ... 直到InsertDataProcess8();
        
        // 所有操作成功，标记事务完成
        globalScope.Complete();
    }
    catch (Exception ex)
    {
        // 任意失败，TransactionScope会自动回滚所有参与的事务
        throw new InvalidOperationException("跨资源操作失败，已回滚所有操作", ex);
    }
}

关键注意事项 #

• 需要确保数据库服务器开启了DTC（分布式事务协调器），否则跨库事务会报错
• TransactionScope会自动提升为分布式事务，性能比单库事务稍差，尽量仅在跨资源场景使用

最后提醒 #

一定要删除原来每个子过程内部的tran.Rollback()和Commit()代码！现在事务的控制权完全在上层，子过程自己处理事务会导致全局事务失效，引发异常。

内容的提问来源于stack exchange，提问作者AviZiyah