【EFCore仓储模式】介绍一个EFCore的Repository实现

2024-01-21 14:44
文章标签 实现 模式 介绍 repository efcore 仓储

本文主要是介绍【EFCore仓储模式】介绍一个EFCore的Repository实现，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

阅读本文你的收获

  1. 了解仓储模式及泛型仓储的优点
  2. 学会封装泛型仓储的一般设计思路
  3. 学习在ASP.NET Core WebAPI项目中使用EntityFrameworkCore.Data.Repository

本文中的案例是微软EntityFrameworkCore的一个仓储模式实现，这个仓储库不是我自己写的，而是使用了一个老外写的EntityFrameworkCore.Data.Repository，大家可以一起来学习一下，如果你觉得合适，可以直接用在你的项目中，很方便。案例代码下载

一、 什么是仓储模式

仓储（Repository）模式自2004年首次作为领域驱动模型DDD设计的一部分引入，仓储本质上是提供数据的抽象，以便应用程序可以使用具有接口的相似的简单抽象集合。从此集合中CURD是通过一系列直接的方法完成，无需处理连接、命令等问题，使用此种模式可帮助实现松耦合，并保持领域对象的持久性无知。

  • 仓储模式是为了在程序的数据访问层和业务逻辑层之间创建的一个抽象层
  • 仓储模式是一种数据访问模式，提供一种更松散耦合的数据访问方法
  • 将创建数据访问的逻辑写在单独的类中即仓储
  • 仓储负责和业务层进行持久化通信

下图为控制器和仓储协同工作的图例：
仓储示意图

二、泛型仓储

仓储（Repository）是存在于工作单元和数据库之间单独分离出来的一层，是对数据访问的封装。其优点是

  • 业务层无需知道具体实现，达到分离关注点；
  • 提高对数据库访问的维护，对于仓储的改变，并不改变业务的逻辑；

如果我们采用的ORM框架是EF Core，实现仓储模式的话，那么类图设计一般如下：
仓储模式类图通常实现仓储的时候，会使用泛型技术封装增删改查的的通用功能，类型T即为具体要进行增删改查处理的实体类型。

使用泛型仓储（Generic Repository）的好处有以下几点：

  • 更好的可重用性：泛型仓储可以在多个实体类型之间共享和重用，减少了重复的代码编写和维护工作。
  • 更好的类型安全性：使用泛型仓储可以在编译时就约束数据的类型，减少了运行时类型错误的可能性。
  • 更好的简洁性：泛型仓储可以通过使用通用的方法和接口来简化数据访问的逻辑，提供统一的CRUD（增删改查）操作接口。
  • 更好的可测试性：泛型仓储使得数据访问逻辑可以更容易地进行单元测试，因为可以使用模拟或者假数据来代替实际的数据存储。
  • 更好的扩展性：泛型仓储可以通过继承或者接口实现来扩展其功能，例如添加自定义的查询方法或者过滤器。

三、基于EF Core实现的泛型仓储案例

开发环境：

操作系统： Windows 10 专业版
平台版本是：.NET 6
开发框架：ASP.NET Core WebApi、Entity Framework Core
开发工具：Visual Studio 2022
数据库： MySQL 5.7+

安装NuGet包

使用的NuGet包主要有：

  1. EntityFrameworkCore.Data.Repository – 一个老外封装好的开源EfCore仓储实现
  2. EntityFrameworkCore.Data.UnitOfWork-- 跟以上配套的工作单元
  3. Pomelo.EntityFrameworkCore.MySql – MySQL数据库提供程序

简单剖析一下 EntityFrameworkCore.Data.Repository

可以看到，作者定义了泛型仓储接口如下：

public interface IRepository<T> : IRepository, IDisposable, ISyncRepository<T>, ISyncRepository, IQueryFactory<T>, IAsyncRepository<T>, IAsyncRepository where T : class
{
}

IRepository< T >接口分别集继承了 ISyncRepository< T > 和 IAsyncRepository< T >这两个接口，分别是同步仓储方法接口和异步仓储方法接口。

//同步仓储方法接口
public interface ISyncRepository<T> : ISyncRepository, IRepository, IDisposable, IQueryFactory<T> where T : class
{IList<T> Search(IQuery<T> query);IList<TResult> Search<TResult>(IQuery<T, TResult> query);T SingleOrDefault(IQuery<T> query);TResult SingleOrDefault<TResult>(IQuery<T, TResult> query);T FirstOrDefault(IQuery<T> query);TResult FirstOrDefault<TResult>(IQuery<T, TResult> query);T LastOrDefault(IQuery<T> query);TResult LastOrDefault<TResult>(IQuery<T, TResult> query);bool Any(Expression<Func<T, bool>> predicate = null);int Count(Expression<Func<T, bool>> predicate = null);long LongCount(Expression<Func<T, bool>> predicate = null);TResult Max<TResult>(Expression<Func<T, TResult>> selector, Expression<Func<T, bool>> predicate = null);TResult Min<TResult>(Expression<Func<T, TResult>> selector, Expression<Func<T, bool>> predicate = null);decimal Average(Expression<Func<T, decimal>> selector, Expression<Func<T, bool>> predicate = null);decimal Sum(Expression<Func<T, decimal>> selector, Expression<Func<T, bool>> predicate = null);T Attach(T entity);void AttachRange(IEnumerable<T> entities);T Add(T entity);void AddRange(IEnumerable<T> entities);T Update(T entity, params Expression<Func<T, object>>[] properties);int Update(Expression<Func<T, bool>> predicate, Expression<Func<T, T>> expression);void UpdateRange(IEnumerable<T> entities, params Expression<Func<T, object>>[] properties);T Remove(T entity);int Remove(Expression<Func<T, bool>> predicate);void RemoveRange(IEnumerable<T> entities);int ExecuteSqlCommand(string sql, params object[] parameters);IList<T> FromSql(string sql, params object[] parameters);void ChangeTable(string table);void ChangeState(T entity, EntityState state);EntityState GetState(T entity);void Reload(T entity);void TrackGraph(T rootEntity, Action<EntityEntryGraphNode> callback);void TrackGraph<TState>(T rootEntity, TState state, Func<EntityEntryGraphNode<TState>, bool> callback);IQueryable<T> ToQueryable(IQuery<T> query);IQueryable<TResult> ToQueryable<TResult>(IQuery<T, TResult> query);
}

//异步仓储方法接口
public interface IAsyncRepository<T> : IAsyncRepository, IRepository, IDisposable, IQueryFactory<T> where T : class
{Task<IList<T>> SearchAsync(IQuery<T> query, CancellationToken cancellationToken = default(CancellationToken));Task<IList<TResult>> SearchAsync<TResult>(IQuery<T, TResult> query, CancellationToken cancellationToken = default(CancellationToken));Task<T> SingleOrDefaultAsync(IQuery<T> query, CancellationToken cancellationToken = default(CancellationToken));Task<TResult> SingleOrDefaultAsync<TResult>(IQuery<T, TResult> query, CancellationToken cancellationToken = default(CancellationToken));Task<T> FirstOrDefaultAsync(IQuery<T> query, CancellationToken cancellationToken = default(CancellationToken));Task<TResult> FirstOrDefaultAsync<TResult>(IQuery<T, TResult> query, CancellationToken cancellationToken = default(CancellationToken));Task<T> LastOrDefaultAsync(IQuery<T> query, CancellationToken cancellationToken = default(CancellationToken));Task<TResult> LastOrDefaultAsync<TResult>(IQuery<T, TResult> query, CancellationToken cancellationToken = default(CancellationToken));Task<bool> AnyAsync(Expression<Func<T, bool>> predicate = null, CancellationToken cancellationToken = default(CancellationToken));Task<int> CountAsync(Expression<Func<T, bool>> predicate = null, CancellationToken cancellationToken = default(CancellationToken));Task<long> LongCountAsync(Expression<Func<T, bool>> predicate = null, CancellationToken cancellationToken = default(CancellationToken));Task<TResult> MaxAsync<TResult>(Expression<Func<T, TResult>> selector, Expression<Func<T, bool>> predicate = null, CancellationToken cancellationToken = default(CancellationToken));Task<TResult> MinAsync<TResult>(Expression<Func<T, TResult>> selector, Expression<Func<T, bool>> predicate = null, CancellationToken cancellationToken = default(CancellationToken));Task<decimal> AverageAsync(Expression<Func<T, decimal>> selector, Expression<Func<T, bool>> predicate = null, CancellationToken cancellationToken = default(CancellationToken));Task<decimal> SumAsync(Expression<Func<T, decimal>> selector, Expression<Func<T, bool>> predicate = null, CancellationToken cancellationToken = default(CancellationToken));Task<T> AddAsync(T entity, CancellationToken cancellationToken = default(CancellationToken));Task AddRangeAsync(IEnumerable<T> entities, CancellationToken cancellationToken = default(CancellationToken));Task<int> UpdateAsync(Expression<Func<T, bool>> predicate, Expression<Func<T, T>> expression, CancellationToken cancellationToken = default(CancellationToken));Task<int> RemoveAsync(Expression<Func<T, bool>> predicate, CancellationToken cancellationToken = default(CancellationToken));Task<IList<T>> FromSqlAsync(string sql, IEnumerable<object> parameters = null, CancellationToken cancellationToken = default(CancellationToken));Task<int> ExecuteSqlCommandAsync(string sql, IEnumerable<object> parameters = null, CancellationToken cancellationToken = default(CancellationToken));Task ReloadAsync(T entity, CancellationToken cancellationToken = default(CancellationToken));
}

//泛型仓储的实现（列举一部分实现，感兴趣的可以自己查看源码）
public class Repository<T> : IRepository<T>, IRepository, IDisposable, ISyncRepository<T>, ISyncRepository, IQueryFactory<T>, IAsyncRepository<T>, IAsyncRepository where T : class
{private bool _disposed;protected DbContext DbContext { get; }protected DbSet<T> DbSet { get; }public Repository(DbContext dbContext){DbContext = dbContext ?? throw new ArgumentNullException("dbContext", "dbContext cannot be null.");DbSet = dbContext.Set<T>();}public virtual ISingleResultQuery<T> SingleResultQuery(){return EntityFrameworkCore.QueryBuilder.SingleResultQuery<T>.New();}public virtual IMultipleResultQuery<T> MultipleResultQuery(){return EntityFrameworkCore.QueryBuilder.MultipleResultQuery<T>.New();}public virtual ISingleResultQuery<T, TResult> SingleResultQuery<TResult>(){return SingleResultQuery<T, TResult>.New();}public virtual IMultipleResultQuery<T, TResult> MultipleResultQuery<TResult>(){return MultipleResultQuery<T, TResult>.New();}public virtual IList<T> Search(IQuery<T> query){if (query == null){throw new ArgumentNullException("query", "query cannot be null.");}return ToQueryable(query).ToList();}public virtual T Add(T entity){if (entity == null){throw new ArgumentNullException("entity", "entity cannot be null.");}DbSet.Add(entity);return entity;}public virtual void AddRange(IEnumerable<T> entities){if (entities == null){throw new ArgumentNullException("entities", "entities cannot be null.");}if (entities.Any()){DbSet.AddRange(entities);}}public virtual T Update(T entity, params Expression<Func<T, object>>[] properties){if (entity == null){throw new ArgumentNullException("entity", "entity cannot be null.");}if (properties != null && properties.Any()){EntityEntry<T> entityEntry = DbContext.Entry(entity);foreach (Expression<Func<T, object>> propertyExpression in properties){PropertyEntry propertyEntry;try{propertyEntry = entityEntry.Property(propertyExpression);}catch{propertyEntry = null;}if (propertyEntry != null){propertyEntry.IsModified = true;continue;}ReferenceEntry referenceEntry;try{referenceEntry = entityEntry.Reference(propertyExpression);}catch{referenceEntry = null;}if (referenceEntry != null){EntityEntry targetEntry = referenceEntry.TargetEntry;DbContext.Update(targetEntry.Entity);}}}else{DbSet.Update(entity);}return entity;}public virtual int Update(Expression<Func<T, bool>> predicate, Expression<Func<T, T>> expression){if (predicate == null){throw new ArgumentNullException("predicate", "predicate cannot be null.");}if (expression == null){throw new ArgumentNullException("expression", "expression cannot be null.");}return Queryable.Where(DbSet, predicate).Update(expression);}
public virtual T Remove(T entity){if (entity == null){throw new ArgumentNullException("entity", "entity cannot be null.");}DbSet.Remove(entity);return entity;}public virtual int Remove(Expression<Func<T, bool>> predicate){if (predicate == null){throw new ArgumentNullException("predicate", "predicate cannot be null.");}return Queryable.Where(DbSet, predicate).Delete();}public virtual void RemoveRange(IEnumerable<T> entities){if (entities == null){throw new ArgumentNullException("entities", "entities cannot be null.");}if (entities.Any()){DbSet.RemoveRange(entities);}}

四、 在WebApi项目中使用EntityFrameworkCore.Data.Repository

  1. 在appsettings.json中配置连接字符串
//配置连接字符串"ConnectionStrings": {"default": "Server=localhost;Database=20240114WebApplication;user=root;password=12345;port=3306"},
  1. 在Program.cs中注册相关服务
//注册DbContext服务
string connectionString = builder.Configuration.GetConnectionString("default");
builder.Services.AddDbContext<MyDbContext>(option => option.UseMySql(connectionString, ServerVersion.AutoDetect(connectionString)
));
builder.Services.AddScoped<DbContext, MyDbContext>();// 注册工作单元
builder.Services.AddUnitOfWork();
//builder.Services.AddUnitOfWork<MyDbContext>(); // 多数据库支持
//注册泛型仓储服务
builder.Services.AddScoped(typeof(Repository<>));
  1. 设计实体类，本例图书管理为例
 public class Book{public Book(){Title = string.Empty;ISBN = string.Empty;}[Key]public long Id { get; set; }[Required][MaxLength(100)]public string Title { get; set; }[Required][MaxLength(20)]public string ISBN { get; set; }public long CategoryId { get; set; }//导航属性[ForeignKey("CategoryId")]public virtual Category Category { get; set; }}public class Category
{public Category(){Name = string.Empty;Code = string.Empty;}[Key]public long Id { get; set; }/// <summary>/// 分类代码/// </summary>[Required][MaxLength(30)]public string Code { get; set; }/// <summary>/// 分类名/// </summary>[Required][MaxLength(30)]public string Name { get; set; }//导航属性public virtual IList<Book> Books { get; set; }
}
  1. 实现图书管理API接口

（1）依赖注入泛型仓储和工作单元对象：

[Route("api/[controller]")]
[ApiController]
public class BooksController : ControllerBase
{//泛型仓储private readonly Repository<Book> _bookRepository;private readonly Repository<Category> _categoryRepository;//工作单元private readonly IUnitOfWork _unitOfWork;//构造方法public BooksController(Repository<Book> bookRepository,Repository<Category> categoryRepository,IUnitOfWork unitOfWork){_bookRepository = bookRepository;_categoryRepository = categoryRepository;_unitOfWork = unitOfWork;}
}

（2）实现分页显示：

  //分页查询（使用Include加载导航属性)[HttpGet("GetPageList")]public async Task<ActionResult<IPagedList<BookOutput>>> GetPageList([FromQuery] BookPageRequestInput input){//创建查询对象-MultipleResultQuery表示多结果集查询var query = _bookRepository.MultipleResultQuery<BookOutput>().Page(input.PageIndex, input.PageSize) //分页.AndFilter(b => string.IsNullOrEmpty(input.Title) || b.Title.StartsWith(input.Title)) //筛选条件.Include(q => q.Include(x => x.Category))  //级联加载.OrderByDescending("Title").ThenBy("ISBN") //排序.Select(b => new BookOutput                //投影{CategoryId = b.CategoryId,CategoryCode = b.Category.Code,CategoryName = b.Category.Name,ISBN = b.ISBN,Title = b.Title,Id = b.Id}) as IMultipleResultQuery<Book, BookOutput>; //转换类型//执行查询var result = (await _bookRepository.SearchAsync(query)).ToPagedList(query.Paging.PageIndex,query.Paging.PageSize,query.Paging.TotalCount);return Ok(result);}

  //分页查询（使用IQueryable.Join方法进行联表查询)[HttpGet("GetBookPage")]public async Task<ActionResult<PagedList<BookOutput>>> GetBookPage([FromQuery] BookPageRequestInput input){//获取可IQueryable可查询对象var books = _bookRepository.ToQueryable(_bookRepository.MultipleResultQuery());var categories = _categoryRepository.ToQueryable(_categoryRepository.MultipleResultQuery());var query = books.Join(categories, b => b.CategoryId, c => c.Id,(b, c) => new BookOutput{CategoryId = b.CategoryId,CategoryCode = b.Category.Code,CategoryName = b.Category.Name,ISBN = b.ISBN,Title = b.Title,Id = b.Id}).Where(b => string.IsNullOrEmpty(input.Title) || b.Title.StartsWith(input.Title)).OrderBy(b => b.Id);PagedList<BookOutput> result = new PagedList<BookOutput>();result.TotalCount = await query.CountAsync();result.Items = await query.Skip((input.PageIndex - 1) * input.PageSize).Take(input.PageSize).ToListAsync();return result;}

（3）添加图书：

  //POST api/Books[HttpPost]public async Task<ActionResult<int>> Add([FromBody] BookAddOrUpdateInput input){Book book = new Book{CategoryId = input.CategoryId,ISBN = input.ISBN,Title = input.Title};await _bookRepository.AddAsync(book);var result = await _unitOfWork.SaveChangesAsync();return result;}

（4）修改图书：

   //PUT api/Books[HttpPut]public async Task<ActionResult<int>> Update([FromBody] BookAddOrUpdateInput input){var numAffected = await _bookRepository.UpdateAsync(b => b.Id == input.Id, b => new Book{CategoryId = input.CategoryId,ISBN = input.ISBN,Title = input.Title});var result = await _unitOfWork.SaveChangesAsync();return result;}

（5）删除图书：

   //DELETE api/Books/{id}[HttpDelete("{id}")]public async Task<ActionResult<int>> Delete(long id){var numAffected = await _bookRepository.RemoveAsync(b => b.Id == id);var result = await _unitOfWork.SaveChangesAsync();return result;}

（6）根据ID获取图书：

  //GET api/Books/{id}[HttpGet("{id}")]public async Task<ActionResult<BookOutput>> Get(long id){//创建查询对象，SingleResultQuery表示单条结果查询var query = _bookRepository.SingleResultQuery<BookOutput>().Include(q => q.Include(x => x.Category)).AndFilter(b => b.Id == id).Select(b => new BookOutput  //投影{CategoryId = b.CategoryId,CategoryCode = b.Category.Code,CategoryName = b.Category.Name,ISBN = b.ISBN,Title = b.Title,Id = b.Id});return await _bookRepository.SingleOrDefaultAsync(query);}

本次演示了在ASP.NET Core中使用泛型仓储模式封装EF Core的CRUD方法，推荐大家可以尝试一下EntityFrameworkCore.Data.Repository这个开源仓储实现类。如果本文对你有帮助的话，请点赞+评论+关注，或者转发给需要的朋友。

这篇关于【EFCore仓储模式】介绍一个EFCore的Repository实现的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/629878。

相关文章

HTML5 getUserMedia API网页录音实现指南示例小结

HTML5 getUserMedia API网页录音实现指南示例小结

《HTML5getUserMediaAPI网页录音实现指南示例小结》本教程将指导你如何利用这一API，结合WebAudioAPI，实现网页录音功能,从获取音频流到处理和保存录音，整个过程将逐步... 目录1. html5 getUserMedia API简介1.1 API概念与历史1.2 功能与优势1.3
阅读更多...
Java实现删除文件中的指定内容

Java实现删除文件中的指定内容

《Java实现删除文件中的指定内容》在日常开发中,经常需要对文本文件进行批量处理,其中,删除文件中指定内容是最常见的需求之一,下面我们就来看看如何使用java实现删除文件中的指定内容吧... 目录1. 项目背景详细介绍2. 项目需求详细介绍2.1 功能需求2.2 非功能需求3. 相关技术详细介绍3.1 Ja
阅读更多...
使用Python和OpenCV库实现实时颜色识别系统

使用Python和OpenCV库实现实时颜色识别系统

《使用Python和OpenCV库实现实时颜色识别系统》：本文主要介绍使用Python和OpenCV库实现的实时颜色识别系统,这个系统能够通过摄像头捕捉视频流,并在视频中指定区域内识别主要颜色（红... 目录一、引言二、系统概述三、代码解析1. 导入库2. 颜色识别函数3. 主程序循环四、HSV色彩空间详解
阅读更多...
PostgreSQL中MVCC 机制的实现

PostgreSQL中MVCC 机制的实现

《PostgreSQL中MVCC机制的实现》本文主要介绍了PostgreSQL中MVCC机制的实现,通过多版本数据存储、快照隔离和事务ID管理实现高并发读写,具有一定的参考价值,感兴趣的可以了解一下... 目录一 MVCC 基本原理python1.1 MVCC 核心概念1.2 与传统锁机制对比二 Postg
阅读更多...
SpringBoot整合Flowable实现工作流的详细流程

SpringBoot整合Flowable实现工作流的详细流程

《SpringBoot整合Flowable实现工作流的详细流程》Flowable是一个使用Java编写的轻量级业务流程引擎,Flowable流程引擎可用于部署BPMN2.0流程定义,创建这些流程定义的... 目录1、流程引擎介绍2、创建项目3、画流程图4、开发接口4.1 Java 类梳理4.2 查看流程图4
阅读更多...
C++中零拷贝的多种实现方式

C++中零拷贝的多种实现方式

《C++中零拷贝的多种实现方式》本文主要介绍了C++中零拷贝的实现示例,旨在在减少数据在内存中的不必要复制,从而提高程序性能、降低内存使用并减少CPU消耗,零拷贝技术通过多种方式实现,下面就来了解一下... 目录一、C++中零拷贝技术的核心概念二、std::string_view 简介三、std::stri
阅读更多...
C++高效内存池实现减少动态分配开销的解决方案

C++高效内存池实现减少动态分配开销的解决方案

《C++高效内存池实现减少动态分配开销的解决方案》C++动态内存分配存在系统调用开销、碎片化和锁竞争等性能问题,内存池通过预分配、分块管理和缓存复用解决这些问题,下面就来了解一下... 目录一、C++内存分配的性能挑战二、内存池技术的核心原理三、主流内存池实现：TCMalloc与Jemalloc1. TCM
阅读更多...
OpenCV实现实时颜色检测的示例

OpenCV实现实时颜色检测的示例

《OpenCV实现实时颜色检测的示例》本文主要介绍了OpenCV实现实时颜色检测的示例,通过HSV色彩空间转换和色调范围判断实现红黄绿蓝颜色检测,包含视频捕捉、区域标记、颜色分析等功能,具有一定的参考... 目录一、引言二、系统概述三、代码解析1. 导入库2. 颜色识别函数3. 主程序循环四、HSV色彩空间
阅读更多...
Redis Cluster模式配置

Redis Cluster模式配置

《RedisCluster模式配置》：本文主要介绍RedisCluster模式配置,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录分片 一、分片的本质与核心价值二、分片实现方案对比 ‌三、分片算法详解1. ‌范围分片（顺序分片）‌2. ‌哈希分片3. ‌虚
阅读更多...
Python实现精准提取 PDF中的文本,表格与图片

Python实现精准提取 PDF中的文本,表格与图片

《Python实现精准提取PDF中的文本,表格与图片》在实际的系统开发中,处理PDF文件不仅限于读取整页文本,还有提取文档中的表格数据,图片或特定区域的内容,下面我们来看看如何使用Python实... 目录安装 python 库提取 PDF 文本内容：获取整页文本与指定区域内容获取页面上的所有文本内容获取
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2