ASP.NET Core 2.2 WebApi 系列【七】泛型仓储模式和工作单元

2021-01-27 18:16

阅读：696

标签：linq == ddd 表数 ret sys 函数 osi 表数据

在之前的泛型仓储模式实现中，每个增删改都调用了SaveChanges方法，导致每次更新都提交了事务。

在实际开发过程中，我们经常遇到同时操作多张表数据，那么按照之前的写法，对数据库提交了多次操作，开启了多事务，不能保证数据的一致性，结合工作单元（UnitOfWork）是为了把多次操作放到同一事务中，要么都成功（Commit），要么都失败（Rollback），保证了数据的一致性。

修改仓储类

先把仓储接口中增删改接口无返回（void）值类型，然后去仓储实现类去掉SaveChanges方法，交给UOW统一处理

实现UOW

把SaveChanges抽离出来，定义IUnitOfWork接口

namespace NetCoreWebApi.Repository
{
    /// 
    /// 接口
    /// 
    public interface IUnitOfWork
    {
        /// 
        /// 保存
        /// 
        /// 
        int SaveChanges();
    }
}

实现IUnitOfWork接口

using System;
using Microsoft.EntityFrameworkCore;

namespace NetCoreWebApi.Repository
{
    /// 
    /// 实现类
    /// 
    public class UnitOfWork : IUnitOfWork where TDbContext : DbContext
    {
        /// 
        /// dbContext上下文
        /// 
        private readonly TDbContext _dbContext;
        /// 
        /// 构造函数
        /// 
        /// 
        public UnitOfWork(TDbContext dbContext)
        {
            _dbContext = dbContext;
        }

        /// 
        /// 保存
        /// 
        public int SaveChanges()
        {
            int code;
            try
            {
                code = _dbContext.SaveChanges();
            }
            catch (DbUpdateException e)
            {
                throw new Exception(e.InnerException == null ? e.Message : e.InnerException.Message);
            }
            return code;
        }
    }
}

UOW依赖注入

因为AddDbContext默认生命周期是Scoped，所以用AddScoped注册UOW，确保每次请求共用同一个DbContex对象。

            //注入DbContext
            services.AddDbContext (options => options.UseSqlServer(connectionStr,e => e.MigrationsAssembly("NetCoreWebApi.Model")));
            //注入Uow依赖
            services.AddScoped>();

使用UOW

修改UserRepository业务层

using NetCoreWebApi.Model.Models;
using NetCoreWebApi.Repository.Interface;
using NetCoreWebApi.Repository.Repository;
using System.Collections.Generic;
using System.Linq;

namespace NetCoreWebApi.Repository.Implement
{
    /// 
    /// 业务处理
    /// 
    public class UserRepository : IUserRepository
    {
        private readonly IUnitOfWork _unitOfWork;
        private readonly IRepository _userRepository;

        /// 
        /// 构造函数
        /// 
        /// 
        /// 
        public UserRepository(IRepository userRepository, IUnitOfWork unitOfWork)
        {
            _userRepository = userRepository;
            _unitOfWork = unitOfWork;
        }
        /// 
        /// 添加用户
        /// 
        /// 
        /// 
        public void Add(TbUser entity)
        {
            _userRepository.Add(entity);
            _unitOfWork.SaveChanges();
        }
        /// 
        /// 删除用户
        /// 
        /// 
        /// 
        public void Remove(TbUser entity)
        {
            _userRepository.Remove(entity);
            _unitOfWork.SaveChanges();
        }
        /// 
        /// 查询用户
        /// 
        /// 
        public IList GetAll()
        {
            return _userRepository.GetAll().ToList();
        }
    }
}

遇到多仓储持久化操作时，用构造函数依赖注入相应的仓储即可。

ASP.NET Core 2.2 WebApi 系列【七】泛型仓储模式和工作单元

标签：linq == ddd 表数 ret sys 函数 osi 表数据

原文地址：https://www.cnblogs.com/tenghao510/p/11921501.html

上一篇：Windows系统Git配置教程（Git配置git config）

下一篇：Windows 下使用 Composer 安装 thinkphp

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：ASP.NET Core 2.2 WebApi 系列【七】泛型仓储模式和工作单元
文章链接：http://soscw.com/essay/47872.html

亲，登录后才可以留言！

ASP.NET Core 2.2 WebApi 系列【七】泛型仓储模式和工作单元

修改仓储类

实现UOW

UOW依赖注入

使用UOW

评论

热门文章

推荐文章

最新文章

置顶文章