在C#中操作数据库事务时,可以通过 SqlTransaction 或 DbTransaction 设置事务的隔离级别。隔离级别决定了事务之间的可见性和并发行为,防止脏读、不可重复读和幻读等问题。
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,除非明确接受脏读风险。基本上就这些。根据业务需求选择合适的隔离级别,既能保证数据一致性,也能兼顾系统性能。
