【从零开始搭建自己的.NET Core Api框架】（六）泛型仓储的作用

时间：2018-08-18 21:12:48 阅读：663 评论：0 收藏：0 [点我收藏+]

标签：搭建类继承 3.2 soft 目录源码 closed 基础 model

系列目录

一. 创建项目并集成swagger

　　1.1 创建

　　1.2 完善

二. 搭建项目整体架构

三. 集成轻量级ORM框架——SqlSugar

　　3.1 搭建环境

　　3.2 实战篇：利用SqlSugar快速实现CRUD

　　3.3 生成实体类

四. 集成JWT授权验证

五. 实现CORS跨域

六. 集成泛型仓储

源码下载：https://github.com/WangRui321/RayPI_V2.0

1. 根

之前在集成SqlSugar的时候，我们用Student类作为例子，写了5个基础的接口：获取集合、获取单个、添加、修改、删除，也就是常说的仓储的CRUD了。

技术分享图片

Service层的代码是这样的：

技术分享图片

而且我们规定，以后每个实体类都必须有这个5个基础接口。

所以，当我们再添加一个实体（比如Teacher）时，在TeacherService中也要写和StudentService几乎一样的代码（其实就是把代码里所有“Student”换成“Teacher”就行了）。

这么多重复代码，显然是不符合程序员的审美的。这个时候使用泛型仓储就再适合不过了。

2. 道

整体思路是，写一个基类“BaseService”，这个基类是一个抽象的泛型类，然后让每个实体的Service都继承它。

那么当再新建一个Service时，不需要写任何代码，就已经实现了我们需要的那5种基础CRUD了。

2.1 IService层

在IService层新建一个IBase接口：

技术分享图片

using RayPI.Model;

namespace RayPI.IService
{
    public interface IBase<T> where T:class,new()
    {
        /// <summary>
        /// 获取分页列表
        /// </summary>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <returns></returns>
        TableModel<T> GetPageList(int pageIndex, int pageSize);
        /// <summary>
        /// 获取单个
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        T Get(long id);
        /// <summary>
        /// 添加
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        bool Add(T entity);
        /// <summary>
        /// 编辑
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        bool Update(T entity);
        /// <summary>
        /// 批量删除
        /// </summary>
        /// <param name="ids"></param>
        /// <returns></returns>
        bool Dels(dynamic[] ids);
    }
}

IBase

该接口是个泛型接口，里面集成了对泛型T的5中基础CRUD操作。

2.2 Service层

在Service层新建一个BaseService类：

技术分享图片

using RayPI.Model;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;

namespace RayPI.Service
{
    /// <summary>
    /// 服务层基类
    /// </summary>
    /// <typeparam name="T"></typeparam>
    public abstract class BaseService<T> where T:class,new()
    {
        public BaseService()
        {
            db = GetClient();
            sdb = db.GetSimpleClient();
        }
        public SqlSugarClient db;
        public SimpleClient sdb;
        /// <summary>
        /// 获取客户端
        /// </summary>
        /// <returns></returns>
        private SqlSugarClient GetClient()
        {
            SqlSugarClient db = new SqlSugarClient(
                new ConnectionConfig()
                {
                    ConnectionString = BaseDBConfig.ConnectionString,
                    DbType = DbType.SqlServer,
                    IsAutoCloseConnection = true
                }
            );
            db.Aop.OnLogExecuting = (sql, pars) =>
            {
                Console.WriteLine(sql + "\r\n" + db.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value)));
                Console.WriteLine();
            };
            return db;
        }

        #region CRUD
        public TableModel<T> GetPageList(int pageIndex, int pageSize)
        {
            PageModel p = new PageModel() { PageIndex = pageIndex, PageSize = pageSize };
            Expression<Func<T, bool>> ex = (it => 1 == 1);
            List<T> data = sdb.GetPageList(ex, p);
            var t = new TableModel<T>
            {
                Code = 0,
                Count = p.PageCount,
                Data = data,
                Msg = "成功"
            };
            return t;
        }

        public T Get(long id)
        {
            return sdb.GetById<T>(id);
        }

        public bool Add(T entity)
        {
            return sdb.Insert(entity);
        }

        public bool Update(T entity)
        {
            return sdb.Update(entity);
        }

        public bool Dels(dynamic[] ids)
        {
            return sdb.DeleteByIds<T>(ids);
        }
        #endregion
    }
}