基于 abp vnext 和 .net core 开发博客项目 -凯发k8官方网

基于 abp vnext 和 .net core 开发博客项目 - 自定义仓储之增删改查

转载于：https://github.com/meowv/blog

本篇说一下自定义仓储的实现方式，其实在abp框架中已经默认给我们实现了默认的通用(泛型)仓储，irepository，有着标准的crud操作，可以看：https://docs.abp.io/zh-hans/abp/latest/repositories 学习更多。

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

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

自定义仓储

在.domain领域层中创建仓储接口，ipostrepository、icategoryrepository、itagrepository、iposttagrepository、ifriendlinkrepository，这里直接全部继承 irepository 以使用已有的通用仓储功能。

可以转到irepository接口定义看一下

图片

看看abp对于仓储的介绍，如下：

irepository 接口扩展了标准 iqueryable 你可以使用标准linq方法自由查询。但是，某些orm提供程序或数据库系统可能不支持iqueryable接口。

abp提供了 ibasicrepository 和 ibasicrepository 接口来支持这样的场景。

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

依赖于 ibasicrepository 而不是依赖 irepository 有一个优点, 即使它们不支持 iqueryable 也可以使用所有的数据源, 但主要的供应商, 像 entity framework, nhibernate 或 mongodb 已经支持了 iqueryable。

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

对于想要使用只读仓储提供了ireadonlyrepository 与 ireadonlybasicrepository接口。

仓储接口类如下：

//ipostrepository.cs
using volo.abp.domain.repositories;

namespace meowv.blog.domain.blog.repositories
{
///
/// ipostrepository
///
public interface ipostrepository : irepository
{
}
}
//icategoryrepository.cs
using volo.abp.domain.repositories;

namespace meowv.blog.domain.blog.repositories
{
///
/// icategoryrepository
///
public interface icategoryrepository : irepository
{
}
}
//itagrepository.cs
using system.collections.generic;
using system.threading.tasks;
using volo.abp.domain.repositories;

namespace meowv.blog.domain.blog.repositories
{
///
/// itagrepository
///
public interface itagrepository : irepository
{
///
/// 批量插入
///
///
///
task bulkinsertasync(ienumerable tags);
}
}
//iposttagrepository.cs
using system.collections.generic;
using system.threading.tasks;
using volo.abp.domain.repositories;

namespace meowv.blog.domain.blog.repositories
{
///
/// iposttagrepository
///
public interface iposttagrepository : irepository
{
///
/// 批量插入
///
///
///
task bulkinsertasync(ienumerable posttags);
}
}
//ifriendlinkrepository.cs
using volo.abp.domain.repositories;

namespace meowv.blog.domain.blog.repositories
{
///
/// ifriendlinkrepository
///
public interface ifriendlinkrepository : irepository
{
}
}

在itagrepository和iposttagrepository仓储接口中，我们添加了批量插入的方法。相对于的在我们的.entityframeworkcore层实现这些接口。

创建repositories/blog 文件夹，添加实现类：postrepository、categoryrepository、tagrepository、posttagrepository、friendlinkrepository。

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

在自定义仓储的实现中，我们可以使用任意你想使用的数据访问工具，我们这里还是继续用entity framework core，需要继承efcorerepository，和我们的仓储接口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
{
///
/// postrepository
///
public class postrepository : efcorerepository, ipostrepository
{
public postrepository(idbcontextprovider 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
{
///
/// categoryrepository
///
public class categoryrepository : efcorerepository, icategoryrepository
{
public categoryrepository(idbcontextprovider 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
{
///
/// tagrepository
///
public class tagrepository : efcorerepository, itagrepository
{
public tagrepository(idbcontextprovider dbcontextprovider) : base(dbcontextprovider)
{
}