.NET Core MongoDB数据仓储和工作单元模式封装

前言

         上一章我们把系统所需要的MongoDB集合设计好了，这一章我们的主要任务是使用.NET Core应用程序连接MongoDB并且封装MongoDB数据仓储和工作单元模式，因为本章内容涵盖的有点多关于仓储和工作单元的使用就放到下一章节中讲解了。仓储模式（Repository ）带来的好处是一套代码可以适用于多个类，把常用的CRUD通用方法抽象出来通过接口形式集中管理，从而解除业务逻辑层与数据访问层之间的耦合，使业务逻辑层在存储、访问数据库时无须关心数据的来源及存储方式。工作单元模式（UnitOfWork）它是用来维护一个由已经被业务修改(如增加、删除和更新等)的业务对象组成的列表，跨多个请求的业务，统一管理事务，统一提交从而保障事物一致性的作用。

MongoDB从入门到实战的相关教程

MongoDB从入门到实战之MongoDB简介👉

MongoDB从入门到实战之MongoDB快速入门👉

MongoDB从入门到实战之Docker快速安装MongoDB👉

MongoDB从入门到实战之MongoDB工作常用操作命令👉

MongoDB从入门到实战之.NET Core使用MongoDB开发ToDoList系统（1）-后端项目框架搭建👉

MongoDB从入门到实战之.NET Core使用MongoDB开发ToDoList系统（2）-Swagger框架集成👉

MongoDB从入门到实战之.NET Core使用MongoDB开发ToDoList系统（3）-系统数据集合设计👉

MongoDB从入门到实战之.NET Core使用MongoDB开发ToDoList系统（4）-MongoDB数据仓储和工作单元模式封装👉

YyFlight.ToDoList项目源码地址

欢迎各位看官老爷review，有帮助的别忘了给我个Star哦💖！！！

GitHub地址：GitHub - YSGStudyHards/YyFlight.ToDoList: 【.NET8 MongoDB 待办清单系统】.NET8 MongoDB从入门到实战基础教程，该项目后端使用的是.NET8、前端页面使用Blazor、使用MongoDB存储数据，更多相关内容大家可以看目录中的MongoDB从入门到实战的相关教程。该系列教程可作为.NET Core入门项目进行学习，感兴趣的小伙伴可以关注博主和我一起学习共同进步。

MongoRepository地址：https://github.com/YSGStudyHards/YyFlight.ToDoList/tree/main/Repository/Repository

MongoDB事务使用前提说明

参阅MongoDB的事务

说明：

MongoDB单机服务器不支持事务【使用MongoDB事务会报错：Standalone servers do not support transactions】,只有在集群情况下才支持事务，因为博主接下来都是在单机环境下操作，所以无法来演示Mongo事务操作，但是方法都已经是封装好了的，大家可以自己搭建集群实操。

原因：

MongoDB在使用分布式事务时需要进行多节点之间的协调和通信，而单机环境下无法实现这样的分布式协调和通信机制。但是，在MongoDB部署为一个集群（cluster）后，将多个计算机连接为一个整体，通过协调和通信机制实现了分布式事务的正常使用。从数据一致性和可靠性的角度来看，在分布式系统中实现事务处理是至关重要的。而在单机环境下不支持事务，只有在集群情况下才支持事务的设计方式是为了保证数据一致性和可靠性，并且也符合分布式系统的设计思想。

MongoDB.Driver驱动安装

1、直接命令自动安装

Install-Package MongoDB.Driver

2、搜索Nuget手动安装

MongoSettings数据库连接配置

前往appsettings.json文件中配置Mongo数据库信息：

  "MongoSettings": {"Connection": "mongodb://root:123456@local:27017/yyflight_todolist?authSource=admin", //MongoDB连接字符串"DatabaseName": "yyflight_todolist" //MongoDB数据库名称}

定义单例的MongoClient

基于MongoDB的最佳实践对于MongoClient最好设置为单例注入，因为在MongoDB.Driver中MongoClient已经被设计为线程安全可以被多线程共享，这样可还以避免反复实例化MongoClient带来的开销，避免在极端情况下的性能低下。

我们这里设计一个MongoConnection类，用于包裹这个MongoClient，然后将其以单例模式注入IoC容器中。

定义IMongoConnection接口

    public interface IMongoConnection{public MongoClient MongoDBClient { get; set; }public IMongoDatabase DatabaseName { get; set; }}

定义MongoConnection类

    public class MongoConnection : IMongoConnection{//基于MongoDB的最佳实践对于MongoClient最好设置为单例注入，因为在MongoDB.Driver中MongoClient已经被设计为线程安全可以被多线程共享，这样可还以避免反复实例化MongoClient带来的开销，避免在极端情况下的性能低下。//我们这里设计一个MongoConnection类，用于包裹这个MongoClient，然后将其以单例模式注入IoC容器中。public MongoClient MongoDBClient { get; set; }public IMongoDatabase DatabaseName { get; set; }public MongoConnection(IConfiguration configuration){MongoDBClient = new MongoClient(configuration["MongoSettings:Connection"]);DatabaseName = MongoDBClient.GetDatabase(configuration["MongoSettings:DatabaseName"]);}}

定义Mongo DBContext上下文

现在我们将定义MongoDB DBContext上下文类，具体到一个业务对象或需要被持久化的对象，这个上下文类将封装数据库的连接和集合。
该类应负责建立与所需数据库的连接，在建立连接后，该类将在内存中或按请求持有数据库上下文（基于API管道中配置的生命周期管理。）

定义IMongoContext接口 

    public interface IMongoContext : IDisposable{/// <summary>/// 添加命令操作/// </summary>/// <param name="func">委托 方法接受一个 Func<IClientSessionHandle, Task> 委托作为参数，该委托表示一个需要 IClientSessionHandle 对象作为参数并返回一个异步任务的方法</param>/// <returns></returns>Task AddCommandAsync(Func<IClientSessionHandle, Task> func);/// <summary>/// 提交更改并返回受影响的行数/// TODO：MongoDB单机服务器不支持事务【使用MongoDB事务会报错：Standalone servers do not support transactions】,只有在集群情况下才支持事务/// 原因：MongoDB在使用分布式事务时需要进行多节点之间的协调和通信，而单机环境下无法实现这样的分布式协调和通信机制。但是，在MongoDB部署为一个集群（cluster）后，将多个计算机连接为一个整体，通过协调和通信机制实现了分布式事务的正常使用。从数据一致性和可靠性的角度来看，在分布式系统中实现事务处理是至关重要的。而在单机环境下不支持事务，只有在集群情况下才支持事务的设计方式是为了保证数据一致性和可靠性，并且也符合分布式系统的设计思想。/// </summary>/// <param name="session">MongoDB 会话（session）对象</param>/// <returns></returns>Task<int> SaveChangesAsync(IClientSessionHandle session);/// <summary>/// 初始化Mongodb会话对象session/// </summary>/// <returns></returns>Task<IClientSessionHandle> StartSessionAsync();/// <summary>/// 获取集合数据/// </summary>/// <typeparam name="T"></typeparam>/// <param name="name"></param>/// <returns></returns>IMongoCollection<T> GetCollection<T>(string name);}

定义MongoContext类

    public class MongoContext : IMongoContext{private readonly IMongoDatabase _databaseName;private readonly MongoClient _mongoClient;//这里将 _commands 中的每个元素都定义为一个 Func<IClientSessionHandle, Task> 委托，此委托表示一个需要 IClientSessionHandle 对象作为参数并返回一个异步任务的方法//每个委托都表示一个MongoDB 会话（session）对象和要执行的命令private readonly List<Func<IClientSessionHandle, Task>> _commands = new List<Func<IClientSessionHandle, Task>>();public MongoContext(IMongoConnection mongoConnection){_mongoClient = mongoConnection.MongoDBClient;_databaseName = mongoConnection.DatabaseName;}/// <summary>/// 添加命令操作/// </summary>/// <param name="func">方法接受一个 Func<IClientSessionHandle, Task> 委托作为参数，该委托表示一个需要 IClientSessionHandle 对象作为参数并返回一个异步任务的方法</param>/// <returns></returns>public async Task AddCommandAsync(Func<IClientSessionHandle, Task> func){_commands.Add(func);await Task.CompletedTask;}/// <summary>/// 提交更改并返回受影响的行数/// TODO：MongoDB单机服务器不支持事务【使用MongoDB事务会报错：Standalone servers do not support transactions】,只有在集群情况下才支持事务/// 原因：MongoDB在使用分布式事务时需要进行多节点之间的协调和通信，而单机环境下无法实现这样的分布式协调和通信机制。但是，在MongoDB部署为一个集群（cluster）后，将多个计算机连接为一个整体，通过协调和通信机制实现了分布式事务的正常使用。从数据一致性和可靠性的角度来看，在分布式系统中实现事务处理是至关重要的。而在单机环境下不支持事务，只有在集群情况下才支持事务的设计方式是为了保证数据一致性和可靠性，并且也符合分布式系统的设计思想。/// </summary>/// <param name="session">MongoDB 会话（session）对象</param>/// <returns></returns>public async Task<int> SaveChangesAsync(IClientSessionHandle session){try{session.StartTransaction();//开始事务foreach (var command in _commands){await command(session);//语句实现了对事务中所有操作的异步执行，并等待它们完成。如果没有错误发生，程序会继续执行session.CommitTransactionAsync();方法，将之前进行的所有更改一起提交到MongoDB服务器上，从而实现事务提交。}await session.CommitTransactionAsync();//提交事务return _commands.Count;}catch (Exception ex){await session.AbortTransactionAsync();//回滚事务return 0;}finally{_commands.Clear();//清空_commands列表中的元素}}/// <summary>/// 初始化Mongodb会话对象session/// </summary>/// <returns></returns>public async Task<IClientSessionHandle> StartSessionAsync(){var session = await _mongoClient.StartSessionAsync();return session;}/// <summary>/// 获取MongoDB集合/// </summary>/// <typeparam name="T"></typeparam>/// <param name="name">集合名称</param>/// <returns></returns>public IMongoCollection<T> GetCollection<T>(string name){return _databaseName.GetCollection<T>(name);}/// <summary>/// 释放上下文/// </summary>public void Dispose(){GC.SuppressFinalize(this);}}

定义通用泛型Repository

Repository(仓储)是DDD(领域驱动设计)中的经典思想，可以归纳为介于实际业务层(领域层)和数据访问层之间的层，能让领域层能在感觉不到数据访问层的情况下，完成与数据库的交互和以往的DAO(数据访问)层相比，Repository层的设计理念更偏向于面向对象，而淡化直接对数据表进行的CRUD操作。

定义IMongoRepository接口

定义一个泛型Repository通用接口，抽象常用的增加，删除，修改，查询等操作方法。

    public interface IMongoRepository<T> where T : class, new(){#region 事务操作示例/// <summary>/// 事务添加数据/// </summary>/// <param name="session">MongoDB 会话（session）对象</param>/// <param name="objData">添加数据</param>/// <returns></returns>Task AddTransactionsAsync(IClientSessionHandle session, T objData);/// <summary>/// 事务数据删除/// </summary>/// <param name="session">MongoDB 会话（session）对象</param>/// <param name="id">objectId</param>/// <returns></returns>Task DeleteTransactionsAsync(IClientSessionHandle session, string id);/// <summary>/// 事务异步局部更新（仅更新一条记录）/// </summary>/// <param name="session">MongoDB 会话（session）对象</param>/// <param name="filter">过滤器</param>/// <param name="update">更新条件</param>/// <returns></returns>Task UpdateTransactionsAsync(IClientSessionHandle session, FilterDefinition<T> filter, UpdateDefinition<T> update);#endregion#region 添加相关操作/// <summary>/// 添加数据/// </summary>/// <param name="objData">添加数据</param>/// <returns></returns>Task AddAsync(T objData);/// <summary>/// 批量插入/// </summary>/// <param name="objDatas">实体集合</param>/// <returns></returns>Task InsertManyAsync(List<T> objDatas);#endregion#region 删除相关操作/// <summary>/// 数据删除/// </summary>/// <param name="id">objectId</param>/// <returns></returns>Task DeleteAsync(string id);/// <summary>/// 异步删除多条数据/// </summary>/// <param name="filter">删除的条件</param>/// <returns></returns>Task<DeleteResult> DeleteManyAsync(FilterDefinition<T> filter);#endregion#region 修改相关操作/// <summary>/// 指定对象异步修改一条数据/// </summary>/// <param name="obj">要修改的对象</param>/// <param name="id">修改条件</param>/// <returns></returns>Task UpdateAsync(T obj, string id);/// <summary>/// 局部更新（仅更新一条记录）/// <para><![CDATA[expression 参数示例：x => x.Id == 1 && x.Age > 18 && x.Gender == 0]]></para>/// <para><![CDATA[entity 参数示例：y => new T{ RealName = "Ray", Gender = 1}]]></para>/// </summary>/// <param name="expression">筛选条件</param>/// <param name="entity">更新条件</param>/// <returns></returns>Task UpdateAsync(Expression<Func<T, bool>> expression, Expression<Action<T>> entity);/// <summary>/// 异步局部更新（仅更新一条记录）/// </summary>/// <param name="filter">过滤器</param>/// <param name="update">更新条件</param>/// <returns></returns>Task UpdateAsync(FilterDefinition<T> filter, UpdateDefinition<T> update);/// <summary>/// 异步局部更新（仅更新多条记录）/// </summary>/// <param name="expression">筛选条件</param>/// <param name="update">更新条件</param>/// <returns></returns>Task UpdateManyAsync(Expression<Func<T, bool>> expression, UpdateDefinition<T> update);/// <summary>/// 异步批量修改数据/// </summary>/// <param name="dic">要修改的字段</param>/// <param name="filter">更新条件</param>/// <returns></returns>Task<UpdateResult> UpdateManayAsync(Dictionary<string, string> dic, FilterDefinition<T> filter);#endregion#region 查询统计相关操作/// <summary>/// 通过ID主键获取数据/// </summary>/// <param name="id">objectId</param>/// <returns></returns>Task<T> GetByIdAsync(string id);/// <summary>/// 获取所有数据/// </summary>/// <returns></returns>Task<IEnumerable<T>> GetAllAsync();/// <summary>/// 获取记录数/// </summary>/// <param name="expression">筛选条件</param>/// <returns></returns>Task<long> CountAsync(Expression<Func<T, bool>> expression);/// <summary>/// 获取记录数/// </summary>/// <param name="filter">过滤器</param>/// <returns></returns>Task<long> CountAsync(FilterDefinition<T> filter);/// <summary>/// 判断是否存在/// </summary>/// <param name="predicate">条件</param>/// <returns></returns>Task<bool> ExistsAsync(Expression<Func<T, bool>> predicate);/// <summary>/// 异步查询集合/// </summary>/// <param name="filter">查询条件</param>/// <param name="field">要查询的字段,不写时查询全部</param>/// <param name="sort">要排序的字段</param>/// <returns></returns>Task<List<T>> FindListAsync(FilterDefinition<T> filter, string[]? field = null, SortDefinition<T>? sort = null);/// <summary>/// 异步分页查询集合/// </summary>/// <param name="filter">查询条件</param>/// <param name="pageIndex">当前页</param>/// <param name="pageSize">页容量</param>/// <param name="field">要查询的字段,不写时查询全部</param>/// <param name="sort">要排序的字段</param>/// <returns></returns>Task<List<T>> FindListByPageAsync(FilterDefinition<T> filter, int pageIndex, int pageSize, string[]? field = null, SortDefinition<T>? sort = null);#endregion}

实现泛型MongoBaseRepository基类

    public class MongoBaseRepository<T> : IMongoRepository<T> where T : class, new(){protected readonly IMongoContext _context;protected readonly IMongoCollection<T> _dbSet;private readonly string _collectionName;protected MongoBaseRepository(IMongoContext context){_context = context;_collectionName = typeof(T).GetAttributeValue((TableAttribute m) => m.Name) ?? typeof(T).Name;_dbSet = _context.GetCollection<T>(_collectionName);}#region 事务操作示例/// <summary>/// 事务添加数据/// </summary>/// <param name="session">MongoDB 会话（session）对象</param>/// <param name="objData">添加数据</param>/// <returns></returns>public async Task AddTransactionsAsync(IClientSessionHandle session, T objData){await _context.AddCommandAsync(async (session) => await _dbSet.InsertOneAsync(objData));}/// <summary>/// 事务数据删除/// </summary>/// <param name="session">MongoDB 会话（session）对象</param>/// <param name="id">objectId</param>/// <returns></returns>public async Task DeleteTransactionsAsync(IClientSessionHandle session, string id){await _context.AddCommandAsync((session) => _dbSet.DeleteOneAsync(Builders<T>.Filter.Eq(" _id ", id)));}/// <summary>/// 事务异步局部更新（仅更新一条记录）/// </summary>/// <param name="session">MongoDB 会话（session）对象</param>/// <param name="filter">过滤器</param>/// <param name="update">更新条件</param>/// <returns></returns>public async Task UpdateTransactionsAsync(IClientSessionHandle session, FilterDefinition<T> filter, UpdateDefinition<T> update){await _context.AddCommandAsync((session) => _dbSet.UpdateOneAsync(filter, update));}#endregion#region 添加相关操作/// <summary>/// 添加数据/// </summary>/// <param name="objData">添加数据</param>/// <returns></returns>public async Task AddAsync(T objData){await _dbSet.InsertOneAsync(objData);}/// <summary>/// 批量插入/// </summary>/// <param name="objDatas">实体集合</param>/// <returns></returns>public async Task InsertManyAsync(List<T> objDatas){await _dbSet.InsertManyAsync(objDatas);}#endregion#region 删除相关操作/// <summary>/// 数据删除/// </summary>/// <param name="id">objectId</param>/// <returns></returns>public async Task DeleteAsync(string id){await _dbSet.DeleteOneAsync(Builders<T>.Filter.Eq("_id", new ObjectId(id)));}/// <summary>/// 异步删除多条数据/// </summary>/// <param name="filter">删除的条件</param>/// <returns></returns>public async Task<DeleteResult> DeleteManyAsync(FilterDefinition<T> filter){return await _dbSet.DeleteManyAsync(filter);}#endregion#region 修改相关操作/// <summary>/// 指定对象异步修改一条数据/// </summary>/// <param name="obj">要修改的对象</param>/// <param name="id">修改条件</param>/// <returns></returns>public async Task UpdateAsync(T obj, string id){//修改条件FilterDefinition<T> filter = Builders<T>.Filter.Eq("_id", new ObjectId(id));//要修改的字段var list = new List<UpdateDefinition<T>>();foreach (var item in obj.GetType().GetProperties()){if (item.Name.ToLower() == "id") continue;list.Add(Builders<T>.Update.Set(item.Name, item.GetValue(obj)));}var updatefilter = Builders<T>.Update.Combine(list);await _dbSet.UpdateOneAsync(filter, updatefilter);}/// <summary>/// 局部更新（仅更新一条记录）/// <para><![CDATA[expression 参数示例：x => x.Id == 1 && x.Age > 18 && x.Gender == 0]]></para>/// <para><![CDATA[entity 参数示例：y => new T{ RealName = "Ray", Gender = 1}]]></para>/// </summary>/// <param name="expression">筛选条件</param>/// <param name="entity">更新条件</param>/// <returns></returns>public async Task UpdateAsync(Expression<Func<T, bool>> expression, Expression<Action<T>> entity){var fieldList = new List<UpdateDefinition<T>>();if (entity.Body is MemberInitExpression param){foreach (var item in param.Bindings){var propertyName = item.Member.Name;object propertyValue = null;if (item is not MemberAssignment memberAssignment) continue;if (memberAssignment.Expression.NodeType == ExpressionType.Constant){if (memberAssignment.Expression is ConstantExpression constantExpression)propertyValue = constantExpression.Value;}else{propertyValue = Expression.Lambda(memberAssignment.Expression, null).Compile().DynamicInvoke();}if (propertyName != "_id") //实体键_id不允许更新{fieldList.Add(Builders<T>.Update.Set(propertyName, propertyValue));}}}await _dbSet.UpdateOneAsync(expression, Builders<T>.Update.Combine(fieldList));}/// <summary>/// 异步局部更新（仅更新一条记录）/// </summary>/// <param name="filter">过滤器</param>/// <param name="update">更新条件</param>/// <returns></returns>public async Task UpdateAsync(FilterDefinition<T> filter, UpdateDefinition<T> update){await _dbSet.UpdateOneAsync(filter, update);}/// <summary>/// 异步局部更新（仅更新多条记录）/// </summary>/// <param name="expression">筛选条件</param>/// <param name="update">更新条件</param>/// <returns></returns>public async Task UpdateManyAsync(Expression<Func<T, bool>> expression, UpdateDefinition<T> update){await _dbSet.UpdateManyAsync(expression, update);}/// <summary>/// 异步批量修改数据/// </summary>/// <param name="dic">要修改的字段</param>/// <param name="filter">更新条件</param>/// <returns></returns>public async Task<UpdateResult> UpdateManayAsync(Dictionary<string, string> dic, FilterDefinition<T> filter){T t = new T();//要修改的字段var list = new List<UpdateDefinition<T>>();foreach (var item in t.GetType().GetProperties()){if (!dic.ContainsKey(item.Name)) continue;var value = dic[item.Name];list.Add(Builders<T>.Update.Set(item.Name, value));}var updatefilter = Builders<T>.Update.Combine(list);return await _dbSet.UpdateManyAsync(filter, updatefilter);}#endregion#region 查询统计相关操作/// <summary>/// 通过ID主键获取数据/// </summary>/// <param name="id">objectId</param>/// <returns></returns>public async Task<T> GetByIdAsync(string id){var queryData = await _dbSet.FindAsync(Builders<T>.Filter.Eq("_id", new ObjectId(id)));return queryData.FirstOrDefault();}/// <summary>/// 获取所有数据/// </summary>/// <returns></returns>public async Task<IEnumerable<T>> GetAllAsync(){var queryAllData = await _dbSet.FindAsync(Builders<T>.Filter.Empty);return queryAllData.ToList();}/// <summary>/// 获取记录数/// </summary>/// <param name="expression">筛选条件</param>/// <returns></returns>public async Task<long> CountAsync(Expression<Func<T, bool>> expression){return await _dbSet.CountDocumentsAsync(expression);}/// <summary>/// 获取记录数/// </summary>/// <param name="filter">过滤器</param>/// <returns></returns>public async Task<long> CountAsync(FilterDefinition<T> filter){return await _dbSet.CountDocumentsAsync(filter);}/// <summary>/// 判断是否存在/// </summary>/// <param name="predicate">条件</param>/// <returns></returns>public async Task<bool> ExistsAsync(Expression<Func<T, bool>> predicate){return await Task.FromResult(_dbSet.AsQueryable().Any(predicate));}/// <summary>/// 异步查询集合/// </summary>/// <param name="filter">查询条件</param>/// <param name="field">要查询的字段,不写时查询全部</param>/// <param name="sort">要排序的字段</param>/// <returns></returns>public async Task<List<T>> FindListAsync(FilterDefinition<T> filter, string[]? field = null, SortDefinition<T>? sort = null){//不指定查询字段if (field == null || field.Length == 0){if (sort == null) return await _dbSet.Find(filter).ToListAsync();return await _dbSet.Find(filter).Sort(sort).ToListAsync();}//指定查询字段var fieldList = new List<ProjectionDefinition<T>>();for (int i = 0; i < field.Length; i++){fieldList.Add(Builders<T>.Projection.Include(field[i].ToString()));}var projection = Builders<T>.Projection.Combine(fieldList);fieldList?.Clear();//不排序if (sort == null) return await _dbSet.Find(filter).Project<T>(projection).ToListAsync();//排序查询return await _dbSet.Find(filter).Sort(sort).Project<T>(projection).ToListAsync();}/// <summary>/// 异步分页查询集合/// </summary>/// <param name="filter">查询条件</param>/// <param name="pageIndex">当前页</param>/// <param name="pageSize">页容量</param>/// <param name="field">要查询的字段,不写时查询全部</param>/// <param name="sort">要排序的字段</param>/// <returns></returns>public async Task<List<T>> FindListByPageAsync(FilterDefinition<T> filter, int pageIndex, int pageSize, string[]? field = null, SortDefinition<T>? sort = null){//不指定查询字段if (field == null || field.Length == 0){if (sort == null) return await _dbSet.Find(filter).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToListAsync();//进行排序return await _dbSet.Find(filter).Sort(sort).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToListAsync();}//指定查询字段var fieldList = new List<ProjectionDefinition<T>>();for (int i = 0; i < field.Length; i++){fieldList.Add(Builders<T>.Projection.Include(field[i].ToString()));}var projection = Builders<T>.Projection.Combine(fieldList);fieldList?.Clear();//不排序if (sort == null) return await _dbSet.Find(filter).Project<T>(projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToListAsync();//排序查询return await _dbSet.Find(filter).Sort(sort).Project<T>(projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToListAsync();}#endregion}

工作单元模式

工作单元模式是“维护一个被业务事务影响的对象列表，协调变化的写入和并发问题的解决”。具体来说，在C#工作单元模式中，我们通过UnitOfWork对象来管理多个Repository对象，同时UnitOfWork还提供了对事务的支持。对于一组需要用到多个Repository的业务操作，我们可以在UnitOfWork中创建一个事务，并将多个Repository操作放在同一个事务中处理，以保证数据的一致性。当所有Repository操作完成后，再通过UnitOfWork提交事务或者回滚事务。

定义IUnitOfWork接口

    /// <summary>/// 工作单元接口/// </summary>public interface IUnitOfWork : IDisposable{/// <summary>/// 提交保存更改/// </summary>/// <param name="session">MongoDB 会话（session）对象</param>/// <returns></returns>Task<bool> Commit(IClientSessionHandle session);/// <summary>/// 初始化MongoDB会话对象session/// </summary>/// <returns></returns>Task<IClientSessionHandle> InitTransaction();}

定义UnitOfWork类

    /// <summary>/// 工作单元类/// </summary>public class UnitOfWork : IUnitOfWork{private readonly IMongoContext _context;public UnitOfWork(IMongoContext context){_context = context;}/// <summary>/// 提交保存更改/// </summary>/// <param name="session">MongoDB 会话（session）对象</param>/// <returns></returns>public async Task<bool> Commit(IClientSessionHandle session){return await _context.SaveChangesAsync(session) > 0;}/// <summary>/// 初始化MongoDB会话对象session/// </summary>/// <returns></returns>public async Task<IClientSessionHandle> InitTransaction(){return await _context.StartSessionAsync();}public void Dispose(){_context.Dispose();}}

注册数据库基础操作和工作单元

//注册数据库基础操作和工作单元
builder.Services.AddSingleton<IMongoConnection, MongoConnection>();
builder.Services.AddScoped<IMongoContext, MongoContext>();
builder.Services.AddScoped<IUnitOfWork, UnitOfWork>();
builder.Services.AddScoped<IUserRepository, UserRepository>();

参考文章

NoSQL – MongoDB Repository Implementation in .NET Core with Unit Testing example

ASP.NET CORE – MONGODB REPOSITORY PATTERN & UNIT OF WORK

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/685828.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

两年前的爱爱竟然让她染上菜花和梅毒！医师警告：性病潜伏期不可小觑，HPV疫苗是必备的

两年前的爱爱竟然让她染上菜花和梅毒！医师警告：性病潜伏期不可小觑，HPV疫苗是必备的

【记者许家源/综合报道】 台北市一名30多岁的女性&#xff0c;因为私密处长出不明物体&#xff0c;到泌尿科求诊&#xff0c;没想到被诊断出是菜花&#xff0c;而且还合并了梅毒。 她回想起自己最后一次发生性关系&#xff0c;竟然是两年前和前男友的事&#xff0c;不明白为什…
阅读更多...
搭建 blender python api 的外部开发环境

搭建 blender python api 的外部开发环境

以下都是为了不直接在 blender 的 script ide 里写脚本而做&#xff0c;直接在 blender 里写的话就没什么参考意义了。 首先是2个blender的设置选项&#xff0c;建议开启&#xff0c;会比较方便。 开发选项启用后&#xff0c;你在一些菜单上右键的话&#xff0c;会多出来 在线…
阅读更多...
CleanMyMac X2024版本有哪些常见的使用场景？

CleanMyMac X2024版本有哪些常见的使用场景？

CleanMyMac X作为一款Mac电脑清理和优化工具&#xff0c;具有多种使用场景。以下是一些常见的使用场景&#xff1a; 清理系统垃圾文件&#xff1a;CleanMyMac X可以智能扫描Mac磁盘空间&#xff0c;清理系统冗余文件和各种软件应用产生的垃圾文件&#xff0c;如缓存、日志文件…
阅读更多...
Kotlin基础——类、对象和接口

Kotlin基础——类、对象和接口

文章目录 1 定义类继承结构1.1 接口1.1.1 接口概述1.1.2 接口中的默认方法1.1.3 接口方法重复1.1.4 Kotlin接口中静态方法实现原理 1.2 修饰符1.2.1 类继承修饰1.2.2 方法重写修饰1.2.3 抽象类1.2.4 接口的修饰符 1.3 可见性修饰符1.3.1 Kotlin中的可见性修饰符1.3.2 Kotlin中的…
阅读更多...
林浩然与杨凌芸的时空约会奇遇记

林浩然与杨凌芸的时空约会奇遇记

林浩然与杨凌芸的时空约会奇遇记 The Time-Traveling Love Story of Lin Haoran and Yang Lingyun in the Java World 在那个阳光明媚、Java代码飞舞的日子里&#xff0c;程序员界的“情圣”林浩然和美丽聪明的数据分析师杨凌芸携手演绎了一场跨越时间与空间的爱情故事&#xf…
阅读更多...
ZYNQ：PL－CAN总线功能应用

ZYNQ：PL－CAN总线功能应用

流程背景 前期基本实现PS端的CAN总线功能&#xff0c;现阶段的主要目的是实现PL端的CAN总线功能&#xff0c;需要采用CAN IP。 PL系统搭建 PL外设时钟源 搭建完vivado系统后&#xff0c;需要在sdk编程。但是在配置PL&#xff0d;CAN时&#xff0c;意识到CAN时钟值不清楚&…
阅读更多...
蓝桥省赛真题|简单：分数

蓝桥省赛真题|简单：分数

题目链接&#xff1a;https://www.lanqiao.cn/problems/610/learning/?page1&first_category_id1&second_category_id3&tags2018&name%E5%88%86%E6%95%B0 题不难&#xff0c;但是可以帮助编程时好的习惯的养成&#xff0c;更加注意一些细节。 注意几个地方︰…
阅读更多...
《区块链公链数据分析简易速速上手小册》第10章：未来趋势和挑战（2024 最新版）

《区块链公链数据分析简易速速上手小册》第10章：未来趋势和挑战（2024 最新版）

文章目录 10.1 区块链技术的发展方向10.1.1 基础知识10.1.2 重点案例&#xff1a;构建一个简单的智能合约步骤1: 创建智能合约步骤2: 部署智能合约步骤3: 使用Python与智能合约交互结语 10.1.3 拓展案例 1&#xff1a;探索 DeFi 应用准备工作实现步骤步骤1: 获取Compound市场数…
阅读更多...
Jmeter接口测试实战篇：10分钟学会Jmeter的用法

Jmeter接口测试实战篇：10分钟学会Jmeter的用法

一提到接口测试&#xff0c;通常大家会有这样的疑问&#xff1a;前端测试不是已经覆盖到各种业务逻辑了吗&#xff1f;为什么还要做接口测试&#xff0c;接口测试和前端测试是不是重复了&#xff1f;对于这个问题&#xff0c;可以从下面几个方面来解释&#xff1a; 什么是接口…
阅读更多...
CSS3学习（二）

CSS3学习（二）

目录&#xff1a; 1. 字体属性 1.1 字体系列 1.2 字体大小 1.3 字体粗细 1.4 文字样式 1.5 字体复合属性 1.6 总结 2 文本属性 2.1 文本颜色 2.2 对齐文本 2.3 装饰文本 2.4 文本缩进 2.5 行间距 2.6 总结 1. 字体属性 1.1 字体系列 使用font-family属性定义文…
阅读更多...
Redis篇----第二篇

Redis篇----第二篇

系列文章目录 文章目录 系列文章目录前言一、Memcache 与 Redis 的区别都有哪些？二、Redis 是单进程单线程的？三、一个字符串类型的值能存储最大容量是多少？四、Redis持久化机制前言 前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点…
阅读更多...
optee imx8mm

optee imx8mm

总仓库 git clone https://github.com/Xsyin/imx8mqevk.git -b container_region 替换imx8mqevk中的optee-client git clone https://github.com/nxp-imx/imx-optee-client.git -b lf-5.15.32_2.0.0 用 5.15.32 kernel 会有如下报错&#xff0c;需要将optee os升级到分支 lf-…
阅读更多...
【开源】JAVA+Vue.js实现大学计算机课程管理平台

【开源】JAVA+Vue.js实现大学计算机课程管理平台

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 实验课程档案模块2.2 实验资源模块2.3 学生实验模块 三、系统设计3.1 用例设计3.2 数据库设计3.2.1 实验课程档案表3.2.2 实验资源表3.2.3 学生实验表 四、系统展示五、核心代码5.1 一键生成实验5.2 提交实验5.3 批阅实…
阅读更多...
不同的AI修改同一篇文章标题

不同的AI修改同一篇文章标题

提问AI 我写了一篇文章&#xff0c;请帮我把标题重新改一下&#xff1a;“比较不同AI分析同一个错误代码及给出解决方案的能力&#xff08;结果出我意料&#xff09;” 这篇文章的原地址为&#xff1a;https://blog.csdn.net/snans/article/details/136132211 答案对比结果&am…
阅读更多...
Qt：Qt3个窗口类的区别、VS与QT项目转换

Qt：Qt3个窗口类的区别、VS与QT项目转换

一、Qt3个窗口类的区别 QMainWindow&#xff1a;包含菜单栏、工具栏、状态栏 QWidget&#xff1a;普通的一个窗口&#xff0c;什么也不包括 QDialog&#xff1a;对话框&#xff0c;常用来做登录窗口、弹出窗口&#xff08;例如设置页面&#xff09; QDialog实现简易登录界面…
阅读更多...
网络原理-TCP_IP(6)

网络原理-TCP_IP(6)

网络层 在复杂的网络环境中确定一个合适的路径. IP协议 与TCP协议并列,都是网络体系中最核心的协议. 基本概念 主机:配有IP地址,但是不进行路由控制的设备; 路由器:即配有IP地址,又能进行路由控制; 节点:主机和路由器的统称; 协议头格式 4位版本号(version):指定IP协议的版…
阅读更多...
【机器学习基础】决策树（Decision Tree）

【机器学习基础】决策树（Decision Tree）

&#x1f680;个人主页&#xff1a;为梦而生~ 关注我一起学习吧&#xff01; &#x1f4a1;专栏&#xff1a;机器学习 欢迎订阅&#xff01;后面的内容会越来越有意思~ ⭐特别提醒&#xff1a;针对机器学习&#xff0c;特别开始专栏&#xff1a;机器学习python实战 欢迎订阅&am…
阅读更多...
OpenTitan- 开源安全芯片横空出世

OpenTitan- 开源安全芯片横空出世

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗&#xff1f;订阅我们的简报&#xff0c;深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同&#xff0c;从行业内部的深度分析和实用指南中受益。不要错过这个机会&#xff0c;成为AI领…
阅读更多...
Linux——系统文件I/O

Linux——系统文件I/O

系统文件I/O 注&#xff1a;学习本次内容之前&#xff0c;最好先对C语言文件操作有所了解 本章思维导图&#xff1a; 注&#xff1a;思维导图对应的.xmind文件和.png文件都已同步导入至资源&#xff0c;可供免费查阅 在以前学习的C语言中&#xff0c;我们可以通过fwrite和fre…
阅读更多...
通过玩游戏学会AWS

通过玩游戏学会AWS

游戏名字&#xff1a; Cloud Quest 类型&#xff1a;亚马逊云科技官方出了一款 3D 角色扮演、虚拟城市建造形式的游戏实验课 进入方法&#xff1a;浏览器搜索 Cloud Quest&#xff08;或扫描下方二维码&#xff09;进入 Cloud Quest 课程页。 选择以下的链接 点击进行注册 进…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023