asp.net core 实现一个简单的仓储的方法

一直有自己写个框架的想法,但是一直没有行动起来,最近比较闲,正好可以开工了.

现在已经完成了两部分.1.一个简单仓储,实现使用的是ef 2.IOC部分,这里是把内置的ioc替换成了aotofac,这部分感觉还是有一点缺陷的.下面说

仓储部分

这里主要是接口是实现,目前使用ef实现了仓储的接口.看一下代码

 public interface IRepository<TEntity, TPrimaryKey>  where TEntity : class {  #region Select/Get/Query  IQueryable<TEntity> GetAll();  IQueryable<TEntity> GetAllIncluding(params Expression<Func<TEntity, object>>[] propertySelectors);  List<TEntity> GetAllList();  Task<List<TEntity>> GetAllListAsync();  List<TEntity> GetAllList(Expression<Func<TEntity, bool>> predicate);  Task<List<TEntity>> GetAllListAsync(Expression<Func<TEntity, bool>> predicate);  T Query<T>(Func<IQueryable<TEntity>, T> queryMethod);  TEntity Get(TPrimaryKey id);  Task<TEntity> GetAsync(TPrimaryKey id);  TEntity Single(Expression<Func<TEntity, bool>> predicate);  Task<TEntity> SingleAsync(Expression<Func<TEntity, bool>> predicate);  TEntity FirstOrDefault(TPrimaryKey id);  Task<TEntity> FirstOrDefaultAsync(TPrimaryKey id);  TEntity FirstOrDefault(Expression<Func<TEntity, bool>> predicate);  Task<TEntity> FirstOrDefaultAsync(Expression<Func<TEntity, bool>> predicate);  TEntity Load(TPrimaryKey id);  #endregion  #region Insert  TEntity Insert(TEntity entity);  Task<TEntity> InsertAsync(TEntity entity);  #endregion  #region Update  TEntity Update(TEntity entity);  Task<TEntity> UpdateAsync(TEntity entity);  TEntity Update(TPrimaryKey id, Action<TEntity> updateAction);  Task<TEntity> UpdateAsync(TPrimaryKey id, Func<TEntity, Task> updateAction);  #endregion  #region Delete  void Delete(TEntity entity);  Task DeleteAsync(TEntity entity);  void Delete(TPrimaryKey id);  Task DeleteAsync(TPrimaryKey id);  void Delete(Expression<Func<TEntity, bool>> predicate);  Task DeleteAsync(Expression<Func<TEntity, bool>> predicate);  #endregion  #region Aggregates  int Count();  Task<int> CountAsync();  int Count(Expression<Func<TEntity, bool>> predicate);  Task<int> CountAsync(Expression<Func<TEntity, bool>> predicate);  long LongCount();  Task<long> LongCountAsync();  long LongCount(Expression<Func<TEntity, bool>> predicate);  Task<long> LongCountAsync(Expression<Func<TEntity, bool>> predicate);  #endregion }

下面是实现的部分代码,代码比较占版面,就不贴全了.

 public abstract class RepositoryBase<TEntity, TPrimaryKey> : IRepository<TEntity, TPrimaryKey>  where TEntity : class {  public abstract IQueryable<TEntity> GetAll();  public abstract IQueryable<TEntity> GetAllIncluding(params Expression<Func<TEntity, object>>[] propertySelectors);  public virtual List<TEntity> GetAllList()  {   return GetAll().ToList();  }  public virtual async Task<List<TEntity>> GetAllListAsync()  {   return await Task.FromResult(GetAllList());  } }