.NET Core MongoDB数据仓储和工作单元模式实操

三剑客时 發表於 2023-4-11 01:10:00

.NET Core MongoDB数据仓储和工作单元模式实操

<h2>前言</h2>
　　上一章节我们主要讲解了MongoDB数据仓储和工作单元模式的封装，这一章节主要讲的是MongoDB用户管理相关操作实操。如：获取所有用户信息、获取用户分页数据、通过用户ID获取对应用户信息、添加用户信息、事务添加用户信息、用户信息修改、用户信息删除等实战教程。
<img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230407222549553-1063502695.png" alt="" loading="lazy">
<h2>MongoDB从入门到实战的相关教程</h2>
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数据仓储和工作单元模式封装👉
MongoDB从入门到实战之.NET Core使用MongoDB开发ToDoList系统（5）-MongoDB数据仓储和工作单元模式实操👉
<h2>YyFlight.ToDoList项目源码地址</h2>
欢迎各位看官老爷review，有帮助的别忘了给我个Star哦💖！！！
<blockquote>
GitHub地址：https://github.com/YSGStudyHards/YyFlight.ToDoList
MongoRepository地址：https://github.com/YSGStudyHards/YyFlight.ToDoList/tree/main/Repository/Repository
</blockquote>
<h2>MongoDB事务使用前提说明</h2>
参阅MongoDB的事务👉
说明：
<blockquote>
MongoDB单机服务器不支持事务【使用MongoDB事务会报错：Standalone servers do not support transactions】,只有在集群情况下才支持事务，因为博主接下来都是在单机环境下操作，所以无法来演示Mongo事务操作，但是方法都已经是封装好了的，大家可以自己搭建集群实操。
</blockquote>
原因：
<blockquote>
MongoDB在使用分布式事务时需要进行多节点之间的协调和通信，而单机环境下无法实现这样的分布式协调和通信机制。但是，在MongoDB部署为一个集群（cluster）后，将多个计算机连接为一个整体，通过协调和通信机制实现了分布式事务的正常使用。从数据一致性和可靠性的角度来看，在分布式系统中实现事务处理是至关重要的。而在单机环境下不支持事务，只有在集群情况下才支持事务的设计方式是为了保证数据一致性和可靠性，并且也符合分布式系统的设计思想。
</blockquote>
<h2>创建EntityBase公共类</h2>
<blockquote>
一个公共的具有相同特性和行为的基类。
</blockquote>
<div class="cnblogs_code">
<pre> public class EntityBase
{
 /// <summary>
 /// 主键Id
 /// </summary>


 public string Id { get; set; }

 /// <summary>
 /// 创建时间
 /// </summary>
 public DateTime CreateDate { get; set; }

 /// <summary>
 /// 更新时间
 /// </summary>
 public DateTime UpdateDate { get; set; }
}</pre>
</div>
<h2>添加UserInfo用户表实体映射模型</h2>
<div class="cnblogs_code">
<pre>
public class UserInfo : EntityBase
{
 /// <summary>
 /// 登录账号
 /// </summary>
 public string UserName { get; set; }

 /// <summary>
 /// 登录密码
 /// </summary>

 public string Password { get; set; }

 /// <summary>
 /// 用户昵称
 /// </summary>
 public string NickName { get; set; }

 /// <summary>
 /// 用户头像
 /// </summary>
 public string HeadPortrait { get; set; }

 /// <summary>
 /// 用户邮箱
 /// </summary>
 public string Email { get; set; }

 /// <summary>
 /// 用户状态（0冻结，1正常，2注销）
 /// </summary>
 public int Status { get; set; }
}</pre>
</div>
在前面类中，Id属性中的特性的作用：
<ul>
<li>需要用于将通用语言运行时（CLR）对象映射到MongoDB集合。</li>
<li>用进行注释，使该属性成为文档的主键。</li>
<li>用进行注释，以允许以字符串类型而不是ObjectId结构传递参数。Mongo处理从字符串到ObjectId的转换。没有此特性序列化时会有如下异常提示：</li>
</ul>
<blockquote>
System.FormatException: An error occurred while deserializing the Id property of class Repository.Domain.User.UserInfo: Cannot deserialize a 'String' from BsonType 'ObjectId'.
</blockquote>
<h4>知识拓展MongoDB ObjectId类型概述：</h4>
<blockquote>
每次插入一条数据系统都会自动插入一个_id键，键值不可以重复，它可以是任何类型的，也可以手动的插入，默认情况下它的数据类型是ObjectId，由于MongoDB在设计之初就是用作分布式数据库，所以使用ObjectId可以避免不同数据库中_id的重复（如果使用自增的方式在分布式系统中就会出现重复的_id的值）。 ObjectId使用12字节的存储空间，每个字节可以存储两个十六进制数字，所以一共可以存储24个十六进制数字组成的字符串，在这24个字符串中，前8位表示时间戳，接下来6位是一个机器码，接下来4位表示进程id，最后6位表示计数器。

</blockquote>
MongoDB 采用 ObjectId 来表示主键的类型，数据库中每个文档都拥有一个_id 字段表示主键，_id 的生成规则如下：
<blockquote>
其中包括4-byte Unix 时间戳，3-byte 机器 ID，2-byte 进程 ID，3-byte 计数器(初始化随机)

</blockquote>
<img src="https://img2023.cnblogs.com/blog/1336199/202303/1336199-20230327213834087-2092438723.png" alt="" class="medium-zoom-image" loading="lazy">
<div class="cnblogs_Highlighter">
<pre class="brush:csharp;gutter:true;">601e2b6ba3203cc89f 2d31aa
↑ ↑ ↑ ↑
时间戳机器码进程ID 随机数　</pre>
</div>
<h2>创建用户Repository</h2>
<h3>创建用户IUserRepository接口</h3>
<div class="cnblogs_code">
<pre> public interface IUserRepository : IMongoRepository<UserInfo>
{
}</pre>
</div>
<h3>创建用户UserRepository类</h3>
<div class="cnblogs_code">
<pre> public class UserRepository : MongoBaseRepository<UserInfo>, IUserRepository
{
 public UserRepository(IMongoContext context) : base(context)
 {
 }
}</pre>
</div>
<h2>创建用户管理业务代码</h2>
<h3>创建IUserOperationExampleServices接口</h3>
<div class="cnblogs_code">
<pre> public interface IUserOperationExampleServices
{
 /// <summary>
 /// 获取所有用户信息
 /// </summary>
 /// <returns></returns>
 Task<IEnumerable<UserInfo>> GetAllUserInfos();

 /// <summary>
 /// 用户分页数据获取
 /// </summary>
 /// <param name="userInfoByPageListReq">userInfoByPageListReq</param>
 /// <returns></returns>
 Task<IEnumerable<UserInfo>> GetUserInfoByPageList(UserInfoByPageListReq userInfoByPageListReq);

 /// <summary>
 /// 通过用户ID获取对应用户信息
 /// </summary>
 /// <param name="id">id</param>
 /// <returns></returns>
 Task<UserInfo> GetUserInfoById(string id);

 /// <summary>
 /// 添加用户信息
 /// </summary>
 /// <param name="userInfo">userInfo</param>
 /// <returns></returns>
 Task<UserInfo> AddUserInfo(UserInfoReq userInfo);

 /// <summary>
 /// 事务添加用户信息
 /// </summary>
 /// <param name="userInfo">userInfo</param>
 /// <returns></returns>
 Task<UserInfo> AddUserInfoTransactions(UserInfoReq userInfo);

 /// <summary>
 /// 用户信息修改
 /// </summary>
 /// <param name="id">id</param>
 /// <param name="userInfo">userInfo</param>
 /// <returns></returns>
 Task<UserInfo> UpdateUserInfo(string id, UserInfoReq userInfo);

 /// <summary>
 /// 用户信息删除
 /// </summary>
 /// <param name="id">id</param>
 /// <returns></returns>
 Task<bool> Delete(string id);
}</pre>
</div>
<h3>创建UserOperationExampleServices类</h3>
<div class="cnblogs_code">
<pre> public class UserOperationExampleServices : IUserOperationExampleServices
{
 private readonly IUnitOfWork _unitOfWork;
 private readonly IUserRepository _userRepository;

 /// <summary>
 /// 依赖注入
 /// </summary>
 /// <param name="unitOfWork">unitOfWork</param>
 /// <param name="userRepository">userRepository</param>
 public UserOperationExampleServices(IUnitOfWork unitOfWork, IUserRepository userRepository)
 {
 _unitOfWork = unitOfWork;
 _userRepository = userRepository;
 }

 /// <summary>
 /// 获取所有用户信息
 /// </summary>
 /// <returns></returns>
 public async Task<IEnumerable<UserInfo>> GetAllUserInfos()
 {
 var getAllUserInfos = await _userRepository.GetAllAsync();
 return getAllUserInfos;
 }

 /// <summary>
 /// 用户分页数据获取
 /// </summary>
 /// <param name="userInfoByPageListReq">userInfoByPageListReq</param>
 /// <returns></returns>
 public async Task<IEnumerable<UserInfo>> GetUserInfoByPageList(UserInfoByPageListReq request)
 {
 //创建查询条件构造器
 FilterDefinitionBuilder<UserInfo> buildFilter = Builders<UserInfo>.Filter;
 FilterDefinition<UserInfo> filter = buildFilter.Empty;
 SortDefinition<UserInfo> sort = Builders<UserInfo>.Sort.Ascending(m => m.CreateDate);
 if (!string.IsNullOrEmpty(request.NickName))
 {
 filter = buildFilter.Eq(m => m.NickName, request.NickName);
 }

 if (!string.IsNullOrEmpty(request.Id))
 {
 filter = buildFilter.Eq(m => m.Id, request.Id);
 }

 var list = await _userRepository.FindListByPageAsync(filter, request.PageIndex, request.PageSize, Array.Empty<string>(), sort);
 return list;
 }

 /// <summary>
 /// 通过用户ID获取对应用户信息
 /// </summary>
 /// <param name="id">id</param>
 /// <returns></returns>
 public async Task<UserInfo> GetUserInfoById(string id)
 {
 var getUserInfo = await _userRepository.GetByIdAsync(id);
 return getUserInfo;
 }

 /// <summary>
 /// 添加用户信息
 /// </summary>
 /// <param name="userInfo">userInfo</param>
 /// <returns></returns>
 public async Task<UserInfo> AddUserInfo(UserInfoReq userInfo)
 {
 var addUserInfo = new UserInfo()
 {
 Id = ObjectId.GenerateNewId().ToString(),
 UserName = userInfo.UserName,
 Email = userInfo.Email,
 NickName = userInfo.NickName,
 Password = MD5Helper.MDString(userInfo.Password),
 Status = 1,
 HeadPortrait = userInfo.HeadPortrait,
 CreateDate = DateTime.Now,
 UpdateDate = DateTime.Now,
 };
 await _userRepository.AddAsync(addUserInfo);
 var queryUserInfo = await _userRepository.GetByIdAsync(addUserInfo.Id);
 return queryUserInfo;
 }

 /// <summary>
 /// 事务添加用户信息
 /// </summary>
 /// <param name="userInfo">userInfo</param>
 /// <returns></returns>
 public async Task<UserInfo> AddUserInfoTransactions(UserInfoReq userInfo)
 {
 using var session = await _unitOfWork.InitTransaction();
 var addUserInfo = new UserInfo()
 {
 Id = ObjectId.GenerateNewId().ToString(),
 UserName = userInfo.UserName,
 Email = userInfo.Email,
 NickName = userInfo.NickName,
 Password = MD5Helper.MDString(userInfo.Password),
 Status = 1,
 HeadPortrait = userInfo.HeadPortrait,
 CreateDate = DateTime.Now,
 UpdateDate = DateTime.Now,
 };
 await _userRepository.AddTransactionsAsync(session, addUserInfo);

 //查不到任何信息
 var queryUserInfo = await _userRepository.GetByIdAsync(addUserInfo.Id);

 //提交新增用户信息操作
 await _unitOfWork.Commit(session);

 //UserInfo只有在提交后才会被添加
 queryUserInfo = await _userRepository.GetByIdAsync(addUserInfo.Id);

 return queryUserInfo;
 }

 /// <summary>
 /// 用户信息修改
 /// </summary>
 /// <param name="id">id</param>
 /// <param name="userInfo">userInfo</param>
 /// <returns></returns>
 public async Task<UserInfo> UpdateUserInfo(string id, UserInfoReq userInfo)
 {
 #region 指定字段和条件修改

 //修改条件
 var list = new List<FilterDefinition<UserInfo>>
 {
 Builders<UserInfo>.Filter.Eq("_id", new ObjectId(id))
 };
 var filter = Builders<UserInfo>.Filter.And(list);

 //指定要修改的字段内容
 //参考文章：https://chsakell.gitbook.io/mongodb-csharp-docs/crud-basics/update-documents
 var updateDefinition = Builders<UserInfo>.Update.
 Set(u => u.HeadPortrait, userInfo.HeadPortrait).
 Set(u => u.NickName, userInfo.NickName).
 Set(u => u.Status, userInfo.Status);

 await _userRepository.UpdateAsync(filter, updateDefinition);

 #endregion

 #region 指定对象异步修改一条数据

 //var updateUserInfo = new UserInfo
 //{
 // UserName = userInfo.UserName,
 // Password = MD5Helper.MDString(userInfo.Password),
 // Status = 1,
 // HeadPortrait = userInfo.HeadPortrait,
 // Email = userInfo.Email,
 // NickName = userInfo.NickName,
 // UpdateDate = DateTime.Now,
 //};
 //await _userRepository.UpdateAsync(updateUserInfo, id);

 #endregion

 #region 数据批量修改示例

 ////1.批量修改的条件(把创建时间CreateDate为近五日的用户状态更改为0)
 //var time = DateTime.Now;
 //var list = new List<FilterDefinition<UserInfo>>();
 //list.Add(Builders<UserInfo>.Filter.Gt("CreateDate", time));//大于当前时间
 //list.Add(Builders<UserInfo>.Filter.Lt("CreateDate", time.AddDays(5)));//小于当前时间+5day
 //var filter = Builders<UserInfo>.Filter.And(list);

 ////2.要修改的字段内容
 //var dic = new Dictionary<string, string>
 //{
 // { "Status", "0" }
 //};

 ////3.批量修改
 //await _userRepository.UpdateManayAsync(dic, filter);

 #endregion

 return await _userRepository.GetByIdAsync(id);
 }

 /// <summary>
 /// 用户信息删除
 /// </summary>
 /// <param name="id"></param>
 /// <returns></returns>
 public async Task<bool> Delete(string id)
 {
 await _userRepository.DeleteAsync(id);
 var testUserInfo = await _userRepository.GetByIdAsync(id);
 return testUserInfo == null;
 }
}</pre>
</div>
<h2>UserOperationExample控制创建</h2>
<div class="cnblogs_code">
<pre> /// <summary>
/// MongoDB用户管理操作示例
/// </summary>


/")]
public class UserOperationExampleController : ControllerBase
{
 private readonly IUserOperationExampleServices _userOperationExampleServices;

 /// <summary>
 /// 依赖注入
 /// </summary>
 /// <param name="userOperationExampleServices">userOperationExampleServices</param>
 public UserOperationExampleController(IUserOperationExampleServices userOperationExampleServices)
 {
 _userOperationExampleServices = userOperationExampleServices;
 }

 /// <summary>
 /// 获取所有用户信息
 /// </summary>
 /// <returns></returns>

 public async Task<ActionResult<IEnumerable<UserInfo>>> GetAllUserInfos()
 {
 var userInfos = await _userOperationExampleServices.GetAllUserInfos();
 return Ok(userInfos);
 }

 /// <summary>
 /// 获取用户分页数据
 /// </summary>
 /// <param name="userInfoByPageListReq">userInfoByPageListReq</param>
 /// <returns></returns>

 public async Task<ActionResult<IEnumerable<UserInfo>>> GetUserInfoByPageList( UserInfoByPageListReq userInfoByPageListReq)
 {
 var getUserInfoByPageList = await _userOperationExampleServices.GetUserInfoByPageList(userInfoByPageListReq);
 return Ok(getUserInfoByPageList);
 }

 /// <summary>
 /// 通过用户ID获取对应用户信息
 /// </summary>
 /// <param name="id">id</param>
 /// <returns></returns>

 public async Task<ActionResult<UserInfo>> GetUserInfoById(string id)
 {
 var userInfo = await _userOperationExampleServices.GetUserInfoById(id);
 return Ok(userInfo);
 }

 /// <summary>
 /// 添加用户信息
 /// </summary>
 /// <param name="userInfo">userInfo</param>
 /// <returns></returns>

 public async Task<ActionResult<UserInfo>> AddUserInfo( UserInfoReq userInfo)
 {
 var addUserInfo = await _userOperationExampleServices.AddUserInfo(userInfo);
 return Ok(addUserInfo);
 }

 /// <summary>
 /// 事务添加用户信息
 /// </summary>
 /// <param name="userInfo">userInfo</param>
 /// <returns></returns>

 public async Task<ActionResult<UserInfo>> AddUserInfoTransactions( UserInfoReq userInfo)
 {
 //TODO:单机服务器不支持事务使用【使用MongoDB事务会报错：Standalone servers do not support transactions】,只有在集群情况下才能用
 var addUserInfo = await _userOperationExampleServices.AddUserInfoTransactions(userInfo);
 return Ok(addUserInfo);
 }

 /// <summary>
 /// 用户信息修改
 /// </summary>
 /// <param name="id">id</param>
 /// <param name="userInfo">userInfo</param>
 /// <returns></returns>

 public async Task<ActionResult<UserInfo>> UpdateUserInfo(string id, UserInfoReq userInfo)
 {
 var updateUserInfo = await _userOperationExampleServices.UpdateUserInfo(id, userInfo);
 return Ok(updateUserInfo);
 }

 /// <summary>
 /// 用户信息删除
 /// </summary>
 /// <param name="id">id</param>
 /// <returns></returns>

 public async Task<ActionResult> Delete(string id)
 {
 var deleteUser = await _userOperationExampleServices.Delete(id);
 return Ok(deleteUser);
 }
}</pre>
</div>
<h2>注册数据库基础操作和工作单元</h2>
<div class="cnblogs_code">
<pre>//注册数据库基础操作和工作单元
builder.Services.AddSingleton<IMongoConnection, MongoConnection>();
builder.Services.AddScoped<IMongoContext, MongoContext>();
builder.Services.AddScoped<IUnitOfWork, UnitOfWork>();
builder.Services.AddScoped<IUserRepository, UserRepository>();</pre>
</div>
<h2>注册相关应用服务</h2>
<div class="cnblogs_code">
<pre>builder.Services.AddScoped<IUserOperationExampleServices, UserOperationExampleServices>();</pre>
</div>
<h2>Swagger用户管理操作示例展示</h2>
<h3>添加用户信息</h3>
<img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408120434744-1491332643.png" alt="" loading="lazy">
 添加成功，返回添加成功的用户信息：
<img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408120512409-1982768734.png" alt="" loading="lazy">
<h3>通过用户ID获取对应用户信息</h3>
拿刚才添加成功的用户ID，查询用户信息：
<img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408120726974-1583274111.png" alt="" loading="lazy">
<h3>获取所有用户信息</h3>
<img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408120902608-731171977.png" alt="" loading="lazy">
<h3>用户分页数据获取</h3>
查询第1页，显示10条数据：
<img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408121533855-194645817.png" alt="" loading="lazy">
<img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408121554091-1666337051.png" alt="" loading="lazy">
查询第1页，显示2条数据：
<img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408121126893-1440857254.png" alt="" loading="lazy">
 <img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408121312356-545452564.png" alt="" loading="lazy">
<h3> 用户信息修改</h3>
指定要修改的字段内容，修改HeadPortrait、NickName、Status 参考文章：https://chsakell.gitbook.io/mongodb-csharp-docs/crud-basics/update-documents
 <img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408122109316-2104963625.png" alt="" loading="lazy">
 修改成功：
<img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408122144945-1298530128.png" alt="" loading="lazy">
<h3>用户信息删除</h3>
输入需要删除的用户ID，点击Execute删除：
<img src="https://img2023.cnblogs.com/blog/1336199/202304/1336199-20230408122346136-1247492688.png" alt="" loading="lazy">
 

</div>
<div id="MySignature" role="contentinfo">
<blockquote >
作者名称：追逐时光者
作者简介：一个热爱编程、善于分享、喜欢学习、探索、尝试新事物和新技术的全栈软件工程师。

本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文链接，否则保留追究法律责任的权利。如果该篇文章对您有帮助的话，可以点一下右下角的【&hearts;推荐&hearts;】，希望能够持续的为大家带来好的技术文章，文中可能存在描述不正确的地方，欢迎指正或补充，不胜感激。

</blockquote> 
来源：https://www.cnblogs.com/Can-daydayup/p/17294749.html

頁: [1]

琼殿技术论坛's Archiver

.NET Core MongoDB数据仓储和工作单元模式实操