EFCore通用数据操作类

发布于:2024-04-09 ⋅ 阅读:(109) ⋅ 点赞:(0)
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
}


网站公告

今日签到

点亮在社区的每一天
去签到