抽象一个数据库访问层的统一入口(类似于EF的上下文,拿到上下文,就可以拿到所有的表).实际这个入口就是一个类,类里面有所有的仓储对应的属性.这样,只要拿到这个类的实例,就可以点出所有的仓储,我们在 Repository层里面添加一个类 DbSession.cs
namespace YouJiao.MvcWeb.Repository { /// <summary> /// 相当于是简单工厂:通过DbSession可以拿到所有的仓储的实例,所以我们也可以将此DbSession看做是简单工厂. /// 职责:对整个数据库访问层做了高度抽象,它是整个数据库访问层的统一入口,BLL层来调用Repository层的时候 /// 只要拿到DbSession就可以拿到所有的仓储,就可以对所有的表进行增删改查了 /// </summary> public class DbSession : IDbSession { public ObjectContext db = new ModelContainer(); //EF上下文 我们先直接new 后面再来修改成线程内唯一 private IUserInfoRepository _userInfoRepository; public IUserInfoRepository UserInfoRepository { get { if (_userInfoRepository == null) { _userInfoRepository = new UserInfoRepository(); } return _userInfoRepository; } set { _userInfoRepository = value; } } private IProductRepository _productRepository; public IProductRepository ProductRepository { get { if (_productRepository == null) { _productRepository = new ProductRepository(); } return _productRepository; } set { _productRepository = value; } } //执行sql脚本 public int ExecuteSql(string sql, ObjectParameter[] parameters) { return db.ExecuteFunction(sql, parameters); } //单元工作模式 public int SaveChanges() { return db.SaveChanges(); } } }
然后我们抽象出一个接口,在 IRepository里面增加一个 IDbSession.cs
namespace YouJiao.MvcWeb.IRepository { public interface IDbSession { IUserInfoRepository UserInfoRepository { get; set; } IProductRepository ProductRepository { get; set; } int ExecuteSql(string sql, ObjectParameter[] parameters); /// <summary> /// 将整个数据库访问层的所有修改都一次性的提交回数据库 /// 业务逻辑层:一个业务场景,肯定会对多个表做修改,对多个表进行处理 /// 此方法的存在:极大的提高数据库访问层批量提交sql的性能,提高数据库的吞吐量,减少跟数据库的交互次数 /// </summary> /// <returns></returns> int SaveChanges(); //UnitWork模式 } }
这样结构就变成了下图所示
然后我们再来修改一下 EF上下文的实例,在BaseRepository和DbSession里面都有用到 上下文,我们要保证这个上下文在线程内是唯一的
我们在 Repository层,创建一个EF的简单工厂 实际也就是一个类(DbEfContextFactory),里面一个静态方法(GetCurrentDbEfContext)
namespace YouJiao.MvcWeb.Repository { public class DbEfContextFactory { public static ObjectContext GetCurrentDbEfContext() { //CallContext：是线程内部唯一的独用的数据槽（一块内存空间） //传递dbcontext进去获取实例的信息，在这里进行强制转换。 ObjectContext context = (ObjectContext) CallContext.GetData("dbcontext"); if (context == null) //如果线程在数据槽里面没有此上下文 { context=new ModelContainer(); //那么我们自己就new一个 CallContext.SetData("dbcontext",context); //放到数据槽中 } return context; } } }
现在我们来修改一下刚才 DbSession.cs 和 BaseRepository.cs
namespace YouJiao.MvcWeb.Repository { /// <summary> /// 相当于是简单工厂:通过DbSession可以拿到所有的仓储的实例,所以我们也可以将此DbSession看做是简单工厂. /// 职责:对整个数据库访问层做了高度抽象,它是整个数据库访问层的统一入口,BLL层来调用Repository层的时候 /// 只要拿到DbSession就可以拿到所有的仓储,就可以对所有的表进行增删改查了 /// </summary> public class DbSession : IDbSession { public ObjectContext db { get { return DbEfContextFactory.GetCurrentDbEfContext();//EF上下文线程内唯一 } } private IUserInfoRepository _userInfoRepository; public IUserInfoRepository UserInfoRepository { get { if (_userInfoRepository == null) { _userInfoRepository = new UserInfoRepository(); } return _userInfoRepository; } set{_userInfoRepository = value;} } private IProductRepository _productRepository; public IProductRepository ProductRepository { get { if (_productRepository == null) { _productRepository = new ProductRepository(); } return _productRepository; } set { _productRepository = value; } } //执行sql脚本 public int ExecuteSql(string sql, ObjectParameter[] parameters) { return db.ExecuteFunction(sql, parameters); } //单元工作模式 public int SaveChanges() { return db.SaveChanges(); } } }
namespace YouJiao.MvcWeb.Repository { public class BaseRepository<T> where T : class // 这里约束泛型T必须是个类 { private ObjectContext db { get { return DbEfContextFactory.GetCurrentDbEfContext();//获取EF上下文的实例 } } public IList<T> LoadEneities(Func<T, bool> whereLambda) { return db.CreateObjectSet<T>().Where(whereLambda).ToList(); } public IList<T> LoadPageEneities<S>(int pageSize, int pageIndex, out int total, Func<T, bool> whereLambda, Func<T, S> orderbyLambda, bool isAsc) { var tempList = db.CreateObjectSet<T>().Where(whereLambda).ToList(); total = tempList.Count; if (isAsc) //如果是升序 { tempList = tempList.OrderBy(orderbyLambda) .Skip(pageIndex * pageSize - 1) //越过多少条 .Take(pageSize).ToList(); //取出多少条 } else { tempList = tempList.OrderByDescending(orderbyLambda) .Skip(pageIndex * pageSize - 1) .Take(pageSize).ToList(); } return tempList; } public T AddEntity(T model) { db.CreateObjectSet<T>().AddObject(model); db.SaveChanges(); return model; } public bool DeleteEntity(T model) { db.CreateObjectSet<T>().Attach(model); db.ObjectStateManager.ChangeObjectState(model, EntityState.Deleted); return db.SaveChanges() > 0; } public bool UpdateEntity(T model) { db.CreateObjectSet<T>().Attach(model); db.ObjectStateManager.ChangeObjectState(model, EntityState.Modified); return db.SaveChanges() > 0; } } }