使用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() 回滚事务。
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 等环境中,注意不要跨异步方法丢失事务上下文。
基本上就这些。只要保证多个操作共享同一个事务对象,就能实现原子性操作。
以上就是C#中如何使用Dapper的事务支持?示例代码是什么?的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号