【无私分享:ASP.NET CORE 项目实战(第五章)】Repository仓储 UnitofWork
2016-08-01 11:34
1101 查看
目录索引
【无私分享: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:namespace wkmvc.Core { /// <summary> /// Describe:工作单元接口 /// Author:yuangang /// Date:2016/07/16 /// Blogs:http://www.cnblogs.com/yuangang /// </summary> public interface IUnitOfWork { bool Commit(); } }
IUnitOfWork 实现类 UnitOfWork:
using System; using wkmvc.Data; namespace wkmvc.Core { /// <summary> /// Describe:工作单元实现类 /// Author:yuangang /// Date:2016/07/16 /// Blogs:http://www.cnblogs.com/yuangang /// </summary> public class UnitOfWork : IUnitOfWork, IDisposable { #region 数据上下文 /// <summary> /// 数据上下文 /// </summary> private ApplicationDbContext _Context; public UnitOfWork(ApplicationDbContext Context) { _Context = Context; } #endregion public bool Commit() { return _Context.SaveChanges() > 0; } public void Dispose() { if(_Context!=null) { _Context.Dispose(); } GC.SuppressFinalize(this); } } }
这样,UnitOfWork 就完成了。下面我们来添加仓储:
仓储 IRepository、Repository
新建接口 IRepository 添加基本的操作方法:using System; using System.Linq.Expressions; namespace wkmvc.Core { /// <summary> /// Describe:仓储接口 /// Author:yuangang /// Date:2016/07/16 /// Blogs:http://www.cnblogs.com/yuangang /// </summary> /// <typeparam name="T">实体模型</typeparam> public interface IRepository<T> where T : class { #region 单模型 CRUD 操作 /// <summary> /// 增加一条记录 /// </summary> /// <param name="entity">实体模型</param> /// <param name="IsCommit">是否提交(默认提交)</param> /// <returns></returns> bool Save(T entity, bool IsCommit = true); /// <summary> /// 更新一条记录 /// </summary> /// <param name="entity">实体模型</param> /// <param name="IsCommit">是否提交(默认提交)</param> /// <returns></returns> bool Update(T entity, bool IsCommit = true); /// <summary> /// 增加或更新一条记录 /// </summary> /// <param name="entity">实体模型</param> /// <param name="IsSave">是否增加</param> /// <param name="IsCommit">是否提交(默认提交)</param> /// <returns></returns> bool SaveOrUpdate(T entity, bool IsSave, bool IsCommit = true); /// <summary> /// 通过Lamda表达式获取实体 /// </summary> /// <param name="predicate">Lamda表达式(p=>p.Id==Id)</param> /// <returns></returns> T Get(Expression<Func<T, bool>> predicate); /// <summary> /// 删除一条记录 /// </summary> /// <param name="entity">实体模型</param> /// <param name="IsCommit">是否提交(默认提交)</param> /// <returns></returns> bool Delete(T entity, bool IsCommit = true); #endregion } }
实现类 Repository :
using Microsoft.EntityFrameworkCore; using System; using System.Linq; using System.Linq.Expressions; using wkmvc.Data; namespace wkmvc.Core { /// <summary> /// Describe:仓储实现类 /// Author:yuangang /// Date:2016/07/16 /// Blogs:http://www.cnblogs.com/yuangang /// </summary> /// <typeparam name="T">实体模型</typeparam> public abstract class Repository<T> : IRepository<T> where T : class { #region 数据上下文 /// <summary> /// 数据上下文 /// </summary> private ApplicationDbContext _Context; /// <summary> /// 工作单元 /// </summary> UnitOfWork _UnitOfWork; public Repository(ApplicationDbContext Context) { _Context = Context; _UnitOfWork = new UnitOfWork(_Context); } #endregion #region 单模型 CRUD 操作 /// <summary> /// 增加一条记录 /// </summary> /// <param name="entity">实体模型</param> /// <param name="IsCommit">是否提交(默认提交)</param> /// <returns></returns> public virtual bool Save(T entity,bool IsCommit=true) { _Context.Add(entity); if (IsCommit) return _UnitOfWork.Commit(); else return false; } /// <summary> /// 更新一条记录 /// </summary> /// <param name="entity">实体模型</param> /// <param name="IsCommit">是否提交(默认提交)</param> /// <returns></returns> public virtual bool Update(T entity, bool IsCommit = true) { _Context.Attach(entity); _Context.Entry(entity).State = EntityState.Modified; if (IsCommit) return _UnitOfWork.Commit(); else return false; } /// <summary> /// 增加或更新一条记录 /// </summary> /// <param name="entity">实体模型</param> /// <param name="IsSave">是否增加</param> /// <param name="IsCommit">是否提交(默认提交)</param> /// <returns></returns> public virtual bool SaveOrUpdate(T entity, bool IsSave, bool IsCommit = true) { return IsSave ? Save(entity, IsCommit) : Update(entity, IsCommit); } /// <summary> /// 通过Lamda表达式获取实体 /// </summary> /// <param name="predicate">Lamda表达式(p=>p.Id==Id)</param> /// <returns></returns> public virtual T Get(Expression<Func<T, bool>> predicate) { return _Context.Set<T>().AsNoTracking().SingleOrDefault(predicate); } /// <summary> /// 删除一条记录 /// </summary> /// <param name="entity">实体模型</param> /// <param name="IsCommit">是否提交(默认提交)</param> /// <returns></returns> public virtual bool Delete(T entity, bool IsCommit = true) { if (entity == null) return false; _Context.Remove(entity); if (IsCommit) return _UnitOfWork.Commit(); else return false; } #endregion } }
我们都添加了一个 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
相关文章推荐
- 【无私分享:ASP.NET CORE 项目实战(第五章)】Repository仓储 UnitofWork
- 【无私分享:ASP.NET CORE 项目实战(第五章)】Code First 创建数据库和数据表
- 【无私分享:ASP.NET CORE 项目实战(第三章)】EntityFramework下领域驱动设计的应用
- 【无私分享:ASP.NET CORE 项目实战(第十章)】发布项目到 Linux 上运行 Core 项目
- 【无私分享:ASP.NET CORE 项目实战(第七章)】文件操作 FileHelper
- 【无私分享:ASP.NET CORE 项目实战(第二章)】添加EF上下文对象,添加接口、实现类以及无处不在的依赖注入(DI)
- 【无私分享:ASP.NET CORE 项目实战(第六章)】读取配置文件(一) appsettings.json
- [转]【无私分享:ASP.NET CORE 项目实战(第九章)】创建区域Areas,添加TagHelper
- 【无私分享:ASP.NET CORE 项目实战(第四章)】Code First 创建数据库和数据表
- 【无私分享:ASP.NET CORE 项目实战(第二章)】添加EF上下文对象,添加接口、实现类以及无处不在的依赖注入(DI)
- 【无私分享:ASP.NET CORE 项目实战(第十章)】发布项目到 Linux 上运行 Core 项目
- 【无私分享:ASP.NET CORE 项目实战(第十一章)】Asp.net Core 缓存 MemoryCache 和 Redis
- 【无私分享:ASP.NET CORE 项目实战】EntityFramework下领域驱动设计的应用
- 【无私分享:ASP.NET CORE 项目实战(第九章)】创建区域Areas,添加TagHelper
- 【无私分享:ASP.NET CORE 项目实战(第六章)】读取配置文件(一) appsettings.json
- 【无私分享:ASP.NET CORE 项目实战(第十四章)】图形验证码的实现
- 【无私分享:ASP.NET CORE 项目实战(第九章)】创建区域Areas,添加TagHelper
- [转]【无私分享:ASP.NET CORE 项目实战(第十四章)】图形验证码的实现
- 【无私分享:ASP.NET CORE 项目实战(第八章)】读取配置文件(二) 读取自定义配置文件
- 【无私分享:ASP.NET CORE 项目实战(第七章)】文件操作 FileHelper