你的位置:首页 > ASP.net教程

[ASP.net教程]【无私分享:ASP.NET CORE 项目实战(第五章)】Repository仓储 UnitofWork


 

目录索引 

 

【无私分享:ASP.NET CORE 项目实战】目录索引

 

简介

 

  本章我们来创建仓储类Repository 并且引入 UnitOfWork

 

 

我对UnitOfWork的一些理解

 

   UnitOfWork 工作单元,对于这个的解释和实例,网上很多很多大神之作,我在这就不班门弄斧了,只是浅谈 一下个人理解,不一定对,希望大家指正:

  UnitOfWork 看了很多,个人理解就是 统一事务,在很多操作中我们可能是进行多项操作的,比如 同时保存两个表的数据,如果我们先保存一个表(SaveChanges()之后),再保存另一个表(SaveChanges())其实是两个不同的事务,通俗的讲,我们对数据库提交了两次数据。而UnitOfWork 就是 把本次操作(分别保存两张表)放在统一事务中,所有的CRUD完成后,统一提交数据,即保证数据的一致性,又减少了提交次数,提高性能。

  举个例子,我们之前的Repository的保存操作:

  Repository:

  public virtual bool Save(T entity)
  {
    _Context.Add(entity);
    return _Context.SaveChanges() > 0;
  }

 

  Controller: 

  public ActionResult Save()

  {

    var Users=new Users(){Id=1,UserName="张三"};

    var Logs=new Logs(){log="注册了用户张三"};

    _UserService.Save(Users);

    _LogService.Save(Logs);

  }

因为本身EF就是带事务的,但是_Context.SaveChanges()之后,事务就结束了,也提交了数据。所以,上面的例子 应该是开启了两次事务,提交了两次数据(一次是Users 一次是 Logs)

这显然是不合理的,首先不说提交两次数据性能的问题,如果用户注册失败,那么日志也不应该添加,应该回滚。但是,显然,上面没有这么做。

所以有了UnitOfWork。

使用UnitOfWork之后,代码应该是这样的:

 

  UnitOfWork:

  public bool Commit()
  {
    return _Context.SaveChanges() > 0; 
  }

 

  Repository:

  public virtual bool Save(T entity)
  {
    _Context.Add(entity);
  }

 

  Controller: 

  public ActionResult Save()

  {

    var Users=new Users(){Id=1,UserName="张三"};

    var Logs=new Logs(){log="注册了用户张三"};

    _UserService.Save(Users);

    _LogService.Save(Logs);

    _UnitOfWork.Commit();

  }

  

 

UnitOfWork接口和实现类

 我们在wkmvc.Core类库下,新建一个接口 IUnitOfWork:

 1 namespace wkmvc.Core 2 { 3   /// <summary> 4   /// Describe:工作单元接口 5   /// Author:yuangang 6   /// Date:2016/07/16 7   /// Blogs:http://www.cnblogs.com/yuangang 8   /// </summary> 9   public interface IUnitOfWork10   {11     bool Commit();12   }13 }

  

  IUnitOfWork 实现类 UnitOfWork:

 1 using System; 2 using wkmvc.Data; 3  4 namespace wkmvc.Core 5 { 6   /// <summary> 7   /// Describe:工作单元实现类 8   /// Author:yuangang 9   /// Date:2016/07/1610   /// Blogs:http://www.cnblogs.com/yuangang11   /// </summary>12   public class UnitOfWork : IUnitOfWork, IDisposable13   {14     #region 数据上下文15 16     /// <summary>17     /// 数据上下文18     /// </summary>19     private ApplicationDbContext _Context;20     public UnitOfWork(ApplicationDbContext Context)21     {22       _Context = Context;23     }24 25     #endregion26 27     public bool Commit()28     {29       return _Context.SaveChanges() > 0;30     }31 32     public void Dispose()33     {34       if(_Context!=null)35       {36         _Context.Dispose();37       }38       GC.SuppressFinalize(this);39     }40   }41 }

 

 

   这样,UnitOfWork 就完成了。下面我们来添加仓储:

 

仓储 IRepository、Repository

新建接口 IRepository 添加基本的操作方法:

 

 1 using System; 2 using System.Linq.Expressions; 3  4 namespace wkmvc.Core 5 { 6   /// <summary> 7   /// Describe:仓储接口 8   /// Author:yuangang 9   /// Date:2016/07/1610   /// Blogs:http://www.cnblogs.com/yuangang11   /// </summary>12   /// <typeparam name="T">实体模型</typeparam>13   public interface IRepository<T> where T : class14   {15     #region 单模型 CRUD 操作16 17     /// <summary>18     /// 增加一条记录19     /// </summary>20     /// <param name="entity">实体模型</param>21     /// <param name="IsCommit">是否提交(默认提交)</param>22     /// <returns></returns>23     bool Save(T entity, bool IsCommit = true);24 25     /// <summary>26     /// 更新一条记录27     /// </summary>28     /// <param name="entity">实体模型</param>29     /// <param name="IsCommit">是否提交(默认提交)</param>30     /// <returns></returns>31     bool Update(T entity, bool IsCommit = true);32 33     /// <summary>34     /// 增加或更新一条记录35     /// </summary>36     /// <param name="entity">实体模型</param>37     /// <param name="IsSave">是否增加</param>38     /// <param name="IsCommit">是否提交(默认提交)</param>39     /// <returns></returns>40     bool SaveOrUpdate(T entity, bool IsSave, bool IsCommit = true);41 42     /// <summary>43     /// 通过Lamda表达式获取实体44     /// </summary>45     /// <param name="predicate">Lamda表达式(p=>p.Id==Id)</param>46     /// <returns></returns>47     T Get(Expression<Func<T, bool>> predicate);48 49     /// <summary>50     /// 删除一条记录51     /// </summary>52     /// <param name="entity">实体模型</param>53     /// <param name="IsCommit">是否提交(默认提交)</param>54     /// <returns></returns>55     bool Delete(T entity, bool IsCommit = true);56 57     #endregion58   }59 }

 

 

   实现类 Repository :

 

 

 

 1 using Microsoft.EntityFrameworkCore; 2 using System; 3 using System.Linq; 4 using System.Linq.Expressions; 5 using wkmvc.Data; 6  7 namespace wkmvc.Core 8 { 9   /// <summary> 10   /// Describe:仓储实现类 11   /// Author:yuangang 12   /// Date:2016/07/16 13   /// Blogs:http://www.cnblogs.com/yuangang 14   /// </summary> 15   /// <typeparam name="T">实体模型</typeparam> 16   public abstract class Repository<T> : IRepository<T> where T : class 17   { 18     #region 数据上下文 19  20     /// <summary> 21     /// 数据上下文 22     /// </summary> 23     private ApplicationDbContext _Context; 24  25     /// <summary> 26     /// 工作单元 27     /// </summary> 28     UnitOfWork _UnitOfWork; 29  30     public Repository(ApplicationDbContext Context) 31     { 32       _Context = Context; 33       _UnitOfWork = new UnitOfWork(_Context); 34     } 35  36  37     #endregion 38  39     #region 单模型 CRUD 操作 40  41     /// <summary> 42     /// 增加一条记录 43     /// </summary> 44     /// <param name="entity">实体模型</param> 45     /// <param name="IsCommit">是否提交(默认提交)</param> 46     /// <returns></returns> 47     public virtual bool Save(T entity,bool IsCommit=true) 48     { 49       _Context.Add(entity); 50       if (IsCommit) 51         return _UnitOfWork.Commit(); 52       else 53         return false; 54     } 55  56     /// <summary> 57     /// 更新一条记录 58     /// </summary> 59     /// <param name="entity">实体模型</param> 60     /// <param name="IsCommit">是否提交(默认提交)</param> 61     /// <returns></returns> 62     public virtual bool Update(T entity, bool IsCommit = true) 63     { 64       _Context.Attach(entity); 65       _Context.Entry(entity).State = EntityState.Modified; 66       if (IsCommit) 67         return _UnitOfWork.Commit(); 68       else 69         return false; 70     } 71  72     /// <summary> 73     /// 增加或更新一条记录 74     /// </summary> 75     /// <param name="entity">实体模型</param> 76     /// <param name="IsSave">是否增加</param> 77     /// <param name="IsCommit">是否提交(默认提交)</param> 78     /// <returns></returns> 79     public virtual bool SaveOrUpdate(T entity, bool IsSave, bool IsCommit = true) 80     { 81       return IsSave ? Save(entity, IsCommit) : Update(entity, IsCommit); 82     } 83  84     /// <summary> 85     /// 通过Lamda表达式获取实体 86     /// </summary> 87     /// <param name="predicate">Lamda表达式(p=>p.Id==Id)</param> 88     /// <returns></returns> 89     public virtual T Get(Expression<Func<T, bool>> predicate) 90     { 91       return _Context.Set<T>().AsNoTracking().SingleOrDefault(predicate); 92     } 93  94  95     /// <summary> 96     /// 删除一条记录 97     /// </summary> 98     /// <param name="entity">实体模型</param> 99     /// <param name="IsCommit">是否提交(默认提交)</param>100     /// <returns></returns>101     public virtual bool Delete(T entity, bool IsCommit = true)102     {103       if (entity == null) return false;104       _Context.Remove(entity);105 106       if (IsCommit)107         return _UnitOfWork.Commit();108       else109         return false;110     }111 112     #endregion113 114 115   }116 }

 

我们都添加了一个  bool IsCommit = true 参数,是为了方便,如果仅仅是进行一项操作,那就没必要使用 UnitOfWork 统一 直接 SaveChanages() 就行了

 

 

 

我们来看下使用: 

  //第一种
  public bool TestOne()
  {
    var users = new SYS_USER() { UserName="张三",Account="zhangsan",Password="123456" };

    return _UserService.Save(users);
  }


  //第二种
  public bool TestTwo()
  {
    var users1 = new SYS_USER() { UserName = "张三", Account = "zhangsan", Password = "123456" };
    var users2 = new SYS_USER() { UserName = "李四", Account = "lisi", Password = "456789" };
    var users3 = new SYS_USER() { UserName = "王五", Account = "wangwu", Password = "321654" };

    _UserService.Save(users1);
    _UserService.Save(users2);
    _UserService.Save(users3);

    return _UnitOfWork.Commit();
  }

 

本篇主要是介绍用法,具体的解释清大家参考大神们的讲解,如有不对的地方希望指正。具体的实现代码,我们后面一起一点一点写。

 

 

 

 

希望跟大家一起学习Asp.net Core 

刚开始接触,水平有限,很多东西都是自己的理解和翻阅网上大神的资料,如果有不对的地方和不理解的地方,希望大家指正!

虽然Asp.net Core 现在很火热,但是网上的很多资料都是前篇一律的复制,所以有很多问题我也暂时没有解决,希望大家能共同帮助一下!

 

原创文章 转载请尊重劳动成果 http://yuangang.cnblogs.com