基于 abp vNext 和 .NET Core 开发博客项目 - 自定义仓储之增删改查

上一篇文章我们用Code-First的方式创建了博客所需的实体类,生成了数据库表,完成了对EF Core的封装。

本篇说一下自定义仓储的实现方式,其实在abp框架中已经默认给我们实现了默认的通用(泛型)仓储,IRepository<TEntity, TKey>,有着标准的CRUD操作,可以看:https://docs.abp.io/zh-Hans/abp/latest/Repositories 学习更多。

之所以实现自定义仓储,是因为abp没有给我们实现批量插入、更新的方法,这个是需要自己去扩展的。

既然是自定义仓储,那么就有了很高的自由度,我们可以任意发挥,可以接入第三方批量处理数据的库,可以接入Dapper操作等等,在这里贴一下微软官方推荐的一些EF Core的工具和扩展:https://docs.microsoft.com/zh-cn/ef/core/extensions/ 。

自定义仓储

.Domain领域层中创建仓储接口,IPostRepositoryICategoryRepositoryITagRepositoryIPostTagRepositoryIFriendLinkRepository,这里直接全部继承 IRepository<TEntity, TKey> 以使用已有的通用仓储功能。

可以转到IRepository<TEntity, TKey>接口定义看一下

看看abp对于仓储的介绍,如下:

IRepository<TEntity, TKey> 接口扩展了标准 IQueryable<TEntity> 你可以使用标准LINQ方法自由查询。但是,某些ORM提供程序或数据库系统可能不支持IQueryable接口。

ABP提供了 IBasicRepository<TEntity, TPrimaryKey> 和 IBasicRepository<TEntity> 接口来支持这样的场景。

你可以扩展这些接口(并可选择性地从BasicRepositoryBase派生)为你的实体创建自定义存储库。

依赖于 IBasicRepository 而不是依赖 IRepository 有一个优点, 即使它们不支持 IQueryable 也可以使用所有的数据源, 但主要的供应商, 像 Entity Framework, NHibernate 或 MongoDb 已经支持了 IQueryable

因此, 使用 IRepository 是典型应用程序的 建议方法。但是可重用的模块开发人员可能会考虑使用 IBasicRepository 来支持广泛的数据源。

对于想要使用只读仓储提供了IReadOnlyRepository<TEntity, TKey> 与 IReadOnlyBasicRepository<Tentity, TKey>接口。

仓储接口类如下:

//IPostRepository.cs
using Volo.Abp.Domain.Repositories;namespace Meowv.Blog.Domain.Blog.Repositories
{/// <summary>/// IPostRepository/// </summary>public interface IPostRepository : IRepository<Post, int>{}
}
//ICategoryRepository.cs
using Volo.Abp.Domain.Repositories;namespace Meowv.Blog.Domain.Blog.Repositories
{/// <summary>/// ICategoryRepository/// </summary>public interface ICategoryRepository : IRepository<Category, int>{}
}
//ITagRepository.cs
using System.Collections.Generic;
using System.Threading.Tasks;
using Volo.Abp.Domain.Repositories;namespace Meowv.Blog.Domain.Blog.Repositories
{/// <summary>/// ITagRepository/// </summary>public interface ITagRepository : IRepository<Tag, int>{/// <summary>/// 批量插入/// </summary>/// <param name="tags"></param>/// <returns></returns>Task BulkInsertAsync(IEnumerable<Tag> tags);}
}
//IPostTagRepository.cs
using System.Collections.Generic;
using System.Threading.Tasks;
using Volo.Abp.Domain.Repositories;namespace Meowv.Blog.Domain.Blog.Repositories
{/// <summary>/// IPostTagRepository/// </summary>public interface IPostTagRepository : IRepository<PostTag, int>{/// <summary>/// 批量插入/// </summary>/// <param name="postTags"></param>/// <returns></returns>Task BulkInsertAsync(IEnumerable<PostTag> postTags);}
}
//IFriendLinkRepository.cs
using Volo.Abp.Domain.Repositories;namespace Meowv.Blog.Domain.Blog.Repositories
{/// <summary>/// IFriendLinkRepository/// </summary>public interface IFriendLinkRepository : IRepository<FriendLink, int>{}
}

ITagRepositoryIPostTagRepository仓储接口中,我们添加了批量插入的方法。相对于的在我们的.EntityFrameworkCore层实现这些接口。

创建Repositories/Blog 文件夹,添加实现类:PostRepositoryCategoryRepositoryTagRepositoryPostTagRepositoryFriendLinkRepository

不知道大家发现没有,我们的仓储接口以及实现,都是以Repository结尾的,这和我们的.Application应用服务层都以Service结尾是一个道理。

在自定义仓储的实现中,我们可以使用任意你想使用的数据访问工具,我们这里还是继续用Entity Framework Core,需要继承EfCoreRepository<TDbContext, TEntity, TKey>,和我们的仓储接口IXxxRepository

EfCoreRepository默认实现了许多默认的方法,然后就可以直接使用 DbContext 来执行操作了。

仓储接口实现类如下:

//PostRepository.cs
using Meowv.Blog.Domain.Blog;
using Meowv.Blog.Domain.Blog.Repositories;
using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
using Volo.Abp.EntityFrameworkCore;namespace Meowv.Blog.EntityFrameworkCore.Repositories.Blog
{/// <summary>/// PostRepository/// </summary>public class PostRepository : EfCoreRepository<MeowvBlogDbContext, Post, int>, IPostRepository{public PostRepository(IDbContextProvider<MeowvBlogDbContext> dbContextProvider) : base(dbContextProvider){}}
}
//CategoryRepository.cs
using Meowv.Blog.Domain.Blog;
using Meowv.Blog.Domain.Blog.Repositories;
using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
using Volo.Abp.EntityFrameworkCore;
namespace Meowv.Blog.EntityFrameworkCore.Repositories.Blog
{/// <summary>/// CategoryRepository/// </summary>public class CategoryRepository : EfCoreRepository<MeowvBlogDbContext, Category, int>, ICategoryRepository{public CategoryRepository(IDbContextProvider<MeowvBlogDbContext> dbContextProvider) : base(dbContextProvider){}}
}
//TagRepository.cs
using Meowv.Blog.Domain.Blog;
using Meowv.Blog.Domain.Blog.Repositories;
using System.Collections.Generic;
using System.Threading.Tasks;
using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
using Volo.Abp.EntityFrameworkCore;namespace Meowv.Blog.EntityFrameworkCore.Repositories.Blog
{/// <summary>/// TagRepository/// </summary>public class TagRepository : EfCoreRepository<MeowvBlogDbContext, Tag, int>, ITagRepository{public TagRepository(IDbContextProvider<MeowvBlogDbContext> dbContextProvider) : base(dbContextProvider){}/// <summary>/// 批量插入/// </summary>/// <param name="tags"></param>/// <returns></returns>public async Task BulkInsertAsync(IEnumerable<Tag> tags){await DbContext.Set<Tag>().AddRangeAsync(tags);await DbContext.SaveChangesAsync();}}
}
//PostTagRepository.cs
using Meowv.Blog.Domain.Blog;
using Meowv.Blog.Domain.Blog.Repositories;
using System.Collections.Generic;
using System.Threading.Tasks;
using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
using Volo.Abp.EntityFrameworkCore;namespace Meowv.Blog.EntityFrameworkCore.Repositories.Blog
{/// <summary>/// PostTagRepository/// </summary>public class PostTagRepository : EfCoreRepository<MeowvBlogDbContext, PostTag, int>, IPostTagRepository{public PostTagRepository(IDbContextProvider<MeowvBlogDbContext> dbContextProvider) : base(dbContextProvider){}/// <summary>/// 批量插入/// </summary>/// <param name="postTags"></param>/// <returns></returns>public async Task BulkInsertAsync(IEnumerable<PostTag> postTags){await DbContext.Set<PostTag>().AddRangeAsync(postTags);await DbContext.SaveChangesAsync();}}
}
//FriendLinkRepository.cs
using Meowv.Blog.Domain.Blog;
using Meowv.Blog.Domain.Blog.Repositories;
using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
using Volo.Abp.EntityFrameworkCore;namespace Meowv.Blog.EntityFrameworkCore.Repositories.Blog
{/// <summary>/// PostTagRepository/// </summary>public class FriendLinkRepository : EfCoreRepository<MeowvBlogDbContext, FriendLink, int>, IFriendLinkRepository{public FriendLinkRepository(IDbContextProvider<MeowvBlogDbContext> dbContextProvider) : base(dbContextProvider){}}
}

TagRepositoryPostTagRepository仓储接口的实现中,因为数据量不大,可以直接用了EF Core自带的AddRangeAsync批量保存数据。

到这里,关于博客的自定义仓储便完成了,此时项目层级目录图,如下:

增删改查

接下来在就可以在.Application服务层愉快的玩耍了,写服务之前,我们要分析我们的项目,要有哪些功能业务。由于是博客项目,无非就是一些增删改查。今天先不写博客业务,先完成对数据库文章表meowv_posts的一个简单CRUD。

.Application层新建Blog文件夹,添加一个IBlogService.cs博客接口服务类,分别添加增删改查四个方法。

这时就要用到我们的数据传输对象(DTO)了,简单理解,DTO就是从我们的领域模型中抽离出来的对象,它是很纯粹的只包含我们拿到的数据,不参杂任何行为逻辑。

.Application.Contracts层新建Blog文件夹,同时新建一个PostDto.cs类,与.Domain层中的Post.cs与之对应,他们很相似,但是不一样。

于是IBlogService.cs接口服务类的CRUD为:

//IBlogService.cs
using Meowv.Blog.Application.Contracts.Blog;
using System.Threading.Tasks;namespace Meowv.Blog.Application.Blog
{public interface IBlogService{Task<bool> InsertPostAsync(PostDto dto);Task<bool> DeletePostAsync(int id);Task<bool> UpdatePostAsync(int id, PostDto dto);Task<PostDto> GetPostAsync(int id);}
}

接口写好了,少不了实现方式,直接在Blog文件夹新建Impl文件夹,用来存放我们的接口实现类BlogService.cs,注意:都是以Service结尾的噢~

实现服务接口除了要继承我们的IBlogService外,不要忘了还需依赖我们的ServiceBase类。由于我们之前直接接入了Autofac,可以直接使用构造函数依赖注入的方式。

//BlogService.cs
using Meowv.Blog.Application.Contracts.Blog;
using Meowv.Blog.Domain.Blog.Repositories;
using System;
using System.Threading.Tasks;namespace Meowv.Blog.Application.Blog.Impl
{public class BlogService : ServiceBase, IBlogService{private readonly IPostRepository _postRepository;public BlogService(IPostRepository postRepository){_postRepository = postRepository;}...}
}

现在就可以实现我们写的IBlogService接口了。

先写添加,这里实现方式全采用异步的方法,先构建一个Post实体对象,具体内容参数都从PostDto中获取,由于主键之前设置了自增,这里就不用管它了。然后调用 await _postRepository.InsertAsync(entity);,正好它返回了一个创建成功的Post对象,那么我们就可以判断对象是否为空,从而确定文章是否添加成功。

代码如下:

...public async Task<bool> InsertPostAsync(PostDto dto){var entity = new Post{Title = dto.Title,Author = dto.Author,Url = dto.Url,Html = dto.Html,Markdown = dto.Markdown,CategoryId = dto.CategoryId,CreationTime = dto.CreationTime};var post = await _postRepository.InsertAsync(entity);return post != null;}
...

然后在.HttpApi层和之前添加HelloWorldController一样,添加BlogController。调用写的InsertPostAsync方法,如下:

//BlogController.cs
using Meowv.Blog.Application.Blog;
using Meowv.Blog.Application.Contracts.Blog;
using Microsoft.AspNetCore.Mvc;
using System.Threading.Tasks;
using Volo.Abp.AspNetCore.Mvc;namespace Meowv.Blog.HttpApi.Controllers
{[ApiController][Route("[controller]")]public class BlogController : AbpController{private readonly IBlogService _blogService;public BlogController(IBlogService blogService){_blogService = blogService;}/// <summary>/// 添加博客/// </summary>/// <param name="dto"></param>/// <returns></returns>[HttpPost]public async Task<bool> InsertPostAsync([FromBody] PostDto dto){return await _blogService.InsertPostAsync(dto);}}
}

添加博客操作,我们将其设置为[HttpPost]方式来提交,因为现在开发接口api,都要遵循RESTful方式,所以就不用给他指定路由了,[FromBody]的意思是在请求正文中以JSON的方式来提交参数。

完成上述操作,打开我们的Swagger文档看看, .../swagger/index.html ,已经出现我们的接口了。

随手就试一下这个接口,能否成功创建文章。

可以看到数据库已经躺着我们刚刚添加数据内容。

将剩下的三个接口一一实现,相信大家肯定都知道怎么写了。就不逐一唠叨了,代码如下:

...public async Task<bool> DeletePostAsync(int id){await _postRepository.DeleteAsync(id);return true;}public async Task<bool> UpdatePostAsync(int id, PostDto dto){var post = await _postRepository.GetAsync(id);post.Title = dto.Title;post.Author = dto.Author;post.Url = dto.Url;post.Html = dto.Html;post.Markdown = dto.Markdown;post.CategoryId = dto.CategoryId;post.CreationTime = dto.CreationTime;await _postRepository.UpdateAsync(post);return true;}public async Task<PostDto> GetPostAsync(int id){var post = await _postRepository.GetAsync(id);return new PostDto{Title = post.Title,Author = post.Author,Url = post.Url,Html = post.Html,Markdown = post.Markdown,CategoryId = post.CategoryId,CreationTime = post.CreationTime};}
...

在这里先暂时不做参数校验,咱们默认都是正常操作,如果执行操作成功,直接返回true。大家会发现,当我们使用了DTO后,写了大量对象的转换,在这里暂不做优化,将在后续业务开始后使用AutoMapper处理对象映射。如果大家感兴趣可以自己先试一下。

在Controller中调用,代码如下:

.../// <summary>/// 删除博客/// </summary>/// <param name="id"></param>/// <returns></returns>[HttpDelete]public async Task<bool> DeletePostAsync([Required] int id){return await _blogService.DeletePostAsync(id);}/// <summary>/// 更新博客/// </summary>/// <param name="id"></param>/// <param name="dto"></param>/// <returns></returns>[HttpPut]public async Task<bool> UpdatePostAsync([Required] int id, [FromBody] PostDto dto){return await _blogService.UpdatePostAsync(id, dto);}/// <summary>/// 查询博客/// </summary>/// <param name="id"></param>/// <returns></returns>[HttpGet]public async Task<PostDto> GetPostAsync([Required] int id){return await _blogService.GetPostAsync(id);}
...

DeletePostAsync:指定了请求方式[HttpDelete],参数id为必填项

UpdatePostAsync:指定了请求方式[HttpPut],参数id为必填项并且为url的一部分,要更新的具体内容和添加博客的方法InsertPostAsync的一样的

GetPostAsync:指定了请求方式[HttpGet],参数id为必填项

ok,打开Swagger文档看看效果,并试试我们的接口是否好使吧,反正我试了是没有问题的。

做到这一步的项目层级目录如下:

本篇使用自定义仓储的方式完成了对博客(meowv_posts)的增删改查,你学会了吗?????????????

开源地址:https://github.com/Meowv/Blog/tree/blog_tutorial

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

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

相关文章

计算机操作系统第四章作业

计算机操作系统第四章作业 1.何为静态链接&#xff1f;静态链接时需要解决两个什么问题? 答&#xff1a;静态链接是指在程序运行之前&#xff0c;先将各自目标模块及它们所需的库函数&#xff0c;链接成一个完整的装入模块&#xff0c;以后不再拆开的链接方式。   将几个目…

走进WebApiClientCore的设计

WebApiClientWebApiClient是NCC开源社区的一个项目&#xff0c;是目前微服务里http接口调用的一把锋利尖刀&#xff0c;项目早期设计与开发的时候&#xff0c;是基于.netframework的&#xff0c;然后慢慢加入netstandard和netcoreapp多个框架的支持&#xff0c;设计能力出众&am…

Blazor WebAssembly 3.2 正式发布

5月 20日&#xff0c;微软 发布了 Blazor WebAssembly 3.2(https://devblogs.microsoft.com/aspnet/blazor-webassembly-3-2-0-now-available/) 。Blazor 是 ASP.NET Core 中的一个新框架&#xff0c;支持使用 C#和 HTML 创建交互式 Web 应用程序。Blazor WebAssembly 使用基于…

温故知新:Docker基础知识知多少?

【云原生】| 作者/Edison Zhou这是恰童鞋骚年的第233篇原创文章记得之前曾经粗略的写过一篇Docker的基础及ASP.NET Core部署Docker示例的入门文章&#xff0c;但那个时候刚刚学习对Docker的认知还比较浅&#xff0c;现在重新来温故知新一下。本文预计阅读时间为10min。1容器的用…

[C++11]lambda表达式语法

代码如下: #include <iostream> using namespace std;void func(int x, int y) {int a;int b;[]() {int c a;//使用了外部变量&#xff0c;[]里面加个 int d x;}; }int main() {return 0; }lambda表达式的注意事项: 以上图片来自下面链接: https://subingwen.cn/cpp…

[翻译]欢迎使用C#9.0

本文由公众号[开发者精选资讯](微信号&#xff1a;yuantoutiao)翻译首发&#xff0c;转载请注明来源C# 9.0 is taking shape, and I’d like to share our thinking on some of the major features we’re adding to this next version of the language.C&#xff03;9.0初具规…

操作系统第四章习题

操作系统第四章习题 1.对一个将页表放在内存中的分页系统&#xff1a; (1) 如果访问内存需要0.2μs&#xff0c;有效访问时间为多少? (2) 如果加一快表&#xff0c;且假定在快表中找到页表的几率高达90%&#xff0c;则有效访问时间又是多少&#xff08;假定查快表需花的时间…

[C++11]右值和右值引用

代码如下: #include <iostream> using namespace std;int main() {//左值int num 9;//左值引用int &a num;//右值const int N 5;//右值引用int && b 8;//常量左值引用const int &c num;//常量右值引用const int &&d 6;//const int &&…

我们为什么推荐在Json中使用string表示Number属性值

在这篇简短的文章中&#xff0c;我将解释在使用JSON传输数据时&#xff0c;为什么浮点数或大十进制值应表示为字符串 。long类型引发的诡异情况长话短说&#xff0c;同事在利用swagger对接后端API时&#xff0c;诡异的发现swaggerUI中显示的json属性值并不是api返回的值。[Http…

并查集+基础知识点详解

并查集概念 并查集单看名字大家也能猜到这个算法的作用&#xff0c;是用来对集合进行合并和查找操作 并查集是一种树型的数据结构&#xff0c;用于处理一些不相交集合(Disjoint Sets)的合并及查询问题。——来自百度百科 就是将原本不一样的集合&#xff0c;但是由于某种关系有…

[C++11]move资源的转移

从实现上讲&#xff0c;std::move 基本等同于一个类型转换&#xff1a;static_cast<T&&>(lvalue);&#xff0c;函数原型如下: template<class _Ty> _NODISCARD constexpr remove_reference_t<_Ty>&& move(_Ty&& _Arg) _NOEXCEPT { …

基于 abp vNext 和 .NET Core 开发博客项目 - 统一规范API,包装返回模型

上一篇文章使用自定义仓储完成了简单的增删改查案例&#xff0c;有心的同学可以看出&#xff0c;我们的返回参数一塌糊涂&#xff0c;显得很不友好。在实际开发过程中&#xff0c;每个公司可能不尽相同&#xff0c;但都大同小异&#xff0c;我们的返回数据都是包裹在一个公共的…

奔小康赚大钱 HDU - 2255( 二分图匹配KM算法详解)

题目 传说在遥远的地方有一个非常富裕的村落,有一天,村长决定进行制度改革&#xff1a;重新分配房子。 这可是一件大事,关系到人民的住房问题啊。村里共有n间房间,刚好有n家老百姓,考虑到每家都要有房住&#xff08;如果有老百姓没房子住的话&#xff0c;容易引起不安定因素&…

记一次排查线上程序内存的忽高忽低,又是大集合惹祸了

一&#xff1a;背景1. 讲故事昨天继续还技术债&#xff0c;优化一轮后的程序拉到线上后内存继续忽高忽低&#xff0c;低的时候20G&#xff0c;高的时候30G&#xff0c;过了一会又下降了几个G&#xff0c;毫无疑问&#xff0c;程序中有什么集合或者什么操作占用了大量内存&#…

[C++11]forward完美转发

// 函数原型 template <class T> T&& forward (typename remove_reference<T>::type& t) noexcept; template <class T> T&& forward (typename remove_reference<T>::type&& t) noexcept;// 精简之后的样子 std::forward…

Pipe HDU - 2150(判断线段相交+向量叉乘线代详解)

题目&#xff1a; 经过激烈的争夺&#xff0c;Lele终于把那块地从Yueyue的手里抢了回来。接下来&#xff0c;Lele要开始建造他的灌溉系统。 通过咨询Lele的好友——化学系的TT&#xff0c;Lele决定在田里挖出N条沟渠&#xff0c;每条沟渠输送一种肥料。 每条沟渠可以看作是一…

win7如何将计算机移至桌面,如何将win7电脑桌面的文件转移到其他盘中?

想必很多朋友都和小编一样&#xff0c;是一个嫌麻烦的人&#xff0c;是一个不怎么爱收拾的人吧?这种人有一个通病&#xff0c;那就是喜欢将一些重要的文件放置在win7 64位纯净版下载的桌面上&#xff0c;这样的话&#xff0c;不仅容易找到&#xff0c;而且方便使用&#xff0c…

凸包算法知识总结

首先&#xff0c;什么是凸包&#xff1f; 假设平面上有p0~p12共13个点&#xff0c;过某些点作一个多边形&#xff0c;使这个多边形能把所有点都“包”起来。当这个多边形是凸多边形的时候&#xff0c;我们就叫它“凸包”。 处理何种问题&#xff1a;凸包可以看成在木板上钉许多…

[C++11]shared_ptr使用的注意事项(内存被重复析构,内存泄漏问题)

shared_ptr使用的注意事项: 1.不能使用一个原始地址初始化多个共享智能指针 2.函数不能返回管理了this的共享智能指针对象 3.共享智能指针不能循环引用 不能使用一个原始地址初始化多个共享智能指针 代码如下: #include <iostream> #include <memory> using name…