系列文章
- 基于 abp vNext 和 .NET Core 開發博客專案 - 使用 abp cli 搭建專案
- 基于 abp vNext 和 .NET Core 開發博客專案 - 給專案瘦身，讓它跑起來
- 基于 abp vNext 和 .NET Core 開發博客專案 - 完善與美化，Swagger登場
- 基于 abp vNext 和 .NET Core 開發博客專案 - 資料訪問和代碼優先
- 基于 abp vNext 和 .NET Core 開發博客專案 - 自定義倉儲之增刪改查
- 基于 abp vNext 和 .NET Core 開發博客專案 - 統一規范API，包裝回傳模型
- 基于 abp vNext 和 .NET Core 開發博客專案 - 再說Swagger，分組、描述、小綠鎖
- 基于 abp vNext 和 .NET Core 開發博客專案 - 接入GitHub，用JWT保護你的API
- 基于 abp vNext 和 .NET Core 開發博客專案 - 例外處理和日志記錄
- 基于 abp vNext 和 .NET Core 開發博客專案 - 使用Redis快取資料
- 基于 abp vNext 和 .NET Core 開發博客專案 - 集成Hangfire實作定時任務處理
- 基于 abp vNext 和 .NET Core 開發博客專案 - 用AutoMapper搞定物件映射
- 基于 abp vNext 和 .NET Core 開發博客專案 - 定時任務最佳實戰（一）
- 基于 abp vNext 和 .NET Core 開發博客專案 - 定時任務最佳實戰（二）
- 基于 abp vNext 和 .NET Core 開發博客專案 - 定時任務最佳實戰（三）
- 基于 abp vNext 和 .NET Core 開發博客專案 - 博客介面實戰篇（一）
- 基于 abp vNext 和 .NET Core 開發博客專案 - 博客介面實戰篇（二）
- 基于 abp vNext 和 .NET Core 開發博客專案 - 博客介面實戰篇（三）
- 基于 abp vNext 和 .NET Core 開發博客專案 - 博客介面實戰篇（四）
- 基于 abp vNext 和 .NET Core 開發博客專案 - 博客介面實戰篇（五）
- 基于 abp vNext 和 .NET Core 開發博客專案 - Blazor 實戰系列（一）
- 基于 abp vNext 和 .NET Core 開發博客專案 - Blazor 實戰系列（二）
- 基于 abp vNext 和 .NET Core 開發博客專案 - Blazor 實戰系列（三）
- 基于 abp vNext 和 .NET Core 開發博客專案 - Blazor 實戰系列（四）
- 基于 abp vNext 和 .NET Core 開發博客專案 - Blazor 實戰系列（五）
- 基于 abp vNext 和 .NET Core 開發博客專案 - Blazor 實戰系列（六）
- 基于 abp vNext 和 .NET Core 開發博客專案 - Blazor 實戰系列（七）
- 基于 abp vNext 和 .NET Core 開發博客專案 - Blazor 實戰系列（八）
- 基于 abp vNext 和 .NET Core 開發博客專案 - Blazor 實戰系列（九）
- 基于 abp vNext 和 .NET Core 開發博客專案 - 終結篇之發布專案
上一篇文章(https://www.cnblogs.com/meowv/p/12913676.html)我們用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領域層中創建倉儲介面，IPostRepository、ICategoryRepository、ITagRepository、IPostTagRepository、IFriendLinkRepository，這里直接全部繼承 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>
{
}
}
在ITagRepository和IPostTagRepository倉儲介面中，我們添加了批量插入的方法，相對于的在我們的.EntityFrameworkCore層實作這些介面，
創建Repositories/Blog 檔案夾，添加實作類：PostRepository、CategoryRepository、TagRepository、PostTagRepository、FriendLinkRepository，
不知道大家發現沒有，我們的倉儲介面以及實作，都是以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)
{
}
}
}
在TagRepository和PostTagRepository倉儲介面的實作中，因為資料量不大，可以直接用了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
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/27032.html
標籤：.NET Core