asp.net core 实现一个简单的仓储的方法_实用技巧_

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

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

 public class EfRepositoryBase : RepositoryBase where TEntity : class where TDbContext : DbContext { public virtual TDbContext Context { private set; get; } public virtual DbSet Table => Context.Set(); public EfRepositoryBase(TDbContext context) { Context = context; } public override IQueryable GetAll() { return Table; } public override IQueryable GetAllIncluding(params Expression>[] propertySelectors) { if (propertySelectors == null) { return GetAll(); } var linq = GetAll(); foreach (var item in propertySelectors) { linq = linq.Include(item); } return linq; } } 

 public class TestRepository : EfRepositoryBase where TEntity : class { public TestRepository(TestContext context) : base(context) { } }

 public IServiceProvider ConfigureServices(IServiceCollection services) { services.AddMvc(); return services.AddLuna(); } public static IServiceProvider AddLuna([NotNull]this IServiceCollection services) where TModule : IModule, new() { var builder = new ContainerBuilder(); builder.Populate(services); builder.RegisterModule(); return new AutofacServiceProvider(builder.Build()); } public class AutofacModule : Module { protected override void Load(ContainerBuilder builder) { builder.RegisterType(); builder.RegisterGeneric(typeof(TestRepository<,>)).As(typeof(IRepository<,>)) .InstancePerLifetimeScope(); } }