ASP.NET Core 2.2 WebApi 系列【六】泛型倉儲模式

来源:https://www.cnblogs.com/tenghao510/archive/2019/11/23/11918885.html
-Advertisement-
Play Games

為什麼要使用泛型倉儲？好處是？ 前兩章在autofac註入的時候，用的User類作為例子，寫了增刪改查四個介面，也就是倉儲的GRUD。 當我們再添加一個實體（比如Student）時，StudentRepository跟UserRepository代碼幾乎一樣的代碼，重覆量很大，為了減少冗餘、提高工作 ...


為什麼要使用泛型倉儲？好處是？

前兩章在autofac註入的時候，用的User類作為例子，寫了增刪改查四個介面，也就是倉儲的GRUD。

        當我們再添加一個實體（比如Student）時，StudentRepository跟UserRepository代碼幾乎一樣的代碼，重覆量很大，為了減少冗餘、提高工作效率，使用泛型倉儲最好不過了

好處：

減少代碼冗餘

提高了開發人員的工作效率

提高對資料庫訪問的維護

一、泛型倉儲介面和泛型倉儲實現類

泛型倉儲介面

在類庫項目上右鍵->添加->新建文件夾，命名為Repository，存放泛型倉儲類。在Repository文件夾下麵新建 泛型倉儲介面類：IRepository，如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using NetCoreWebApi.Repository.Dto;

namespace NetCoreWebApi.Repository.Repository
{
    public interface IRepository<T> where T : class
    {
        /// <summary>
        /// 添加實體(單個)
        /// </summary>
        /// <param name="entity">實體對象</param>
        int Add(T entity);

        /// <summary>
        /// 批量插入實體(多個)
        /// </summary>
        /// <param name="list">實體列表</param>
        int AddRange(List<T> list);

        /// <summary>
        /// 刪除實體(單個)
        /// </summary>
        /// <param name="entity"></param>
        int Remove(T entity);

        /// <summary>
        /// 批量刪除實體(多個)
        /// </summary>
        /// <param name="list">實體列表</param>
        int RemoveRange(List<T> list);
        /// <summary>
        /// 獲取所有 
        /// </summary>
        /// <returns></returns>
        IQueryable<T> GetAll();
        /// <summary>
        /// 分頁條件查詢
        /// </summary>
        /// <typeparam name="TKey">排序類型</typeparam>
        /// <param name="pageIndex">當前頁</param>
        /// <param name="pageSize">每頁大小</param>
        /// <param name="predicate">條件表達式</param>
        /// <param name="isAsc">是否升序排列</param>
        /// <param name="keySelector">排序表達式</param>
        /// <returns></returns>
        Page<T> SearchFor<TKey>(int pageIndex, int pageSize, Expression<Func<T, bool>> predicate,
            bool isAsc, Expression<Func<T, TKey>> keySelector);
        /// <summary>
        /// 獲取實體（主鍵）
        /// </summary>
        /// <param name="id">主鍵id</param>
        /// <returns></returns>
        T GetModelById(object id);
        /// <summary>
        /// 獲取實體（條件）
        /// </summary>
        /// <param name="predicate">條件表達式</param>
        /// <returns></returns>
        T GetModel(Expression<Func<T, bool>> predicate);
        /// <summary>
        /// 查詢記錄數
        /// </summary>
        /// <param name="predicate">條件表達式</param>
        /// <returns>記錄數</returns>
        int Count(Expression<Func<T, bool>> predicate);
        /// <summary>
        /// 是否存在
        /// </summary>
        /// <param name="anyLambda">查詢表達式</param>
        /// <returns>布爾值</returns>
        bool Exist(Expression<Func<T, bool>> anyLambda);
    }
}

泛型倉儲實現類

在Repository文件夾下麵新建 泛型倉儲實現類：Repository，並繼承IRepository，如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using Microsoft.EntityFrameworkCore;
using NetCoreWebApi.Model;
using NetCoreWebApi.Repository.Dto;

namespace NetCoreWebApi.Repository.Repository
{
    public class Repository<T> : IRepository<T> where T : class
    {
        private readonly MyDbContext _dbContext;
        private DbSet<T> _entity;

        /// <summary>
        /// 構造函數
        /// </summary>
        /// <param name="dbContext"></param>
        public Repository(MyDbContext dbContext)
        {
            _dbContext = dbContext;
        }
        private DbSet<T> Entity => _entity ?? (_entity = _dbContext.Set<T>());
        /// <summary>
        /// 添加實體(單個)
        /// </summary>
        /// <param name="entity">實體對象</param>
        public int Add(T entity)
        {
            Entity.Add(entity);
            return _dbContext.SaveChanges();
        }
        /// <summary>
        /// 批量插入實體(多個)
        /// </summary>
        /// <param name="list">實體列表</param>
        public int AddRange(List<T> list)
        {
            Entity.AddRange(list);
            return _dbContext.SaveChanges();
        }

        /// <summary>
        /// 刪除實體(單個)
        /// </summary>
        /// <param name="entity"></param>
        public int Remove(T entity)
        {
            Entity.Remove(entity);
            return _dbContext.SaveChanges();
        }
        /// <summary>
        /// 批量刪除實體(多個)
        /// </summary>
        /// <param name="list">實體列表</param>
        public int RemoveRange(List<T> list)
        {
            Entity.RemoveRange(list);
            return _dbContext.SaveChanges();
        }
        /// <summary>
        /// 獲取所有
        /// </summary>
        /// <returns></returns>
        public IQueryable<T> GetAll()
        {
            return Entity.AsQueryable().AsNoTracking();
        }
        /// <summary>
        /// 條件查詢
        /// </summary>
        /// <typeparam name="TKey">排序類型</typeparam>
        /// <param name="pageIndex">當前頁</param>
        /// <param name="pageSize">每頁大小</param>
        /// <param name="isAsc">是否升序排列</param>
        /// <param name="predicate">條件表達式</param>
        /// <param name="keySelector">排序表達式</param>
        /// <returns></returns>
        public Page<T> SearchFor<TKey>(int pageIndex, int pageSize, Expression<Func<T, bool>> predicate, bool isAsc,
            Expression<Func<T, TKey>> keySelector)
        {
            if (pageIndex <= 0 || pageSize <= 0) throw new Exception("pageIndex或pageSize不能小於等於0");
            var page = new Page<T> { PageIndex = pageIndex, PageSize = pageSize };
            var skip = (pageIndex - 1) * pageSize;
            var able = Entity.AsQueryable().AsNoTracking();
            if (predicate == null)
            {
                var count = Entity.Count();
                var query = isAsc
                    ? able.OrderBy(keySelector).Skip(skip).Take(pageSize)
                    : able.OrderByDescending(keySelector).Skip(skip).Take(pageSize);
                page.TotalRows = count;
                page.LsList = query.ToList();
                page.TotalPages = page.TotalRows / pageSize;
                if (page.TotalRows % pageSize != 0) page.TotalPages++;
            }
            else
            {
                var queryable = able.Where(predicate);
                var count = queryable.Count();
                var query = isAsc
                    ? queryable.OrderBy(keySelector).Skip(skip).Take(pageSize)
                    : queryable.OrderByDescending(keySelector).Skip(skip).Take(pageSize);
                page.TotalRows = count;
                page.LsList = query.ToList();
                page.TotalPages = page.TotalRows / pageSize;
                if (page.TotalRows % pageSize != 0) page.TotalPages++;
            }
            return page;
        }
        /// <summary>
        /// 獲取實體
        /// </summary>
        /// <param name="id">主鍵id</param>
        /// <returns></returns>
        public T GetModelById(object id)
        {
            return Entity.Find(id);
        }

        /// <summary>
        /// 獲取實體（條件）
        /// </summary>
        /// <param name="predicate">條件表達式</param>
        /// <returns></returns>
        public T GetModel(Expression<Func<T, bool>> predicate)
        {
            return Entity.FirstOrDefault(predicate);
        }
        /// <summary>
        /// 查詢記錄數
        /// </summary>
        /// <param name="predicate"></param>
        /// <returns></returns>
        public int Count(Expression<Func<T, bool>> predicate)
        {
            return predicate != null ? Entity.Where(predicate).Count() : Entity.Count();
        }
        /// <summary>
        /// 是否存在
        /// </summary>
        /// <param name="anyLambda"></param>
        /// <returns></returns>
        public bool Exist(Expression<Func<T, bool>> anyLambda)
        {
            return Entity.Any(anyLambda);
        }
    }
}

分頁Page類

using System.Collections.Generic;

namespace NetCoreWebApi.Repository.Dto
{
    public class Page<T>
    {
        /// <summary>
        /// 當前頁
        /// </summary>
        public int PageIndex { get; set; }
        /// <summary>
        /// 總頁數
        /// </summary>
        public int TotalPages { get; set; }
        /// <summary>
        /// 集合總數
        /// </summary>
        public int TotalRows { get; set; }
        /// <summary>
        /// 每頁項數
        /// </summary>
        public int PageSize { get; set; }
        /// <summary>
        /// 集合
        /// </summary>
        public IList<T> LsList { get; set; }
    }
}

二、倉儲的泛型的依賴註入。

修改Startup.cs啟動類中ConfigureServices方法

        public static IContainer ApplicationContainer { get; set; }
        /// <summary>
        /// //負責註入服務
        /// </summary>
        /// <param name="services"></param>
        /// <returns></returns>
        public IServiceProvider ConfigureServices(IServiceCollection services)
        {
            //獲取資料庫連接字元串
            var connectionStr = Configuration.GetConnectionString("SqlServer");
            services.AddDbContext<MyDbContext>
                (options => options.UseSqlServer(connectionStr,
                    e => e.MigrationsAssembly("NetCoreWebApi.Model")));
            services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
            //初始化容器
            var builder = new ContainerBuilder();
            //管道寄居
            builder.Populate(services);
            //註冊業務
            builder.RegisterAssemblyTypes(Assembly.Load("NetCoreWebApi.Repository"), Assembly.Load("NetCoreWebApi.Repository"))
                .Where(t => t.Name.EndsWith("Repository"))
                .AsImplementedInterfaces();
            //註冊倉儲，所有IRepository介面到Repository的映射
            builder.RegisterGeneric(typeof(Repository<>))
                //InstancePerDependency：預設模式，每次調用，都會重新實例化對象；每次請求都創建一個新的對象；
                .As(typeof(IRepository<>)).InstancePerDependency();
            //構造
            ApplicationContainer = builder.Build();
            //將AutoFac反饋到管道中
            return new AutofacServiceProvider(ApplicationContainer);
        }

 

 三、測試

修改業務層---UserRepository

給泛型類指定ThUser，紅色字體是主要更改部分。

using System.Collections.Generic;
using System.Linq;
using NetCoreWebApi.Model.Models;
using NetCoreWebApi.Repository.Interface;
using NetCoreWebApi.Repository.Repository;

namespace NetCoreWebApi.Repository.Implement
{
    /// <summary>
    /// 業務處理
    /// </summary>
    public class UserRepository:IUserRepository
    {
        private readonly IRepository<TbUser> _userRepository;

        /// <summary>
        /// 構造函數
        /// </summary>
        /// <param name="userRepository"></param>
        public UserRepository(IRepository<TbUser> userRepository)
        {
            _userRepository = userRepository;
        }
        /// <summary>
        /// 添加用戶
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public int Add(TbUser entity)
        {
            return _userRepository.Add(entity);
        }
        /// <summary>
        /// 刪除用戶
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public int Remove(TbUser entity)
        {
            return _userRepository.Remove(entity);
        }
        /// <summary>
        /// 查詢用戶
        /// </summary>
        /// <returns></returns>
        public IList<TbUser> GetAll()
        {
            return _userRepository.GetAll().ToList();
        }
    }
}

運行項目執行介面，可以看到跟之前一樣 

如果有其他實體只需要改變傳入的T就可以了，不需要再重新創建TEntityRepository


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

-Advertisement-
Play Games
更多相關文章
  • .NET開發者的機遇與Web Blazor基礎(有彩蛋)
    一.嘮嘮WebAssembly的發展歷程 目前有很多支持WebAssembly的項目，但發展最快的是Blazor，這是一個構建單頁面的.NET技術，目前已經從Preview版本升級到了beta版本，微軟計劃在2020年5月發佈Blazor的第一個版本。 Blazor是什麼？它是一項將C＃和.NET都 ...
  • WPF customize DelegateCommand
    using System; using System.Collections.Generic; using System.ComponentModel; using System.Linq; using System.Text; using System.Threading.Tasks; using... ...
  • .NET高級特性-Emit(1)
    在這個大數據/雲計算/人工智慧研發普及的時代，Python的崛起以及Javascript的前後端的侵略，程式員與企業似乎越來越青睞動態語言所帶來的便捷性與高效性，即使靜態語言在性能，錯誤檢查等方面的優於靜態語言。對於.NETer來說，.NET做為一門靜態語言，我們不僅要打好.NET的基本功，如基本類 ...
  • C# loop executed one by one wait the former completed
    using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; namespace ... ...
  • 從零開始搭建前後端分離的NetCore2.2（EF Core CodeFirst+Autofac）+Vue的項目框架之十二Swagger（參數）使用二
    引言 在 上一篇 中提到了 Swagger 的基本使用，僅限於沒有參數，沒有驗證的那種api文檔生成，那麼這篇就連接上篇繼續，在一般具有安全性、許可權等驗證的介面上， 都會在header/url中加上請求者的秘鑰、簽名等，當然也有可能添加到body等其它地方， Swashbuckle.AspNetCo ...
  • Microsoft Dynamics CRM 批量上傳web資源（非官方WebResourceUtility）並替換實體圖標
    背景： 去年以前可以按照目錄WebResourceUtility批量上傳web資源，昨天發現用不了了，拿到WebResourceUtility源碼改了一下都不是很方便，感覺官方寫的太冗餘，太長了，跟我喜歡的簡單粗暴思想不太符合，剛好無意閱覽了一個上傳資源的代碼，乾脆自己手寫一個根據目錄去上傳web資 ...
  • ASP.NET Core 2.2 WebApi 系列【七】泛型倉儲模式和工作單元
    在之前的泛型倉儲模式實現中，每個增刪改都調用了SaveChanges方法，導致每次更新都提交了事務。 在實際開發過程中，我們經常遇到同時操作多張表數據，那麼按照之前的寫法，對資料庫提交了多次操作，開啟了多事務，不能保證數據的一致性，結合工作單元（UnitOfWork）是為了把多次操作放到同一事務中， ...
  • 動手造輪子：實現簡單的 EventQueue
    最近項目里有遇到一些併發的問題，想實現一個隊列來將併發的請求一個一個串列處理，可以理解為使用消息隊列處理併發問題，之前實現過一個簡單的 `EventBus`，於是想在 `EventBus` 的基礎上改造一下，加一個隊列，改造成類似消息隊列的處理模式。消息的處理（Consumer）直接使用 .netc... ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類