MVC项目结构搭建及单个类的实现学习笔记1

 using System.Data.Entity; using System.Runtime.Remoting.Messaging; using PMS.Model; namespace PMS.DAL { public class DbContextFactory { /// 
 /// 负责创建EF数据操作上下文实例,必须保证线程内唯一 /// 
 public static DbContext CreateContext() { DbContext dbContext = (DbContext)CallContext.GetData("dbContext"); if (dbContext != null) return dbContext; dbContext = new PMSEntities(); CallContext.SetData("dbContext", dbContext); return dbContext; } } } 

 using System; using System.Data.Entity; using System.Linq; using PMS.IDAL; namespace PMS.DAL { public partial class UserDal   { public DbContext DbEntities = DbContextFactory.CreateContext(); /// 
 /// 查询过滤 /// 
 /// 过滤条件Lambda表达式 /// 实体集合 public IQueryable LoadEntities(System.Linq.Expressions.Expression> whereLamada) { return DbEntities.Set().Where(whereLamada); } /// 
 /// 分页查询 /// 
 /// 排序类型 /// 查询的页码 /// 每页显示的数目 /// 符合条件的总行数 /// 过滤条件Lambda表达式 /// 排序Lambda表达式 /// 排序方向 /// 实体集合 public IQueryable LoadPageEntities(int pageIndex, int pageSize, out int totalCount, System.Linq.Expressions.Expression> whereLambda, System.Linq.Expressions.Expression> orderbyLambda, bool isAsc) { var temp = DbEntities.Set().Where(whereLambda); totalCount = temp.Count(); temp = isAsc ? temp.OrderBy(orderbyLambda).Skip((pageIndex - 1) * pageSize).Take(pageSize) : temp.OrderByDescending(orderbyLambda).Skip((pageIndex - 1) * pageSize).Take(pageSize); return temp; } /// 
 /// 删除数据 /// 
 /// 待删数据 /// 删除结果 public bool DeleteEntity(UserDal entity) { DbEntities.Entry(entity).State = EntityState.Deleted; return true; } /// 
 /// 编辑数据 /// 
 /// 待编辑数据 /// 编辑结果 public bool EditEntity(UserDal entity) { DbEntities.Entry(entity).State = EntityState.Modified; return true; } /// 
 /// 添加数据 /// 
 /// 待添加数据 /// 已添加数据 public UserDal AddEntity(UserDal entity) { entity = DbEntities.Set().Add(entity); return entity; } } } 

 using System; using System.Data.Entity; using System.Linq; namespace PMS.DAL { public class BaseDal where T:class ,new() { public DbContext DbEntities = DbContextFactory.CreateContext(); /// 
 /// 查询过滤 /// 
 /// 过滤条件Lambda表达式 /// 实体集合 public IQueryable LoadEntities(System.Linq.Expressions.Expression> whereLamada) { return DbEntities.Set().Where(whereLamada); } /// 
 /// 分页查询 /// 
 /// 排序类型 /// 查询的页码 /// 每页显示的数目 /// 符合条件的总行数 /// 过滤条件Lambda表达式 /// 排序Lambda表达式 /// 排序方向 /// 实体集合 public IQueryable LoadPageEntities(int pageIndex, int pageSize, out int totalCount, System.Linq.Expressions.Expression> whereLambda, System.Linq.Expressions.Expression> orderbyLambda, bool isAsc) { var temp = DbEntities.Set().Where(whereLambda); totalCount = temp.Count(); temp = isAsc ? temp.OrderBy(orderbyLambda).Skip((pageIndex - 1) * pageSize).Take(pageSize) : temp.OrderByDescending(orderbyLambda).Skip((pageIndex - 1) * pageSize).Take(pageSize); return temp; } /// 
 /// 删除数据 /// 
 /// 待删数据 /// 删除结果 public bool DeleteEntity(T entity) { DbEntities.Entry(entity).State = EntityState.Deleted; return true; } /// 
 /// 编辑数据 /// 
 /// 待编辑数据 /// 编辑结果 public bool EditEntity(T entity) { DbEntities.Entry(entity).State = EntityState.Modified; return true; } /// 
 /// 添加数据 /// 
 /// 待添加数据 /// 已添加数据 public T AddEntity(T entity) { entity = DbEntities.Set().Add(entity); //DbEntities.SaveChanges(); return entity; } } } 

 using PMS.IDAL; using PMS.Model; namespace PMS.DAL { public partial class UserDal : BaseDal { } } 

 using System; using System.Linq; namespace PMS.IDAL { public interface IBaseDal where T:class,new() { IQueryable LoadEntities(System.Linq.Expressions.Expression> whereLamada); IQueryable LoadPageEntities(int pageIndex, int pageSize, out int totalCount, System.Linq.Expressions.Expression> whereLambda, System.Linq.Expressions.Expression> orderbyLambda, bool isAsc); bool DeleteEntity(T entity); bool EditEntity(T entity); T AddEntity(T entity); } } 

 using PMS.Model; namespace PMS.IDAL { public partial interface IUserDal:IBaseDal { } } 

 using System.Configuration; using System.Reflection; using PMS.IDAL; namespace PMS.DALFactory { public partial class AbstractFactory { //读取保存在配置文件中的程序集名称与命名空间名 private static readonly string AssemblyPath = ConfigurationManager.AppSettings["AssemblyPath"]; private static readonly string NameSpace = ConfigurationManager.AppSettings["NameSpace"]; /// 
 /// 获取UserDal的实例 /// 
 ///  public static IUserDal CreateUserInfoDal() { var fullClassName = NameSpace + ".UserInfoDal"; return CreateInstance(fullClassName) as IUserDal; } /// 
 /// 通过反射获得程序集中某类型的实例 /// 
 ///  ///  private static object CreateInstance(string className) { var assembly = Assembly.Load(AssemblyPath); return assembly.CreateInstance(className); } } } 

 using System.Data.Entity; using PMS.IDAL; using PMS.DAL; namespace PMS.DALFactory { public partial class DbSession:IDbSession { public DbContext Db { get { return DbContextFactory.CreateContext(); } } private IUserDal _userDal; public IUserDal UserDal { get { return _userDal ?? (_userDal = AbstractFactory.CreateUserInfoDal()); } set { _userDal = value; } } /// 
 /// 工作单元模式，统一保存数据 /// 
 ///  public bool SaveChanges() { return Db.SaveChanges() > 0; } } } 

 using System; using System.Linq; using System.Linq.Expressions; using PMS.DALFactory; using PMS.IDAL; namespace PMS.BLL { public abstract class BaseService where T:class,new() { public IDbSession CurrentDbSession { get { return new DbSession(); } } public IBaseDal CurrentDal { get; set; } public abstract void SetCurrentDal(); public BaseService() { SetCurrentDal();//子类一定要实现抽象方法，以指明当前类的子类类型。 } /// 
 /// 查询过滤 /// 
 ///  ///  public IQueryable LoadEntities(Expression> whereLambda) { return CurrentDal.LoadEntities(whereLambda); } /// 
 /// 分页 /// 
 ///  ///  ///  ///  ///  ///  ///  ///  public IQueryable LoadPageEntities(int pageIndex, int pageSize, out int totalCount, Expression> whereLambda, Expression> orderbyLambda, bool isAsc) { return CurrentDal.LoadPageEntities(pageIndex, pageSize, out totalCount, whereLambda, orderbyLambda, isAsc); } /// 
 /// 删除 /// 
 ///  ///  public bool DeleteEntity(T entity) { CurrentDal.DeleteEntity(entity); return CurrentDbSession.SaveChanges(); } /// 
 /// 编辑 /// 
 ///  ///  public bool EditEntity(T entity) { CurrentDal.EditEntity(entity); return CurrentDbSession.SaveChanges(); } /// 
 /// 添加数据 /// 
 ///  ///  public T AddEntity(T entity) { CurrentDal.AddEntity(entity); CurrentDbSession.SaveChanges(); return entity; } } } 

 using PMS.IBLL; using PMS.Model; namespace PMS.BLL { public partial class UserService : BaseService { public override void SetCurrentDal() { CurrentDal = CurrentDbSession.UserDal; } } } 

 using System; using System.Linq; using System.Linq.Expressions; using PMS.IDAL; namespace PMS.IBLL { public interface IBaseService where T : class,new() { IDbSession CurrentDbSession { get; } IBaseDal CurrentDal { get; set; } void SetCurrentDal(); IQueryable LoadEntities(Expression> whereLambda); IQueryable LoadPageEntities(int pageIndex, int pageSize, out int totalCount, Expression> whereLambda, Expression> orderbyLambda, bool isAsc); bool DeleteEntity(T entity); bool EditEntity(T entity); T AddEntity(T entity); } } 

 using PMS.Model; namespace PMS.IBLL { public partial interface IUserService:IBaseService { } }