ASP.Net Core基于EF6、Unitwork、Autofac实现Repository模式_实用技巧_

 public interface IRepository where TEntity : class { /// 
 /// Gets all objects from database /// 
 ///  IQueryable All(); /// 
 /// Gets objects from database by filter. /// 
 /// Specified a filter ///  IQueryable Filter(Expression> predicate); /// 
 /// Gets objects from database with filtering and paging. /// 
 /// Specified a filter /// Returns the total records count of the filter. /// Specified the page index. /// Specified the page size ///  IQueryable Filter(Expression> filter, out int total, int index = 0, int size = 50); /// 
 /// Gets the object(s) is exists in database by specified filter. /// 
 /// Specified the filter expression ///  bool Contains(Expression> predicate); /// 
 /// Find object by keys. /// 
 /// Specified the search keys. ///  TEntity Find(params object[] keys); /// 
 /// Find object by specified expression. /// 
 ///  ///  TEntity Find(Expression> predicate); /// 
 /// Create a new object to database. /// 
 /// Specified a new object to create. ///  void Create(TEntity t); /// 
 /// Delete the object from database. /// 
 /// Specified a existing object to delete. void Delete(TEntity t); /// 
 /// Delete objects from database by specified filter expression. /// 
 ///  ///  int Delete(Expression> predicate); /// 
 /// Update object changes and save to database. /// 
 /// Specified the object to save. ///  void Update(TEntity t); /// 
 /// Select Single Item by specified expression. /// 
 ///  ///  TEntity FirstOrDefault(Expression> expression); }

 public class BaseRepository : IRepository where TEntity : class { protected readonly DbContext Context; public BaseRepository(DbContext context) { Context = context; } /// 
 /// Gets all objects from database /// 
 ///  public IQueryable All() { return Context.Set().AsQueryable(); } /// 
 /// Gets objects from database by filter. /// 
 /// Specified a filter ///  public virtual IQueryable Filter(Expression> predicate) { return Context.Set().Where(predicate).AsQueryable(); } /// 
 /// Gets objects from database with filtering and paging. /// 
 /// Specified a filter /// Returns the total records count of the filter. /// Specified the page index. /// Specified the page size ///  public virtual IQueryable Filter(Expression> filter, out int total, int index = 0, int size = 50) { var skipCount = index * size; var resetSet = filter != null ? Context.Set().Where(filter).AsQueryable() : Context.Set().AsQueryable(); resetSet = skipCount == 0 ? resetSet.Take(size) : resetSet.Skip(skipCount).Take(size); total = resetSet.Count(); return resetSet.AsQueryable(); } /// 
 /// Gets the object(s) is exists in database by specified filter. /// 
 /// Specified the filter expression ///  public bool Contains(Expression> predicate) { return Context.Set().Any(predicate); } /// 
 /// Find object by keys. /// 
 /// Specified the search keys. ///  public virtual TEntity Find(params object[] keys) { return Context.Set().Find(keys); } /// 
 /// Find object by specified expression. /// 
 ///  ///  public virtual TEntity Find(Expression> predicate) { return Context.Set().FirstOrDefault(predicate); } /// 
 /// Create a new object to database. /// 
 /// Specified a new object to create. ///  public virtual void Create(TEntity t) { Context.Set().Add(t); } /// 
 /// Delete the object from database. /// 
 /// Specified a existing object to delete. public virtual void Delete(TEntity t) { Context.Set().Remove(t); } /// 
 /// Delete objects from database by specified filter expression. /// 
 ///  ///  public virtual int Delete(Expression> predicate) { var objects = Filter(predicate); foreach (var obj in objects) Context.Set().Remove(obj); return Context.SaveChanges(); } /// 
 /// Update object changes and save to database. /// 
 /// Specified the object to save. ///  public virtual void Update(TEntity t) { try { var entry = Context.Entry(t); Context.Set().Attach(t); entry.State = EntityState.Modified; } catch (OptimisticConcurrencyException ex) { throw ex; } } /// 
 /// Select Single Item by specified expression. /// 
 ///  ///  public TEntity FirstOrDefault(Expression> expression) { return All().FirstOrDefault(expression); } }

 public interface IUnitOfWork : IDisposable { DbContext DbContext { get; } TRepository GetRepository() where TRepository : class; void ExecuteProcedure(string procedureCommand, params object[] sqlParams); void ExecuteSql(string sql); List SqlQuery(string sql); void SaveChanges(); }

 public class UnitOfWork : IUnitOfWork { private readonly IComponentContext _componentContext; protected readonly DbContext Context; public UnitOfWork(DbContext context, IComponentContext componentContext) { Context = context; _componentContext = componentContext; } public DbContext DbContext => Context; public TRepository GetRepository() where TRepository : class { return _componentContext.Resolve(); } public void ExecuteProcedure(string procedureCommand, params object[] sqlParams) { Context.Database.ExecuteSqlCommand(procedureCommand, sqlParams); } public void ExecuteSql(string sql) { Context.Database.ExecuteSqlCommand(sql); } public List SqlQuery(string sql) { return Context.Database.SqlQuery(sql).ToList(); } public void SaveChanges() { try { Context.SaveChanges(); } catch (InvalidOperationException ex) { if (!ex.Message.Contains("The changes to the database were committed successfully")) { throw; } } } public void Dispose() { Context?.Dispose(); } }

public interface IStudentRepository : IRepository { IEnumerable GetAllStudents(); }

public class StudentRepository : BaseRepository, IStudentRepository { private readonly SchoolContext _context; public StudentRepository(SchoolContext context) : base(context) { _context = context; } public IEnumerable GetAllStudents() { return _context.Students; } }

 var builder = new ContainerBuilder(); //register controllers builder.RegisterControllers(typeof(MvcApplication).Assembly); //register repository builder.RegisterAssemblyTypes(Assembly.GetExecutingAssembly()).AsImplementedInterfaces(); //add the Entity Framework context to make sure only one context per request builder.RegisterType().InstancePerR
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：ASP.NET Core快速入门教程_基础应用_
                                                                
下一篇：ASP.NET Core使用MiniProfiler分析应用_实用技巧_