1 namespace LYZJ.UserLimitMVC.IDAL
 2
 3 {
 4
 5     public interface IDbSession
 6
 7     {
 8
 9         //每个表对应的实体仓储对象
10
11         IDAL.IRoleRepository RoleRepository { get; }
12
13         IDAL.IUserInfoRepository UserInfoRepository { get; }
14
15         //将当前应用程序跟数据库的会话内所有实体的变化更新会数据库
16
17         int SaveChanges();
18
19         //执行Sql语句的方法
20
21         //EF4.0的写法
22
23         //int ExcuteSql(string strSql, ObjectParameter[] parameters);
24
25         //EF5.0的写法
26
27         int ExcuteSql(string strSql, DbParameter[] parameters);
28
29     }
30
31 }

 1 namespace LYZJ.UserLimitMVC.DAL
 2
 3 {
 4
 5     //一次跟数据库交互的会话
 6
 7     public class DbSession : IDbSession //代表应用程序跟数据库之间的一次会话，也是数据库访问层的统一入口
 8
 9     {
10
11         public IDAL.IRoleRepository RoleRepository
12
13         {
14
15             get { return new RoleRepository(); }
16
17         }
18
19         public IDAL.IUserInfoRepository UserInfoRepository
20
21         {
22
23             get { return new UserInfoRepository(); }
24
25         }
26
27         //代表：当前应用程序跟数据库的会话内所有的实体的变化，更新会数据库
28
29         public int SaveChanges()
30
31         {
32
33             //调用EF上下文的SaveChanges方法
34
35             return DAL.EFContextFactory.GetCurrentDbContext().SaveChanges();
36
37         }
38
39         //执行Sql脚本的方法
40
41         public int ExcuteSql(string strSql, System.Data.Common.DbParameter[] parameters)
42
43         {
44
45             //Ef4.0的执行方法 ObjectContext
46
47             //封装一个执行SQl脚本的代码
48
49             //return DAL.EFContextFactory.GetCurrentDbContext().ExecuteFunction(strSql, parameters);
50
51             throw new NotImplementedException();
52
53         }
54
55     }
56
57 }

1 //获取的是当前线程内部的上下文实例，而且保证了线程内上下文唯一
2
3 private DbContext db = EFContextFactory.GetCurrentDbContext();

1   //DbSession的存放
2
3  public IDbSession _DbSession = DbSessionFactory.GetCurrenntDbSession();

 1 namespace LYZJ.UserLimitMVC.DAL
 2
 3 {
 4
 5     public class DbSessionFactory
 6
 7     {
 8
 9         //保证了线程内DbSession实例唯一
10
11         public  static IDbSession GetCurrenntDbSession()
12
13         {
14
15             //这里的GetData()方法的key不能和上下文的一样
16
17             IDbSession _dbSession = CallContext.GetData("DbSession") as IDbSession;
18
19             if (_dbSession == null)
20
21             {
22
23                 _dbSession = new DbSession();
24
25                 //将值设置到数据槽里面去
26
27                 CallContext.SetData("DbSession", _dbSession);
28
29             }
30
31             return _dbSession;
32
33         }
34
35     }
36
37 }