分布式事务

同时操作多个数据库，保证事务一致性

    //任意表为例：
   public partial class Sys_DepartmentController
    {
        private readonly ISys_DepartmentService _service;//访问业务代码

        //构造方法获取第一个数据库对象
        private readonly ISys_DepartmentRepository _departmentRepository;
        //构造方法获取第二个数据库对象
        private readonly ITestDbRepository _testDbRepository;

        [ActivatorUtilitiesConstructor]
        public Sys_DepartmentController(
            ISys_DepartmentService service,
            ISys_DepartmentRepository repository,
            ITestDbRepository testDbRepository,
            IHttpContextAccessor httpContextAccessor
        )
        : base(service)
        {
            _service = service;
            _departmentRepository = repository;
            _testDbRepository = testDbRepository;
        }

        /// <summary>
        /// 分布式事务配置，同时操作多个数据库保证事务一致性
        /// </summary>
        /// <returns></returns>
        [HttpPost, Route("transactionTest")]
        public IActionResult TransactionTest()
        {
            using (var transaction1 = _departmentRepository.DbContext.Database.BeginTransaction())
            {
                try
                {
                    //第一个数据库的操作
                    //_departmentRepository.Update/Add操作数据库
                    _departmentRepository.SaveChanges();//    //提交数据库保存
                    using (var transaction2 = _testDbRepository.DbContext.Database.BeginTransaction())
                    {
                        try
                        {
                            //第二个数据库操作
                            //_testDbRepository.Update/Add操作数据库
                            _testDbRepository.SaveChanges(); //提交数据库保存

                            //第三个数据库的操作
                            //using (transaction3 = _xxxDbRepository.DbContext.Database.BeginTransaction())
                            //{
                            //    try
                            //    {   
                            //          提交第三个数据库事务
                            //          transaction3.Commit();
                            //    }
                            //    catch (Exception)
                            //    {
                            //        transaction3?.Rollback();
                            //        throw;
                            //    }
                            //}

                            //提交第三个数据库事务
                            transaction2.Commit();
                        }
                        catch (Exception ex)
                        {
                            transaction2.Rollback();
                            throw ex;
                        }
                    }
                    //提交第一个数据库事务
                    transaction1.Commit();
                }
                catch (Exception ex)
                {
                    transaction1.Rollback();
                    return Content(ex.Message + ex.StackTrace + ex.InnerException);
                }
            }
            return Content("OK");
        }
}