C# 基于ef的2种简单的仓储封装和工作单元 net core3.1 ---sqlserver 2019

1配置

        public void ConfigureServices(IServiceCollection services)
        {
            services.AddControllers();
            services.AddCors();

            services.AddDbContext<MyDbContext>(option =>
            {
                option.UseSqlServer(Configuration.GetConnectionString("connection"));
            });

            //<IRepository<>, Repository<>>
            // 泛型注入
            services.AddScoped(typeof(IRepository<>), typeof(Repository<>));
            // 非泛型注入
            services.AddScoped<IRepository, Repository>();

            //注入工作单元
            services.AddScoped<IunitOfWork, UnitOfWork>();

        }

  public class MyDbContext : DbContext
    {

        public MyDbContext(DbContextOptions<MyDbContext> options) : base(options)
        {
          
        }

        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
        {
            optionsBuilder.Options.Extensions.LastOrDefault();

            //.UseSqlServer(Configuration.GetConnectionString("connection")
            //optionsBuilder.UseSqlServer("Data Source=blog.db");
        }

        /// <summary>
        /// OnModelCreating
        /// </summary>
        /// <param name="modelBuilder"></param>
        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
            base.OnModelCreating(modelBuilder);
        }

        public DbSet<MessageMode> MessageMode { get; set; }

    }

2.第一种实现

接口

public interface IRepository
{

　　IEnumerable<T> GetConditions<T>(Func<T, bool> predicate = null) where T : class;

　　T Get<T>(Func<T, bool> predicate) where T : class;

　　T Get<T>(params object[] keyValues) where T : class;

　　void Add<T>(T entity);

　　void AddRange<T>(List<T> entitys);

　　void Update<T>(T entity);

　　void Delete<T>(T entity);

　　void Delete<T>(List<T> entitys);

}

实现

public class Repository : IRepository
{

 　　private MyDbContext dbContext;

　　/// <summary>
　　/// 构造函数注入
　　/// </summary>
　　/// <param name="_dbContext"></param>
　　public Repository(MyDbContext _dbContext)
　　{
　　　　dbContext = _dbContext;
　　}

　　public void Add<T>(T entity)
　　{
　　　　dbContext.Add(entity);
　　}

　　public void AddRange<T>(List<T> entitys)
　　{
　　　　dbContext.AddRange(entitys);
　　}

　　public void Update<T>(T entity)
　　{
　　　　dbContext.Update(entity);
　　}

　　public void Delete<T>(T entity)
　　{
　　　　dbContext.Remove(entity);
　　}

　　public void Delete<T>(List<T> entitys)
　　{
　　　　dbContext.RemoveRange(entitys);
　　}

　　public T Get<T>(Func<T, bool> predicate) where T : class
　　{
　　　　return dbContext.Set<T>().Where(predicate).FirstOrDefault();
　　}

　　public T Get<T>(params object[] keyValues) where T : class
　　{
　　　　return dbContext.Find<T>(keyValues);
　　}

　　public IEnumerable<T> GetConditions<T>(Func<T, bool> predicate = null) where T : class
　　{
　　　　if (predicate == null)
　　　　{
　　　　　　return dbContext.Set<T>().Where(l => true);
　　　　}
　　　　return dbContext.Set<T>().Where(predicate);
　　}
}

3.第二种实现

接口

public interface IRepository<T> where T : class
{
　　IEnumerable<T> GetConditions(Func<T, bool> predicate = null);

　　T Get(Func<T, bool> predicate);

　　T Get(params object[] keyValues);

　　void Add(T entity);

　　void AddRange(List<T> entitys);

　　void Update(T entity);

　　void Delete(T entity);

　　void Delete(List<T> entitys);

}

实现

public class Repository<T> : IRepository<T> where T : class
{

　　private MyDbContext dbContext ;

　　public MyDbContext Context => dbContext;

　　/// <summary>
　　/// 构造函数注入
　　/// </summary>
　　/// <param name="_dbContext"></param>
　　public Repository(MyDbContext _dbContext)
　　{
　　　　dbContext = _dbContext;
　　}

　　public void Add(T entity)
　　{
　　　　dbContext.Add(entity);
　　}

　　public void AddRange(List<T> entitys)
　　{
　　　　dbContext.AddRange(entitys);
　　}

　　public void Update(T entity)
　　{
　　　　dbContext.Update(entity);
　　}

　　public void Delete(T entity)
　　{
　　　　//dbContext.Add(entity).State = EntityState.Deleted;
　　　　dbContext.Remove(entity);
　　}

　　public void Delete(List<T> entitys)
　　{
　　　　//dbContext.Add(entity).State = EntityState.Deleted;
　　　　dbContext.RemoveRange(entitys);
　　}

　　public T Get(Func<T, bool> predicate)
　　{
　　　　return dbContext.Set<T>().Where(predicate).FirstOrDefault();
　　}

　　public T Get(params object[] keyValues)
　　{
　　　　return dbContext.Find<T>(keyValues);
　　}

　　public IEnumerable<T> GetConditions(Func<T, bool> predicate = null)
　　{
　　　　if (predicate == null)
　　　　{
　　　　　　return dbContext.Set<T>().Where(l=>true);
　　　　}
　　　　return dbContext.Set<T>().Where(predicate);
　　}
}

 工作单元

接口

    public interface IunitOfWork
    {
        void Commit();
    }

实现

    public class UnitOfWork : IunitOfWork
    {
        private MyDbContext _dbContext;
        public UnitOfWork(MyDbContext dbContext)
        {
            _dbContext = dbContext;
        }

        public void Commit()
        {
            _dbContext.SaveChanges();
        }
    }

最终再给一个使用的例子,

    [ApiController]
    [Route("[controller]")]
    public class WeatherForecastController : ControllerBase
    {
       
        private readonly ILogger<WeatherForecastController> _logger;
        private readonly IRepository<MessageMode> _userRepository;
        private readonly IRepository _repository;
        private readonly IunitOfWork _IunitOfWork;
        public WeatherForecastController(ILogger<WeatherForecastController> logger,
            IRepository<MessageMode> userRepository,
            IRepository repository, IunitOfWork IunitOfWork)
        {
            _logger = logger;
            _userRepository = userRepository;
            _repository = repository;
            _IunitOfWork = IunitOfWork;
        }

        
        [HttpGet]
        public IEnumerable<MessageDto> Get()
        {
            return _repository.GetConditions<MessageMode>().Adapt<List<MessageDto>>();
        }

        [HttpPost]
        public IActionResult Post(MessageDto messageDto)
        {
            var model = messageDto.Adapt<MessageMode>();
     
            _repository.Add<MessageMode>(model);
            _IunitOfWork.Commit();
            return Ok("ok");
        }


    }