使用Dapper事务需通过IDbTransaction管理,依赖ADO.NET模型;2. 在同一连接上开启事务并传给Dapper操作;3. 通过Commit提交或Rollback回滚确保原子性。

在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;class Program { private static string connectionString = "Server=.;Database=TestDB;Integrated Security=true;";
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("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 等环境中,注意不要跨异步方法丢失事务上下文。
基本上就这些。只要保证多个操作共享同一个事务对象,就能实现原子性操作。










