基於 abp vNext 和 .NET Core 開發博客項目 - 自定義倉儲之增刪改查

来源:https://www.cnblogs.com/meowv/archive/2020/05/20/12916613.html
-Advertisement-
Play Games

上一篇文章(https://www.cnblogs.com/meowv/p/12913676.html)我們用Code First的方式創建了博客所需的實體類,生成了資料庫表,完成了對EF Core的封裝。 本篇說一下自定義倉儲的實現方式,其實在abp框架中已經預設給我們實現了預設的通用(泛型)倉儲 ...


上一篇文章(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領域層中創建倉儲介面,IPostRepositoryICategoryRepositoryITagRepositoryIPostTagRepositoryIFriendLinkRepository,這裡直接全部繼承 IRepository<TEntity, TKey> 以使用已有的通用倉儲功能。

可以轉到IRepository<TEntity, TKey>介面定義看一下

1

看看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

2

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批量保存數據。

到這裡,關於博客的自定義倉儲便完成了,此時項目層級目錄圖,如下:

3

增刪改查

接下來在就可以在.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 ,已經出現我們的介面了。

4

隨手就試一下這個介面,能否成功創建文章。

5

可以看到資料庫已經躺著我們剛剛添加數據內容。

將剩下的三個介面一一實現,相信大家肯定都知道怎麼寫了。就不逐一嘮叨了,代碼如下:

...
        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文檔看看效果,並試試我們的介面是否好使吧,反正我試了是沒有問題的。

6

做到這一步的項目層級目錄如下:

7

本篇使用自定義倉儲的方式完成了對博客(meowv_posts)的增刪改查,你學會了嗎?

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 一、簡介 FluentScheduler是一個簡單的任務調度框架,定時任務管理器。 GitHub地址:https://github.com/fluentscheduler/FluentScheduler 二、示常式序 2.1、界面 新建一個WinForm程式FluentSchedulerClient ...
  • 一、簡單介紹 Quartz.NET是一個強大、開源、輕量的作業調度框架,是 OpenSymphony 的 Quartz API 的.NET移植,用C#改寫,可用於WinForm和ASP.NET應用中。它靈活而不複雜,可以為執行一個作業而創建簡單或複雜的作業調度。它有很多特征,如:資料庫支持、集群、插 ...
  • 0. 前言 今天是NHibernate的第二篇內容,通過上一篇的內容,我們初步瞭解了NHibernate的創建和使用。這一篇,我繼續探索NHibernate背後的秘密。嗯,就是這樣。 1. NHibernate結構 先給小伙伴們放個圖: 這是NHibernate的整體結構圖。NHibernate通過 ...
  • 隨著信息技術對人們工作生活的影響越來越大,人們對於應用程式的依賴性也越來越大,越來越多的人使用應用程式來解決自己工作和生活中的問題,這也導致應用程式的開發需求越來越高,傳統的應用程式開發方法已經沒有辦法滿足市場的需求,低代碼開發平臺在這樣的背景下誕生了。 力軟低代碼開發平臺可以減少開發成本,代碼、功 ...
  • C#手動建立Table後,並設置列和賦值 public DataTable CreateTable() { //創建Table1 DataTable dt = new DataTable(); //對Table1添加列名,並設置列值類型 DataTable dt1 = new DataTable() ...
  • C#中的關於Table的Merge() 簡介: Merge()方法可以實現對兩個table具有相同欄位的進行Morge,也可以實現對兩個table具有不同欄位的進行Merge。但是實現後的結果可能不太一樣。 一、對兩個table具有相同的欄位進行Merge的時候,所得到Merge後的table行數小 ...
  • 倉儲物流的過程中往往少不了一些使用熱敏印表機或者碳帶印表機列印一些條碼、信息貼在實物或者包裹上 最好的實現方式不過於直接使用熱敏代碼形成文本直接輸出到印表機做列印 但是熱敏代碼也是一門需要特殊的語言,需要學習 故為了更快更方便的實現,就用到了畫布繪製後形成image輸出到印表機 而image也是有要 ...
  • 關於讀取Excel模板對模板讀寫操作 1.根據文件名稱(帶盤符的文件目錄),建立SLDocument對象 SLDocument sldocument = new SLDocument(filename); sldocument.SelectWorksheet("Sheet1"); 2.讀取某一單元格 ...
一周排行
    -Advertisement-
    Play Games
  • Timer是什麼 Timer 是一種用於創建定期粒度行為的機制。 與標準的 .NET System.Threading.Timer 類相似,Orleans 的 Timer 允許在一段時間後執行特定的操作,或者在特定的時間間隔內重覆執行操作。 它在分散式系統中具有重要作用,特別是在處理需要周期性執行的 ...
  • 前言 相信很多做WPF開發的小伙伴都遇到過表格類的需求,雖然現有的Grid控制項也能實現,但是使用起來的體驗感並不好,比如要實現一個Excel中的表格效果,估計你能想到的第一個方法就是套Border控制項,用這種方法你需要控制每個Border的邊框,並且在一堆Bordr中找到Grid.Row,Grid. ...
  • .NET C#程式啟動閃退,目錄導致的問題 這是第2次踩這個坑了,很小的編程細節,容易忽略,所以寫個博客,分享給大家。 1.第一次坑:是windows 系統把程式運行成服務,找不到配置文件,原因是以服務運行它的工作目錄是在C:\Windows\System32 2.本次坑:WPF桌面程式通過註冊表設 ...
  • 在分散式系統中,數據的持久化是至關重要的一環。 Orleans 7 引入了強大的持久化功能,使得在分散式環境下管理數據變得更加輕鬆和可靠。 本文將介紹什麼是 Orleans 7 的持久化,如何設置它以及相應的代碼示例。 什麼是 Orleans 7 的持久化? Orleans 7 的持久化是指將 Or ...
  • 前言 .NET Feature Management 是一個用於管理應用程式功能的庫,它可以幫助開發人員在應用程式中輕鬆地添加、移除和管理功能。使用 Feature Management,開發人員可以根據不同用戶、環境或其他條件來動態地控制應用程式中的功能。這使得開發人員可以更靈活地管理應用程式的功 ...
  • 在 WPF 應用程式中,拖放操作是實現用戶交互的重要組成部分。通過拖放操作,用戶可以輕鬆地將數據從一個位置移動到另一個位置,或者將控制項從一個容器移動到另一個容器。然而,WPF 中預設的拖放操作可能並不是那麼好用。為瞭解決這個問題,我們可以自定義一個 Panel 來實現更簡單的拖拽操作。 自定義 Pa ...
  • 在實際使用中,由於涉及到不同編程語言之間互相調用,導致C++ 中的OpenCV與C#中的OpenCvSharp 圖像數據在不同編程語言之間難以有效傳遞。在本文中我們將結合OpenCvSharp源碼實現原理,探究兩種數據之間的通信方式。 ...
  • 一、前言 這是一篇搭建許可權管理系統的系列文章。 隨著網路的發展,信息安全對應任何企業來說都越發的重要,而本系列文章將和大家一起一步一步搭建一個全新的許可權管理系統。 說明:由於搭建一個全新的項目過於繁瑣,所有作者將挑選核心代碼和核心思路進行分享。 二、技術選擇 三、開始設計 1、自主搭建vue前端和. ...
  • Csharper中的表達式樹 這節課來瞭解一下表示式樹是什麼? 在C#中,表達式樹是一種數據結構,它可以表示一些代碼塊,如Lambda表達式或查詢表達式。表達式樹使你能夠查看和操作數據,就像你可以查看和操作代碼一樣。它們通常用於創建動態查詢和解析表達式。 一、認識表達式樹 為什麼要這樣說?它和委托有 ...
  • 在使用Django等框架來操作MySQL時,實際上底層還是通過Python來操作的,首先需要安裝一個驅動程式,在Python3中,驅動程式有多種選擇,比如有pymysql以及mysqlclient等。使用pip命令安裝mysqlclient失敗應如何解決? 安裝的python版本說明 機器同時安裝了 ...