ASP.NET MVC+EF框架+EasyUI实现权限管理系列(7)-DBSession的封装

namespace LYZJ.UserLimitMVC.DAL

{

    //一次跟数据库交互的会话

    public class DbSession  //代表应用程序跟数据库之间的一次会话，也是数据库访问层的统一入口

    {

        public IDAL.IRoleRepository RoleRepository

        {

            get { return new RoleRepository(); }

        }
        public IDAL.IUserInfoRepository UserInfoRepository

        {

            get { return new UserInfoRepository(); }

        }

        //代表：当前应用程序跟数据库的绘画内所有的实体的变化，更新会数据库

        public int SaveChanges()

        {

            //调用EF上下文的SaveChanges方法

            return DAL.EFContextFactory.GetCurrentDbContext().SaveChanges();

        }

    }

}

 1 //实现对数据库的添加功能
 2 
 3 public T AddEntity(T entity)
 4 
 5 {
 6 
 7      //调用T对应的仓储来做添加工作
 8 
 9     CurrentRepository.AddEntity(entity);
10 
11     CurrentRepository.UpdateEntity(entity);
12 
13 }

 1  //DbSession的存放
 2 
 3         public DbSession _DbSession = new DbSession();
 4 
 5         //基类的构造函数
 6 
 7         public BaseService()
 8 
 9         {
10 
11             SetCurrentRepository();  //构造函数里面去调用了，此设置当前仓储的抽象方法
12 
13         }
14 
15         public abstract void SetCurrentRepository();  //子类必须实现
16 
17         //实现对数据库的添加功能
18 
19         public T AddEntity(T entity)
20 
21         {
22 
23             //调用T对应的仓储来做添加工作
24 
25             CurrentRepository.AddEntity(entity);
26 
27             CurrentRepository.UpdateEntity(entity);
28 
29             _DbSession.SaveChanges();
30 
31         }

  1 namespace LYZJ.UserLimitMVC.BLL
  2 
  3 {
  4 
  5     public abstract class BaseService<T> where T : class, new()
  6 
  7     {
  8 
  9         //当前仓储
 10 
 11         public IDAL.IBaseRepository<T> CurrentRepository { get; set; }
 12 
 13         //DbSession的存放
 14 
 15         public DbSession _DbSession = new DbSession();
 16 
 17         //基类的构造函数
 18 
 19         public BaseService()
 20 
 21         {
 22 
 23             SetCurrentRepository();  //构造函数里面去调用了，此设置当前仓储的抽象方法
 24 
 25         }
 26 
 27         public abstract void SetCurrentRepository();  //子类必须实现
 28 
 29         //实现对数据库的添加功能
 30 
 31         public T AddEntity(T entity)
 32 
 33         {
 34 
 35             //调用T对应的仓储来做添加工作
 36 
 37             var AddEntity = CurrentRepository.AddEntity(entity);
 38 
 39             _DbSession.SaveChanges();
 40 
 41             return AddEntity;
 42 
 43         }
 44         //实现对数据的修改功能
 45 
 46         public bool UpdateEntity(T entity)
 47 
 48         {
 49 
 50             CurrentRepository.UpdateEntity(entity);
 51 
 52             return _DbSession.SaveChanges() > 0;
 53 
 54         }
 55         //实现对数据库的删除功能
 56 
 57         public bool DeleteEntity(T entity)
 58 
 59         {
 60 
 61              CurrentRepository.DeleteEntity(entity);
 62 
 63             return _DbSession.SaveChanges() > 0;
 64 
 65         }
 66         //实现对数据库的查询  --简单查询
 67 
 68         public IQueryable<T> LoadEntities(Func<T, bool> whereLambda)
 69 
 70         {
 71 
 72             return CurrentRepository.LoadEntities(whereLambda);
 73 
 74         }
 75 
 76         /// <summary>
 77 
 78         /// 实现对数据的分页查询
 79 
 80         /// </summary>
 81 
 82         /// <typeparam name="S">按照某个类进行排序</typeparam>
 83 
 84         /// <param name="pageIndex">当前第几页</param>
 85 
 86         /// <param name="pageSize">一页显示多少条数据</param>
 87 
 88         /// <param name="total">总条数</param>
 89 
 90         /// <param name="whereLambda">取得排序的条件</param>
 91 
 92         /// <param name="isAsc">如何排序，根据倒叙还是升序</param>
 93 
 94         /// <param name="orderByLambda">根据那个字段进行排序</param>
 95 
 96         /// <returns></returns>
 97 
 98        public  IQueryable<T> LoadPageEntities<S>(int pageIndex, int pageSize, out int total, Func<T, bool> whereLambda,
 99 
100                                           bool isAsc, Func<T, S> orderByLambda)
101 
102         {
103 
104             return CurrentRepository.LoadPageEntities(pageIndex, pageSize, out total, whereLambda, isAsc, orderByLambda);
105 
106         }
107 
108     }
109 
110 }