如何用C#实现数据库事务的隔离级别?如何设置?

来源:这里教程网 时间:2026-02-21 17:27:21 作者:

在C#中操作数据库事务时,可以通过 SqlTransactionDbTransaction 设置事务的隔离级别。隔离级别决定了事务之间的可见性和并发行为,防止脏读、不可重复读和幻读等问题。

1. 使用 SqlConnection 和 SqlTransaction 设置隔离级别

在使用 SQL Server 时,最常见的方式是通过 SqlConnection.BeginTransaction() 方法,并传入所需的 IsolationLevel 枚举值。

示例代码如下:

using System;
using System.Data;
using System.Data.SqlClient;
<p>class Program
{
static void Main()
{
string connectionString = "Server=.;Database=TestDB;Integrated Security=true;";</p><pre class='brush:php;toolbar:false;'>    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        connection.Open();
        // 开始一个指定隔离级别的事务
        using (SqlTransaction transaction = connection.BeginTransaction(IsolationLevel.ReadCommitted))
        {
            try
            {
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = connection;
                    cmd.Transaction = transaction;
                    cmd.CommandText = "UPDATE Accounts SET Balance = Balance - 100 WHERE Id = 1";
                    cmd.ExecuteNonQuery();
                    cmd.CommandText = "UPDATE Accounts SET Balance = Balance + 100 WHERE Id = 2";
                    cmd.ExecuteNonQuery();
                }
                // 提交事务
                transaction.Commit();
                Console.WriteLine("事务提交成功。");
            }
            catch (Exception)
            {
                // 回滚事务
                transaction.Rollback();
                Console.WriteLine("事务已回滚。");
            }
        }
    }
}

}

2. 常见的 IsolationLevel 枚举值及其含义

.NET 中 System.Data.IsolationLevel 支持以下常用级别:

ReadUncommitted:最低级别,允许脏读(Dirty Read)。 ReadCommitted:默认级别,避免脏读,但可能出现不可重复读或幻读。 RepeatableRead:保证同一事务中多次读取同一数据结果一致,但可能有幻读。 Serializable:最高隔离级别,完全串行化执行,避免所有并发问题,但性能开销大。 Snapshot:基于版本控制,减少锁竞争,适用于高并发读写场景(需数据库支持)。

注意:不是所有隔离级别在所有数据库中都可用。例如,Snapshot 需要在 SQL Server 中启用“快照隔离”选项。

3. 使用 TransactionScope 设置隔离级别(推荐用于多连接或分布式事务)

如果你希望跨多个数据库连接或服务统一管理事务,可以使用 TransactionScope,它更灵活且支持分布式事务。

示例:

using System;
using System.Data;
using System.Data.SqlClient;
using System.Transactions;
<p>class Program
{
static void Main()
{
// 设置事务范围的隔离级别
var transactionOptions = new TransactionOptions
{
IsolationLevel = IsolationLevel.Serializable,
Timeout = TimeSpan.FromMinutes(5)
};</p><pre class='brush:php;toolbar:false;'>    using (var scope = new TransactionScope(TransactionScopeOption.Required, transactionOptions))
    {
        using (SqlConnection conn1 = new SqlConnection("..."))
        using (SqlConnection conn2 = new SqlConnection("..."))
        {
            conn1.Open();
            conn2.Open();
            using (SqlCommand cmd1 = new SqlCommand("UPDATE Table1 SET Value = 1", conn1))
            using (SqlCommand cmd2 = new SqlCommand("UPDATE Table2 SET Value = 2", conn2))
            {
                cmd1.ExecuteNonQuery();
                cmd2.ExecuteNonQuery();
            }
        }
        // 调用 Complete 表示事务成功
        scope.Complete();
    } // 自动提交或回滚
}

}

4. 注意事项

设置隔离级别时需要注意以下几点:

确保数据库支持所选的隔离级别(如 Snapshot 需要手动启用)。 高隔离级别会增加锁的竞争,影响并发性能。 在使用 TransactionScope 时,如果涉及多个连接,默认会升级为分布式事务,可能引入 MSDTC 或轻量级促进者。 不建议随意使用 ReadUncommitted,除非明确接受脏读风险。

基本上就这些。根据业务需求选择合适的隔离级别,既能保证数据一致性,也能兼顾系统性能。

相关推荐