EFCore通用数据操作类

news/2024/5/19 23:43:34 标签: c#, 数据库, .netcore, asp.net, 开发语言
public class ServiceBase : IServiceBase
{

    protected DbContext Context { get; private set; } // 这个DbContext指向的是当前的Context
    public ServiceBase(IEFContext eFContext)
    {
        Context = eFContext.CreateDBContext();
    }

    public void Commit()
    {
        this.Context.SaveChanges(); // 直接保存就行了
    }

    public void Delete<T>(int Id) where T : class
    {
        T t = this.Find<T>(Id);
        if (t == null) throw new Exception("t is null");    // 如果是空就报错
        this.Context.Set<T>().Remove(t);    // 删除这个
        this.Commit();  // 删完提交
    }

    public void Delete<T>(T t) where T : class
    {
        if (t == null) throw new Exception("t is null");    // 如果是空就报错
        this.Context.Set<T>().Attach(t);    // 尊卑删除这个实体
        this.Context.Set<T>().Remove(t);    // 删除这个
        this.Commit();  // 删完提交
    }

    public void Delete<T>(IEnumerable<T> tList) where T : class
    {
        // 将要删除的实体标记上
        foreach (var t in tList)
        {
            this.Context.Set<T>().Attach(t);    // 要删除这个实体
        }
        this.Context.Set<T>().RemoveRange(tList);    // 删除这个集合
        this.Commit();  // 删完提交
    }

    public T Find<T>(int id) where T : class
    {
        return this.Context.Set<T>().Find(id);
    }

    public T Insert<T>(T t) where T : class
    {
        this.Context.Set<T>().Add(t);   // 添加
        this.Commit();  // 提交
        return t;
    }

    public IEnumerable<T> Insert<T>(IEnumerable<T> tList) where T : class
    {
        this.Context.Set<T>().AddRange(tList);
        this.Commit();  //
        return tList;
    }

    public IQueryable<T> Query<T>(Expression<Func<T, bool>> funcWhere) where T : class
    {
        return this.Context.Set<T>().Where<T>(funcWhere);
    }

    public void Update<T>(T t) where T : class
    {
        if (t == null) throw new Exception("t is null");

        this.Context.Set<T>().Attach(t);    // 跟踪实体
        this.Context.Entry<T>(t).State = EntityState.Modified;  // 标记为已修改
        this.Commit();
    }

    public void Update<T>(IEnumerable<T> tList) where T : class
    {
        // 跟踪和标记更改
        foreach (var t in tList)
        {
            this.Context.Set<T>().Attach(t);
            this.Context.Entry<T>(t).State = EntityState.Modified;
        }
        this.Commit();
    }

    public virtual void Dispose()
    {
        if (this.Context != null)
            this.Context.Dispose();
    }
}

接口:

public interface IServiceBase
{
    #region Query
    /// <summary>
    /// 根据id查询实体
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    T Find<T>(int id) where T : class;


    /// <summary>
    /// 查询
    /// </summary>
    /// <typeparam name="T"></typeparam>
    /// <param name="funcWhere"></param>
    /// <returns></returns>
    IQueryable<T> Query<T>(Expression<Func<T, bool>> funcWhere) where T : class;

    #endregion

    #region Add
    /// <summary>
    /// 新增数据,即时Commit
    /// </summary>
    /// <param name="t"></param>
    /// <returns>返回带主键的实体</returns>
    T Insert<T>(T t) where T : class;

    /// <summary>
    /// 新增数据,即时Commit
    /// 多条sql 一个连接,事务插入
    /// </summary>
    /// <param name="tList"></param>
    IEnumerable<T> Insert<T>(IEnumerable<T> tList) where T : class;
    #endregion

    #region Update
    /// <summary>
    /// 更新数据,即时Commit
    /// </summary>
    /// <param name="t"></param>
    void Update<T>(T t) where T : class;

    /// <summary>
    /// 更新数据,即时Commit
    /// </summary>
    /// <param name="tList"></param>
    void Update<T>(IEnumerable<T> tList) where T : class;
    #endregion

    #region Delete
    /// <summary>
    /// 根据主键删除数据,即时Commit
    /// </summary>
    /// <param name="t"></param>
    void Delete<T>(int Id) where T : class;

    /// <su+mary>
    /// 删除数据,即时Commit
    /// </summary>
    /// <param name="t"></param>
    void Delete<T>(T t) where T : class;

    /// <summary>
    /// 删除数据,即时Commit
    /// </summary>
    /// <param name="tList"></param>
    void Delete<T>(IEnumerable<T> tList) where T : class;
    #endregion

    #region Other
    /// <summary>
    /// 立即保存全部修改
    /// 把增/删的savechange给放到这里,是为了保证事务的
    /// </summary>
    void Commit();

    #endregion
}


http://www.niftyadmin.cn/n/5478226.html

相关文章

SpirngBoot开发常用知识

springboot开发常用知识 命令行打包SpringBoot打包插件window端口命令临时属性设置热部署启动热部署热部署范围 常用计量单位数据校验加载测试的专用属性Web环境模拟测试如何发送虚拟请求业务层测试回滚随机产生测试用例内置数据源 命令行打包 对SpringBoot项目进行打包命令行…

动态规划刷题(算法竞赛、蓝桥杯)--区间DP

1、题目链接&#xff1a;[NOI1995] 石子合并 - 洛谷 #include <bits/stdc.h> using namespace std; const int N210; int n,a[N],s[N]; int f[N][N];//存最小值 int g[N][N];//存最大值 int main(){memset(f,0x3f,sizeof f);//求最小初始化为无穷大 memset(g,-0x3f,size…

基于用户的协同过滤算法实现商品推荐

文章目录 简介基于协同过滤算法&#xff08;UserCF&#xff09;原理&#xff08;我的理解&#xff09;皮尔逊相关系数计算 总结 简介 最近在做关于健康商城的项目&#xff0c;在首页需要向用户展示食品推荐&#xff0c;要求采用协同过滤的方式展示推荐的食品&#xff0c;第一次…

【javaWeb】EL与JSTL

目录 EL表达式&#xff08;Expression Language&#xff09;EL和JSP脚本的区别语法EL操作符EL运算符注意 EL功能EL访问作用域隐式对象示例1&#xff1a;获得应用上下文示例2&#xff1a;获取Cookie对象 JSTL(JavaServerPages Standard Tag Library)JSTL使用步骤JSTL标签分类使用…

【OTA】升级机制介绍

一、升级流程 1、读取本地配置文件 作用&#xff1a;获取当前版本号、文件状态、项目名称等信息。 2、网络初始化 作用&#xff1a;尝试使设备联网&#xff0c;扫描环境wifi信息&#xff0c;连接特定的用于OTA的wifi。 3、拉取服务器端配置文件 作用&#xff1a;获取服务…

大话设计模式——17.状态模式(State Pattern)

简介 对象的行为依赖于它的状态&#xff08;属性&#xff09;&#xff0c;可以根据状态的改变而改变相关行为。 UML图&#xff1a; 应用场景&#xff1a; 对象的行为取决于其状态&#xff0c;并且必须要在运行时刻根据状态而改变行为代码中包含大量与对象状态有关的条件语句 …

OceanBase 中一个关于 NOT IN 子查询的 SQL 优化案例

通过一个案例了解 not in 对 NULL 值敏感的处理逻辑和优化方法。 作者&#xff1a;胡呈清&#xff0c;爱可生 DBA 团队成员&#xff0c;擅长故障分析、性能优化&#xff0c;个人博客&#xff1a;[简书 | 轻松的鱼]&#xff0c;欢迎讨论。 爱可生开源社区出品&#xff0c;原创内…

<Halcon> 获取多边形拐点

获取多边形拐点 关键算子 * 多边形拟合XLD轮廓 gen_polygons_xld(Contours : Polygons : Type, Alpha : )* 获取多边形数据 * Row&#xff1a;多边形点的行坐标 * Col&#xff1a;多边形点的列坐标 * Length&#xff1a;点i和点i1之间的线段长度 * Phi&#xff1a;点i和点i1之…