使用EFCore封装Service层CRUD代码

2024-06-21 18:04

本文主要是介绍使用EFCore封装Service层CRUD代码,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在使用asp.net core写后端接口的时候,经常会有很多相似的crud操作,甚至有的接口只需要一行代码就能实现,还要在service层里面定义方法,再来调用,显得很繁琐,因此可以利用c#里面的泛型对service层代码进行封装,写一些通用的crud操作,方便将来进行调用。

1、定义实体类的基类

public class BaseModel<Key>
{[Key]public Key Id { get; set; }}

这个类里面就包含一个主键属性,并且带了一个泛型Key,用来代表主键的类型,因为很多crud操作需要用到主键,因此需要这样定义,其他的实体类需要继承这个基类,比如User类

[Table("sys_user")]
[Comment("用户表")]
public class User:BaseModel<long>
{[Comment("用户名")]public string UserName { get; set; }[Comment("密码")]public string Password { get; set; }[Comment("邮箱")][EmailAddress]public string? Email { get; set; }public List<Role>? Roles { get; set; }internal void Deconstruct(out string userName, out string password){(userName, password) = (UserName, Password);}
}

2、定义service层通用接口

public interface IBaseService<T,Key,Context> where T:BaseModel<Key> where Context:DbContext
{Context GetContext();DbSet<T> GetDbSet();/// <summary>/// 查询表中所有数据,并返回一个数组/// </summary>/// <returns></returns>Task<T[]> GetAllToArrayAsync();/// <summary>/// 保存一条记录/// </summary>/// <param name="entity">需要保存的对象</param>/// <returns></returns>Task<int> SaveAsync(T entity);/// <summary>/// 通过主键更新数据/// </summary>/// <param name="entity">需要更新的对象数据</param>/// <returns></returns>Task<int> UpdateByIdAsync(T entity);/// <summary>/// 先检查数据是否存在,再通过主键更新数据/// </summary>/// <param name="entity">需要更新的对象数据</param>/// <param name="notFoundMessage">数据不存在的提示信息</param>/// <returns></returns>Task<int> UpdateByIdAsync(T entity, string notFoundMessage);/// <summary>/// 根据主键删除数据/// </summary>/// <param name="id">主键</param>/// <returns></returns>Task<int> DeleteByIdAsync(Key id);/// <summary>/// 先检查数据是否存在,再根据主键删除数据/// </summary>/// <param name="id">主键</param>/// <param name="notFoundMessage">数据不存在的提示信息</param>/// <returns></returns>Task<int> DeleteByIdAsync(Key id, string notFoundMessage);/// <summary>/// 根据主键批量删除数据/// </summary>/// <param name="ids">主键的数组或集合</param>/// <returns></returns>Task<int> DeleteByIdsAsync(IEnumerable<Key> ids);/// <summary>/// 先检查数据是否存在,再根据主键批量删除数据/// </summary>/// <param name="ids">主键的数组或集合</param>/// <param name="notFoundMessage">数据都不存在的提示信息</param>/// <returns></returns>Task<int> DeleteByIdsAsync(IEnumerable<Key> ids,string notFoundMessage);/// <summary>/// 执行事务操作/// </summary>/// <param name="execute">在事务中执行的代码</param>/// <returns></returns>Task ExecuteTransactionAsync(Func<Task> execute);
}

这个接口用到了三个泛型,T表示实体类的类型,必须是BaseModel的子类,Key表示主键类型,Context表示数据库上下文类型,并且定义了很多抽象方法,其中GetContext方法可以返回数据库上下文类型,这意味着可以在controller层通过调用这个方法获取数据库上下文对象,简单的查询只要一行代码就能实现,GetDbSet方法可以返回DbSet对象,其他方法可以根据自己的需要来定义。

3、定义service层通用实现类

public class BaseService<T,Key,Context> : IBaseService<T,Key,Context> where T :BaseModel<Key> where Context:DbContext
{protected readonly Context context;protected readonly DbSet<T> dbSet;public BaseService(Context context, DbSet<T> dbSet){this.context = context;this.dbSet = dbSet;}public Context GetContext(){return context;}public DbSet<T> GetDbSet(){return dbSet;}public Task<int> DeleteByIdAsync(Key id){return dbSet.Where(data => data.Id.Equals(id)).ExecuteDeleteAsync();}public async Task<int> DeleteByIdAsync(Key id, string notFoundMessage){var exist = await dbSet.AnyAsync(data => data.Equals(id));if (!exist){throw new AdminException(notFoundMessage);}return await dbSet.Where(data => data.Id.Equals(id)).ExecuteDeleteAsync();}public Task<int> DeleteByIdsAsync(IEnumerable<Key> ids){return dbSet.Where(data => ids.Contains(data.Id)).ExecuteDeleteAsync();}public async Task<int> DeleteByIdsAsync(IEnumerable<Key> ids, string notFoundMessage){var exist=await dbSet.AnyAsync(data => ids.Contains(data.Id));if (!exist){throw new AdminException(notFoundMessage);}return await dbSet.Where(data => ids.Contains(data.Id)).ExecuteDeleteAsync();}public Task<T[]> GetAllToArrayAsync(){return dbSet.ToArrayAsync();}public Task<int> SaveAsync(T entity){dbSet.Add(entity);return context.SaveChangesAsync();}public async Task<int> UpdateByIdAsync(T entity, string notFoundMessage){var exist = await dbSet.AnyAsync(data => data.Id.Equals(entity.Id));if (!exist){throw new AdminException(notFoundMessage);}dbSet.Update(entity);return await context.SaveChangesAsync();}public Task<int> UpdateByIdAsync(T entity){dbSet.Update(entity);return context.SaveChangesAsync();}public async Task ExecuteTransactionAsync(Func<Task> execute){using var transaction=context.Database.BeginTransaction();try{await execute();await transaction.CommitAsync();}catch (Exception ex){throw ex;transaction.RollbackAsync();}}
}

这个类继承了IBaseService接口,并实现了接口中的方法,其中context和dbSet属性需要通过构造方法传入进来。
下一步就是要继承这些类和接口,进行调用,以用户的crud操作为例

4、定义用户的service层接口

public interface IUserService:IBaseService<User,long,SystemDbContext>
{}

这个接口继承了IBaseService接口,传入了实体类型、主键类型、数据库上下文类型,这三个泛型。前面定义的通用方法可以通过这个接口继承下来,一些复杂的crud操作方法,就需要自己再去定义。

5、定义用户的service层实现类

public class UserService : BaseService<User,long,SystemDbContext>,IUserService
{public UserService(SystemDbContext context):base(context,context.Users){}
}

这个类型继承了BaseService类和IUserService接口,并且通过构造方法注入了数据库上下对象,并调用父类的构造方法,将context对象和Dbset对象传给BaseService类
当然,要为这个类注册服务

services.AddScoped<IUserService, UserService>();

6、在controller层接口调用通用的crud方法

[HttpDelete]
public Task<Result<object>> Delete(long[] ids)
{return ExecuteCatchAsync(() => userService.DeleteByIdsAsync(ids, "用户不存在"));
}

其中,DeleteByIdsAsync方法就是前面定义的通用crud方法,将来再写其他业务的接口,就不需要再去定义这个方法了。

这篇关于使用EFCore封装Service层CRUD代码的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1081935

相关文章

如何使用 Python 读取 Excel 数据

《如何使用Python读取Excel数据》:本文主要介绍使用Python读取Excel数据的详细教程,通过pandas和openpyxl,你可以轻松读取Excel文件,并进行各种数据处理操... 目录使用 python 读取 Excel 数据的详细教程1. 安装必要的依赖2. 读取 Excel 文件3. 读

利用Python调试串口的示例代码

《利用Python调试串口的示例代码》在嵌入式开发、物联网设备调试过程中,串口通信是最基础的调试手段本文将带你用Python+ttkbootstrap打造一款高颜值、多功能的串口调试助手,需要的可以了... 目录概述:为什么需要专业的串口调试工具项目架构设计1.1 技术栈选型1.2 关键类说明1.3 线程模

Python Transformers库(NLP处理库)案例代码讲解

《PythonTransformers库(NLP处理库)案例代码讲解》本文介绍transformers库的全面讲解,包含基础知识、高级用法、案例代码及学习路径,内容经过组织,适合不同阶段的学习者,对... 目录一、基础知识1. Transformers 库简介2. 安装与环境配置3. 快速上手示例二、核心模

解决Maven项目idea找不到本地仓库jar包问题以及使用mvn install:install-file

《解决Maven项目idea找不到本地仓库jar包问题以及使用mvninstall:install-file》:本文主要介绍解决Maven项目idea找不到本地仓库jar包问题以及使用mvnin... 目录Maven项目idea找不到本地仓库jar包以及使用mvn install:install-file基

Python使用getopt处理命令行参数示例解析(最佳实践)

《Python使用getopt处理命令行参数示例解析(最佳实践)》getopt模块是Python标准库中一个简单但强大的命令行参数处理工具,它特别适合那些需要快速实现基本命令行参数解析的场景,或者需要... 目录为什么需要处理命令行参数?getopt模块基础实际应用示例与其他参数处理方式的比较常见问http

C 语言中enum枚举的定义和使用小结

《C语言中enum枚举的定义和使用小结》在C语言里,enum(枚举)是一种用户自定义的数据类型,它能够让你创建一组具名的整数常量,下面我会从定义、使用、特性等方面详细介绍enum,感兴趣的朋友一起看... 目录1、引言2、基本定义3、定义枚举变量4、自定义枚举常量的值5、枚举与switch语句结合使用6、枚

Java的栈与队列实现代码解析

《Java的栈与队列实现代码解析》栈是常见的线性数据结构,栈的特点是以先进后出的形式,后进先出,先进后出,分为栈底和栈顶,栈应用于内存的分配,表达式求值,存储临时的数据和方法的调用等,本文给大家介绍J... 目录栈的概念(Stack)栈的实现代码队列(Queue)模拟实现队列(双链表实现)循环队列(循环数组

使用Python从PPT文档中提取图片和图片信息(如坐标、宽度和高度等)

《使用Python从PPT文档中提取图片和图片信息(如坐标、宽度和高度等)》PPT是一种高效的信息展示工具,广泛应用于教育、商务和设计等多个领域,PPT文档中常常包含丰富的图片内容,这些图片不仅提升了... 目录一、引言二、环境与工具三、python 提取PPT背景图片3.1 提取幻灯片背景图片3.2 提取

使用Python实现图像LBP特征提取的操作方法

《使用Python实现图像LBP特征提取的操作方法》LBP特征叫做局部二值模式,常用于纹理特征提取,并在纹理分类中具有较强的区分能力,本文给大家介绍了如何使用Python实现图像LBP特征提取的操作方... 目录一、LBP特征介绍二、LBP特征描述三、一些改进版本的LBP1.圆形LBP算子2.旋转不变的LB

Maven的使用和配置国内源的保姆级教程

《Maven的使用和配置国内源的保姆级教程》Maven是⼀个项目管理工具,基于POM(ProjectObjectModel,项目对象模型)的概念,Maven可以通过一小段描述信息来管理项目的构建,报告... 目录1. 什么是Maven?2.创建⼀个Maven项目3.Maven 核心功能4.使用Maven H