你们好,我是Rectorgit
又是星期五,很兴奋,很高兴,很high...啦啦啦。。。
Rector在码友网又和你们见面啦!!!上一篇《一步一步建立ASP.NET MVC5程序[Repository+Autofac+Automapper+SqlSugar](五)》,咱们完成了:github
经过前面几篇文章的学习,本系列【一步一步建立ASP.NET MVC5程序[Repository+Autofac+Automapper+SqlSugar]】中主要涉及到的技术和组件已基本介绍到位了。接下来的系列文章主要会以知识技术整合,提高,重构等为中心来展开,经过解决项目实战遇到的各类问题来帮助你们有目,有方向性地学习,以达到提高你们的ASP.NENT MVC 5开发技能的效果。web
今天要给你们分享的是本系列[一步一步建立ASP.NET MVC5程序]的 进阶知识:sql
说到为何使用泛型仓储,咱们不得不回到咱们的项目,以项目设计来驱动,说明为何是泛型仓储,用泛型仓储有哪些好处。数据库
在v1.5版本中,咱们已经实现了仓储层和服务层。其中,仓储层是咱们直接访问数据库的层,能够经过仓储层对数据库进行任何有权限的操做,包括增,删,改,查。咱们的PostRepository博文仓储实现类已经实现了其接口中的增,删,改,查操做,IPostRepository接口:mvc
using System.Collections.Generic; using TsBlog.Domain.Entities; namespace TsBlog.Repositories { public interface IPostRepository { /// <summary> /// 根据ID查询单条数据 /// </summary> /// <param name="id">ID</param> /// <returns></returns> Post FindById(int id); /// <summary> /// 查询全部数据(无分页,大数量时请慎用) /// </summary> /// <returns></returns> IEnumerable<Post> FindAll(); /// <summary> /// 写入实体数据 /// </summary> /// <param name="entity">博文实体类</param> /// <returns></returns> int Insert(Post entity); /// <summary> /// 更新实体数据 /// </summary> /// <param name="entity">博文实体类</param> /// <returns></returns> bool Update(Post entity); /// <summary> /// 根据实体删除一条数据 /// </summary> /// <param name="entity">博文实体类</param> /// <returns></returns> bool Delete(Post entity); /// <summary> /// 删除指定ID的数据 /// </summary> /// <param name="id">主键ID</param> /// <returns></returns> bool DeleteById(object id); /// <summary> /// 删除指定ID集合的数据(批量删除) /// </summary> /// <param name="ids">主键ID集合</param> /// <returns></returns> bool DeleteByIds(object[] ids); } }
看着这个接口类文件如今想一下,若是咱们再在数据库新增一个用户表(User),而后在领域项目【TsBlog.Domain】中对应建立领域实体(User),那么按照本系列之前添加仓储和服务层接口的步骤,咱们是否是还须要在仓储中建立一个IUserRepository.cs,若是IUserRepository也包括了增,删,改,查方法,那么咱们是否是须要把IPostRepository中的全部接口方法复制到IUserRepository.cs文件中呢?同时,其实现也要一样的复制。app
若是咱们又添加在数据库新增了多张表,对应的仓储接口和实现是否是又要重复以上的操做呢?ctrl+c , ctrl+v !!! 若是是这样,还不如使用代码生成器来得快。ide
看到这里,但愿有开发经验的开发者们不要笑话。回想一下当初笔者在初入.NET开发的时候也是这么干的,复制,粘贴,代码生成器都用过。随着时间和经验的积累,你也会变得更好,前提是少用或者不用复制,粘贴来实现编码功能,即便是网上找的实现方法,也要本身动手敲一遍。函数
以上两段话跑题了,咱们仍是切回正题,上面提到的问题实际上是有办法来避免重复工做,减轻咱们的工做量的,即使用泛型仓储。post
首先,打开项目【TsBlog.Repositories】,建立接口文件 IRepository.cs,在其中编写通用的查询接口方法:
using System; using System.Collections.Generic; using System.Linq.Expressions; namespace TsBlog.Repositories { /// <summary> /// 仓储通用接口类 /// </summary> /// <typeparam name="T">泛型实体类</typeparam> public interface IRepository<T> where T : class, new() { /// <summary> /// 根据主值查询单条数据 /// </summary> /// <param name="pkValue">主键值</param> /// <returns>泛型实体</returns> T FindById(object pkValue); /// <summary> /// 查询全部数据(无分页,请慎用) /// </summary> /// <returns></returns> IEnumerable<T> FindAll(); /// <summary> /// 根据条件查询数据 /// </summary> /// <param name="predicate">条件表达式树</param> /// <param name="orderBy">排序</param> /// <returns>泛型实体集合</returns> IEnumerable<T> FindListByClause(Expression<Func<T, bool>> predicate, string orderBy); /// <summary> /// 根据条件查询数据 /// </summary> /// <param name="predicate">条件表达式树</param> /// <returns></returns> T FindByClause(Expression<Func<T, bool>> predicate); /// <summary> /// 写入实体数据 /// </summary> /// <param name="entity">实体类</param> /// <returns></returns> long Insert(T entity); /// <summary> /// 更新实体数据 /// </summary> /// <param name="entity"></param> /// <returns></returns> bool Update(T entity); /// <summary> /// 删除数据 /// </summary> /// <param name="entity">实体类</param> /// <returns></returns> bool Delete(T entity); /// <summary> /// 删除数据 /// </summary> /// <param name="where">过滤条件</param> /// <returns></returns> bool Delete(Expression<Func<T, bool>> @where); /// <summary> /// 删除指定ID的数据 /// </summary> /// <param name="id"></param> /// <returns></returns> bool DeleteById(object id); /// <summary> /// 删除指定ID集合的数据(批量删除) /// </summary> /// <param name="ids"></param> /// <returns></returns> bool DeleteByIds(object[] ids); } }
建立泛型基类 GenericRepository.cs :
using System; using System.Collections.Generic; using System.Linq.Expressions; namespace TsBlog.Repositories { public abstract class GenericRepository<T> : IRepository<T> where T : class, new() { #region Implementation of IRepository<T> /// <summary> /// 根据主值查询单条数据 /// </summary> /// <param name="pkValue">主键值</param> /// <returns>泛型实体</returns> public T FindById(object pkValue) { using (var db = DbFactory.GetSqlSugarClient()) { var entity = db.Queryable<T>().InSingle(pkValue); return entity; } } /// <summary> /// 查询全部数据(无分页,请慎用) /// </summary> /// <returns></returns> public IEnumerable<T> FindAll() { using (var db = DbFactory.GetSqlSugarClient()) { var list = db.Queryable<T>().ToList(); return list; } } /// <summary> /// 根据条件查询数据 /// </summary> /// <param name="predicate">条件表达式树</param> /// <param name="orderBy">排序</param> /// <returns>泛型实体集合</returns> public IEnumerable<T> FindListByClause(Expression<Func<T, bool>> predicate, string orderBy) { using (var db = DbFactory.GetSqlSugarClient()) { var entities = db.Queryable<T>().Where(predicate).ToList(); return entities; } } /// <summary> /// 根据条件查询数据 /// </summary> /// <param name="predicate">条件表达式树</param> /// <returns></returns> public T FindByClause(Expression<Func<T, bool>> predicate) { using (var db = DbFactory.GetSqlSugarClient()) { var entity = db.Queryable<T>().First(predicate); return entity; } } /// <summary> /// 写入实体数据 /// </summary> /// <param name="entity">实体类</param> /// <returns></returns> public long Insert(T entity) { using (var db = DbFactory.GetSqlSugarClient()) { //返回插入数据的标识字段值 var i = db.Insertable(entity).ExecuteReturnBigIdentity(); return i; } } /// <summary> /// 更新实体数据 /// </summary> /// <param name="entity"></param> /// <returns></returns> public bool Update(T entity) { using (var db = DbFactory.GetSqlSugarClient()) { //这种方式会以主键为条件 var i = db.Updateable(entity).ExecuteCommand(); return i > 0; } } /// <summary> /// 删除数据 /// </summary> /// <param name="entity">实体类</param> /// <returns></returns> public bool Delete(T entity) { using (var db = DbFactory.GetSqlSugarClient()) { var i = db.Deleteable(entity).ExecuteCommand(); return i > 0; } } /// <summary> /// 删除数据 /// </summary> /// <param name="where">过滤条件</param> /// <returns></returns> public bool Delete(Expression<Func<T, bool>> @where) { using (var db = DbFactory.GetSqlSugarClient()) { var i = db.Deleteable<T>(@where).ExecuteCommand(); return i > 0; } } /// <summary> /// 删除指定ID的数据 /// </summary> /// <param name="id"></param> /// <returns></returns> public bool DeleteById(object id) { using (var db = DbFactory.GetSqlSugarClient()) { var i = db.Deleteable<T>(id).ExecuteCommand(); return i > 0; } } /// <summary> /// 删除指定ID集合的数据(批量删除) /// </summary> /// <param name="ids"></param> /// <returns></returns> public bool DeleteByIds(object[] ids) { using (var db = DbFactory.GetSqlSugarClient()) { var i = db.Deleteable<T>().In(ids).ExecuteCommand(); return i > 0; } } #endregion } }
如今,仓储接口和泛型仓储基类已建立好了,接下来咱们重构 IPostRepository 和 PostRepository,使他们分别继承自 IRepository 和 GenericRepository。
IPostRepository.cs
using TsBlog.Domain.Entities; namespace TsBlog.Repositories { public interface IPostRepository :IRepository<Post> { } }
PostRepository.cs
using TsBlog.Domain.Entities; namespace TsBlog.Repositories { /// <summary> /// POST表的数据库操做类 /// </summary> public class PostRepository : GenericRepository<Post> { } }
IPostRepository 和 PostRepository 是否是一下简洁了不少,但实现的方法仍是和重构前是同样的。
怎么样,若是咱们再新增用户表的仓储接口和仓储实现是否是很是简单了呢?不再用为重复的增,删,改,查操做来复制,粘贴了。
在项目【TsBlog.Repositories】中添加接口类 IDependency.cs :
namespace TsBlog.Repositories { /// <summary> /// 依赖注入的接口约束 /// </summary> public interface IDependency { } }
在泛型仓储抽象基类 GenericRepository.cs 中添加 IDependency 接口约束 :
public abstract class GenericRepository<T> : IDependency, IRepository<T> where T : class, new()
打开项目【TsBlog.Frontend】中的 Global.asax 从新配置 AutofacRegister 方法,以下:
private void AutofacRegister() { var builder = new ContainerBuilder(); //注册MvcApplication程序集中全部的控制器 builder.RegisterControllers(typeof(MvcApplication).Assembly); //注册仓储层服务 //builder.RegisterType<PostRepository>().As<IPostRepository>(); //注册基于接口约束的实体 var assembly = AppDomain.CurrentDomain.GetAssemblies(); builder.RegisterAssemblyTypes(assembly) .Where( t => t.GetInterfaces() .Any(i => i.IsAssignableFrom(typeof(IDependency))) ) .AsImplementedInterfaces() .InstancePerDependency(); //注册服务层服务 builder.RegisterType<PostService>().As<IPostService>(); //注册过滤器 builder.RegisterFilterProvider(); var container = builder.Build(); //设置依赖注入解析器 DependencyResolver.SetResolver(new AutofacDependencyResolver(container)); }
按F5运行,是否报错了?
是的,由于咱们刚才修改了泛型仓储中Insert的返回类型,因此,修改 IPostService.cs中的Insert的返回类型为long:
long Insert(Post entity);
修改后的 IPostService.cs:
using System.Collections.Generic; using TsBlog.Domain.Entities; namespace TsBlog.Services { public interface IPostService { /// <summary> /// 根据ID查询单条数据 /// </summary> /// <param name="id">ID</param> /// <returns></returns> Post FindById(int id); /// <summary> /// 查询全部数据(无分页,大数量时请慎用) /// </summary> /// <returns></returns> IEnumerable<Post> FindAll(); /// <summary> /// 写入实体数据 /// </summary> /// <param name="entity">博文实体类</param> /// <returns></returns> long Insert(Post entity); /// <summary> /// 更新实体数据 /// </summary> /// <param name="entity">博文实体类</param> /// <returns></returns> bool Update(Post entity); /// <summary> /// 根据实体删除一条数据 /// </summary> /// <param name="entity">博文实体类</param> /// <returns></returns> bool Delete(Post entity); /// <summary> /// 删除指定ID的数据 /// </summary> /// <param name="id">主键ID</param> /// <returns></returns> bool DeleteById(object id); /// <summary> /// 删除指定ID集合的数据(批量删除) /// </summary> /// <param name="ids">主键ID集合</param> /// <returns></returns> bool DeleteByIds(object[] ids); } }
再修改 PostService.cs中的Insert的返回类型为long:
public long Insert(Post entity) { return _postRepository.Insert(entity); }
修改后的 PostService.cs:
using System.Collections.Generic; using TsBlog.Domain.Entities; using TsBlog.Repositories; namespace TsBlog.Services { public class PostService : IPostService { private readonly IRepository<Post> _postRepository; public PostService(IRepository<Post> postRepository) { _postRepository = postRepository; } public bool Delete(Post entity) { return _postRepository.Delete(entity); } public bool DeleteById(object id) { return _postRepository.DeleteById(id); } public bool DeleteByIds(object[] ids) { return _postRepository.DeleteByIds(ids); } public IEnumerable<Post> FindAll() { return _postRepository.FindAll(); } public Post FindById(int id) { return _postRepository.FindById(id); } public long Insert(Post entity) { return _postRepository.Insert(entity); } public bool Update(Post entity) { return _postRepository.Update(entity); } } }
请注意:在 PostRepository.cs中尚未继承至 IPostRepository.cs ,因此,在 PostService.cs 的构造函数中咱们暂时使用泛型接口 IRepository<T>:
private readonly IRepository<Post> _postRepository; public PostService(IRepository<Post> postRepository)
_postRepository = postRepository;
}
下一篇将解决这个问题 再次按F5运行,打开页面[http://localhost:54739/home/post],熟悉你页面又回来了,哈哈。。。 ![create-aspnet-mvc-5-web-application-repository-autofac-automapper-sqlsugar-step-by-step-06][2] 本文的源码托管地址:https://github.com/lampo1024/TsBlog/releases/tag/v1.6 本文学习到此结束,本系列未完待续,咱们下期再见…… 若是你喜欢Rector的本系列文章,请为我点个大大的赞。 本文来源 [码友网][3] 《[一步一步建立ASP.NET MVC5程序\[Repository+Autofac+Automapper+SqlSugar\](六)][4]》 [1]: http://codedefault.com/p/create-aspnet-mvc-5-web-application-repository-autofac-automapper-sqlsugar-step-by-step-05 [2]: http://statics.codedefault.com/uploads/2017/12/create-aspnet-mvc-5-web-application-repository-autofac-automapper-sqlsugar-step-by-step-05-05.png [3]: http://codedefault.com