数据仓储之DLL层接口设计

一、接口设计
1.1. IBaseRepository.cs
public interface IBaseRepository<T>
    {
        T Add(T entity);
        bool Update(T entity);
        bool Delete(T entity);
        IQueryable<T> LoadEntities(Expression<Func<T, bool>> whereLambda);
        IQueryable<T> LoadPageEntities<S>(int pageSize, int pageIndex, out int total, Expression<Func<T, bool>> whereLambda, Expression<Func<T, S>> orderbyLambda, bool isAsc);

    }
1.2. ICompanyRepository.cs
public interface ICompanyRepository:IBaseRepository<Company>
    {
        
    }
二、接口实现
2.1 BaseRepository.cs
public class BaseRepository<T> where T:class,new()
    {
        private ObjectContext dbContext
        {
            get
            {
                return EFDbContextFactory.GetCurrentDbContext();
            }
        }
        public virtual T Add(T entity)
        {
            dbContext.CreateObjectSet<T>().AddObject(entity);
            return entity;
        }

        public virtual bool Update(T entity)
        {
           
            dbContext.ObjectStateManager.ChangeObjectState(entity, System.Data.EntityState.Modified);
            return true;
        }

        public virtual bool Delete(T entity)
        {
            dbContext.ObjectStateManager.ChangeObjectState(entity,System.Data.EntityState.Deleted);
            return true;
        }

        public IQueryable<T> LoadEntities(Expression<Func<T, bool>> whereLambda)
        {
            return dbContext.CreateObjectSet<T>().Where(whereLambda).AsQueryable();
        }
        public IQueryable<T> LoadPageEntities<S>(int pageSize, int pageIndex, out int total, Expression<Func<T, bool>> whereLambda, Expression<Func<T,S>> orderbyLambda, bool isAsc)
        {
            total = dbContext.CreateObjectSet<T>().Where(whereLambda).Count();
            if (isAsc)
            {
                return dbContext.CreateObjectSet<T>()
                                .Where(whereLambda)
                                .OrderBy(orderbyLambda)
                                .Skip(pageSize * (pageIndex - 1))
                                .AsQueryable();
            }
            else
            {
                return dbContext.CreateObjectSet<T>()
                                .Where(whereLambda)
                                .OrderByDescending(orderbyLambda)
                                .Skip(pageSize * (pageIndex - 1))
                                .AsQueryable();
            }
        }
    }
2.2 CompanyRepository.cs
 public class CompanyRepository : BaseRepository<Company>,ICompanyRepository
    {
        
    }
三、IDbSession
3.1 IDbSession.cs
public  interface IDbSession
    {
       IMemberRepository MemberRepository { get; }
       IServiceTypeRepository ServiceTypeRepository { get; }
       IServiceRepository ServiceRepository { get; }
       ICompanyRepository CompanyRepository { get; }
       IProductGroupRepository ProductGroupRepository { get; }
       int SaveChanges();
    }
3.2 DbSession.cs
public class DbSession : IDbSession
    {
        private IMemberRepository _MemberRepository;
        private IServiceTypeRepository _ServiceTypeRepository;
        private IServiceRepository _ServiceRepository;
        private ICompanyRepository _CompanyRepository;
        private IProductGroupRepository _ProductGroupRepository;

        public IMemberRepository MemberRepository
        {
            get
            {
                if (_MemberRepository == null)
                {
                    _MemberRepository = new MemberRepository();
                }
                return _MemberRepository;
            }
        }

        public IServiceTypeRepository ServiceTypeRepository
        {
            get
            {
                if (_ServiceTypeRepository == null)
                {
                    _ServiceTypeRepository = new ServiceTypeRepository();
                }
                return _ServiceTypeRepository;
            }
        }

        public IServiceRepository ServiceRepository
        {
            get
            {
                if (_ServiceRepository == null)
                {
                    _ServiceRepository = new ServiceRepository();
                }
                return _ServiceRepository;
            }
        }

        public ICompanyRepository CompanyRepository
        {
            get
            {
                if (_CompanyRepository == null)
                {
                    _CompanyRepository = new CompanyRepository();
                }
                return _CompanyRepository;
            }
        }

        public IProductGroupRepository ProductGroupRepository
        {
            get
            {
                if (_ProductGroupRepository == null)
                {
                    _ProductGroupRepository = new ProductGroupRepository();
                }
                return _ProductGroupRepository;
            }
        }

        public int SaveChanges()
        {
            return EFDbContextFactory.GetCurrentDbContext().SaveChanges();
        }


        
    }
3.3 EFDbContextFactory.cs
 public class EFDbContextFactory
    {
        public static ObjectContext GetCurrentDbContext()
        {
            
                //线程内唯一
                ObjectContext dbContext = (ObjectContext)CallContext.GetData("dbContext");
                if (dbContext == null)
                {
                    dbContext = new SimpleNewsContext();
                    CallContext.SetData("dbContext", dbContext);
                }
                return dbContext;
            }
       
    }