在C#中使用Dapper的事务支持，需要通过 IDbTransaction 接口来管理事务。Dapper本身不提供独立的事务机制，而是依赖 ADO.NET 的数据库连接和事务模型。你可以在同一个数据库连接上开启事务，并将该事务传递给 Dapper 的所有操作，确保它们在同一个事务上下文中执行。
基本步骤
1. 创建数据库连接（IDbConnection）并保持打开状态。
2. 调用 BeginTransaction() 方法创建事务对象（IDbTransaction）。
3. 将事务对象作为参数传入 Dapper 的增删改查方法。
4. 根据业务逻辑决定调用 Commit() 提交事务或 Rollback() 回滚事务。
示例代码：使用 SQL Server 和 Dapper 执行事务
using System;
using System.Data;
using System.Data.SqlClient;
using Dapper;
<p>class Program
{
private static string connectionString = "Server=.;Database=TestDB;Integrated Security=true;";</p><pre class='brush:php;toolbar:false;'>static void Main()
{
using (var connection = new SqlConnection(connectionString))
{
connection.Open();
IDbTransaction transaction = connection.BeginTransaction();
try
{
// 插入用户
string insertUserSql = "INSERT INTO Users (Name, Email) VALUES (@Name, @Email)";
var user = new { Name = "张三", Email = "zhangsan@example.com" };
connection.Execute(insertUserSql, user, transaction);
// 获取刚插入用户的 ID
int userId = connection.QuerySingle<int>("SELECT SCOPE_IDENTITY();", transaction: transaction);
// 插入日志记录
string insertLogSql = "INSERT INTO Logs (UserId, Action) VALUES (@UserId, @Action)";
var log = new { UserId = userId, Action = "UserCreated" };
connection.Execute(insertLogSql, log, transaction);
// 提交事务
transaction.Commit();
Console.WriteLine("事务提交成功！");
}
catch (Exception ex)
{
// 出现异常时回滚
transaction.Rollback();
Console.WriteLine("事务已回滚，错误：" + ex.Message);
}
}
}}
注意事项
- 事务必须与打开的连接关联，不能跨连接使用。
- 所有使用该事务的 Dapper 操作都必须传入 transaction 参数。
- 使用 using 可以确保连接正确释放，但事务需手动 Commit 或 Rollback。
- 在 ASP.NET Core 等环境中，注意不要跨异步方法丢失事务上下文。
基本上就这些。只要保证多个操作共享同一个事务对象，就能实现原子性操作。
