⭐️ Furion v4 版本支持【所有历史版本】无缝升级,一套代码兼容 .NET 5+ ⭐️
Skip to main content

9.26 事务和工作单元

9.26.1 事务

事务指作为单个逻辑工作单元执行的一系列操作,要么完全地执行,要么完全地不执行

简单的说,事务就是并发控制的单位,是用户定义的一个操作序列。 而一个逻辑工作单元要成为事务,就必须满足 ACID 属性。

  • A:原子性(Atomicity):事务中的操作要么都不做,要么就全做
  • C:一致性(Consistency):事务执行的结果必须是从数据库从一个一致性状态转换到另一个一致性状态
  • I:隔离性(Isolation):一个事务的执行不能被其他事务干扰
  • D:持久性(Durability):一个事务一旦提交,它对数据库中数据的改变就应该是永久性的

9.26.2 工作单元

简单来说,就是为了保证一次完整的功能操作所产生的一些列提交数据的完整性,起着事务的作用。在计算机领域中,工作单元通常用 UnitOfWork 名称表示。

通常我们保证用户的每一次请求都是处于在一个功能单元中,也就是工作单元。

9.26.3 如何使用

9.26.3.1 [UnitOfWork] 自动管理

Furion 框架中,我们只需要在控制器 Action 中贴 [UnitOfWork] 特性即可开启工作单元模式,保证了每一次请求都是一个 工作单元,要么同时成功,要么同时失败。

  • 单库操作

下面方式支持所有关系型数据库类型

[UnitOfWork]    // 由于出现错误,所以所有数据库变更都会自动回滚public async Task 测试环境事务(int id){    // 各种奇葩数据库操作    await _personRepository.DeleteNowAsync(id);    // 其他数据库操作。。    // 故意出错    var d = await _personRepository.SqlQueriesAsync("select * from persion2 d");}
  • 多库操作

支持各种奇葩的 ORM,包括 ADO.NETEFCore 等第三方,支持所有关系型数据库类型但不支持 Sqlite

[UnitOfWork(UseAmbientTransaction = true)]    // 由于出现错误,所以所有数据库变更都会自动回滚public async Task 测试环境事务(int id){    // 各种奇葩数据库操作    await _personRepository.DeleteNowAsync(id);    // 其他数据库操作。。    // 故意出错    var d = await _personRepository.SqlQueriesAsync("select * from persion2 d");}
  • UnitOfWork 内置配置:
    • UseAmbientTransaction:是否开启分布式环境事务,bool 类型,默认 false不支持 Sqlite
    • TransactionScope:配置分布式环境事务范围,TransactionScopeOption 类型,当 UseAmbientTransactiontrue 有效
    • TransactionIsolationLevel:配置分布式环境事务隔离级别,IsolationLevel 类型,当 UseAmbientTransactiontrue 有效
    • TransactionTimeout:配置分布式环境事务执行超时时间,int 类型,当 UseAmbientTransactiontrue 有效
    • TransactionScopeAsyncFlow:配置分布式环境事务异步流支持,TransactionScopeAsyncFlowOption 类型,当 UseAmbientTransactiontrue 有效
    • EnsureTransaction:强制使字符串 sql 拓展事务有效,bool 类型,默认 false
版本说明

以下内容仅限 Furion 3.7.3 + 版本使用。

如使用非 EFCore ORM 框架,可实现 IUnitOfWork 接口之后调用 services.AddUnitOfWork<TUnitOfWork>() 注册即可,如示例代码:

using Microsoft.AspNetCore.Mvc.Filters;namespace Furion.DatabaseAccessor;/// <summary>/// SqlSugar 工作单元实现/// </summary>public sealed class SqlSugarUnitOfWork : IUnitOfWork{    /// <summary>    /// SqlSugar 对象    /// </summary>    private readonly ISqlSugarClient _sqlSugarClient;    /// <summary>    /// 构造函数    /// </summary>    /// <param name="sqlSugarClient"></param>    public SqlSugarUnitOfWork(ISqlSugarClient sqlSugarClient)    {        _sqlSugarClient = sqlSugarClient;    }    /// <summary>    /// 开启工作单元处理    /// </summary>    /// <param name="context"></param>    /// <param name="unitOfWork"></param>    /// <exception cref="NotImplementedException"></exception>    public void BeginTransaction(FilterContext context, UnitOfWorkAttribute unitOfWork)    {        _sqlSugarClient.AsTenant().BeginTran();    }    /// <summary>    /// 提交工作单元处理    /// </summary>    /// <param name="resultContext"></param>    /// <param name="unitOfWork"></param>    /// <exception cref="NotImplementedException"></exception>    public void CommitTransaction(FilterContext resultContext, UnitOfWorkAttribute unitOfWork)    {        _sqlSugarClient.AsTenant().CommitTran();    }    /// <summary>    /// 回滚工作单元处理    /// </summary>    /// <param name="resultContext"></param>    /// <param name="unitOfWork"></param>    /// <exception cref="NotImplementedException"></exception>    public void RollbackTransaction(FilterContext resultContext, UnitOfWorkAttribute unitOfWork)    {        _sqlSugarClient.AsTenant().RollbackTran();    }    /// <summary>    /// 执行完毕(无论成功失败)    /// </summary>    /// <param name="context"></param>    /// <param name="resultContext"></param>    /// <exception cref="NotImplementedException"></exception>    public void OnCompleted(FilterContext context, FilterContext resultContext)    {        _sqlSugarClient.Dispose();    }}

之后注册即可:

services.AddUnitOfWork<SqlSugarUnitOfWork>();
小知识-如何判断是否开启了分布式环境事务

有时候我们自定义了工作单元之后,个别 ORM 不支持分布式环境事务,那么就会出现执行错误,我们可以通过 System.Transactions.Transaction.Current != null 来判断是否启用了分布式环境事务,不等于 null 则为启用,否则未启用。

9.26.3.2 EnsureTransaction() 方法 ✨

有些时候我们通过静态类或者其他方式不小心创建了新的 DbContext 实例,这时候贴了 [UnitOfWork] 也不见起效,这时候可以通过以下方法来确认事务是否有效:

repository.EnsureTransaction();

如果不喜欢手动方式也可以通过 [UnitOfWork(true)] 开启此功能。

该方法会将当前仓储添加到数据库上下文池中,并确保事务可用。

9.26.3.2 手动管理

// 开启事务using (var transaction = _testRepository.Database.BeginTransaction()){    try    {        _testRepository.Insert(new Blog { Url = "http://blogs.msdn.com/dotnet" });        _testRepository.SaveNow();        _testRepository.Insert(new Blog { Url = "http://blogs.msdn.com/visualstudio" });        _testRepository.SaveNow();        var blogs = _testRepository.Entity                .OrderBy(b => b.Url)                .ToList();        // 提交事务        transaction.Commit();     }     catch (Exception)     {        // 回滚事务        // transaction.RollBack(); // 新版本自动回滚了     }}

9.26.4 工作单元特性说明

9.26.4.1 [UnitOfWork] 特性

[UnitOfWork] 特性只能用于控制器的 Action 中,一旦贴了 [UnitOfWork] 特性后,那么该请求自动启用工作单元模式,要么成功,要么失败。

9.26.4.2 [ManualCommit] 特性

默认情况下,Furion 框架会在一次成功请求之后自动调用 SaveChanges() 方法,如果选择手动调用 SaveChanges() 方法,可以在控制器 Action 中贴 [ManualCommit] 特性即可。

9.26.5 反馈与建议

与我们交流

给 Furion 提 Issue


了解更多

想了解更多 事务 知识可查阅 EF Core - 使用事务 章节。

演练场