十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
实现代码
成都创新互联公司是一家网站建设、网站制作,提供网页设计,网站设计,网站制作,建网站,按需求定制设计,网站开发公司,2013年至今是互联行业建设者,服务者。以提升客户品牌价值为核心业务,全程参与项目的网站策划设计制作,前端开发,后台程序制作以及后期项目运营并提出专业建议和思路。
1、新建接口类:IRepository.cs,规范各个操作类的都有那些方法,方便管理。
using System;using System.Collections.Generic;using System.Linq;using System.Linq.Expressions;using System.Text;namespace CMS.Entity.Interfaces { public interface IRepositorywhere T:class { /// /// 添加 /// /// 实体对象 void Add(T entity); ////// 更新 /// /// 实体对象 void Update(T entity); ////// 删除 /// /// 实体对象 void Delete(T entity); ////// 删除 /// /// 条件(lambda表达式) void Delete(Expression> where); /// /// 根据ID获取一个对象 /// /// 主键ID ///对象 T GetById(long Id); ////// 根据ID获取一个对象 /// /// 主键ID ///对象 T GetById(string Id); ////// 根据条件获取一个对象 /// /// 条件(lambda表达式) ///对象 T Get(Expression> where); /// /// 获取所有数据 /// ///所有数据 IQueryableGetAll(); /// /// 根据条件获取数据 /// /// 条件(lambda表达式) ///数据 IQueryableGetMany(Expression > where); /// /// 根据条件获取记录数 /// /// 条件(lambda表达式) ///int GetCount(Expression > where); /// /// 关闭代理 /// void CloseProxy(); ////// 打开代理 /// void OpenProxy(); ////// 是否有指定条件的元素 /// /// 条件(lambda表达式) ///bool IsHasValue(Expression > where); } }
2、新建仓储基础操作类RepositoryBase.cs,注意要一一对应实现IRepositroy接口的方法
using System;using System.Collections.Generic;using System.Text;using System.Linq;namespace CMS.Entity.Interfaces { public abstract class BaseRepositorywhere T: class { private BcmfDBContext db;//数据库上下文 public BaseRepository(BcmfDBContext _db) { db = _db; } public virtual void Save() { db.SaveChanges(); } public virtual void Add(T entity) { db.Set ().Add(entity); } public virtual void CloseProxy() { db.Database.CommitTransaction(); } public virtual void Delete(T entity) { db.Set ().Remove(entity); } public virtual void Delete(System.Linq.Expressions.Expression > where) { var dataList = db.Set ().Where(where).AsEnumerable(); db.Set ().RemoveRange(dataList); } public virtual T Get(System.Linq.Expressions.Expression > where) { return db.Set ().FirstOrDefault(where); } public virtual System.Linq.IQueryable GetAll() { return db.Set (); } public virtual T GetById(long Id) { return db.Set ().Find(Id); } public virtual T GetById(string Id) { return db.Set ().Find(Id); } public virtual int GetCount(System.Linq.Expressions.Expression > where) { return db.Set ().Count(where); } public virtual System.Linq.IQueryable GetMany(System.Linq.Expressions.Expression > where) { return db.Set ().Where(where); } public virtual bool IsHasValue(System.Linq.Expressions.Expression > where) { return db.Set ().Any(where); } public virtual void OpenProxy() { db.Database.BeginTransaction(); } public virtual void Update(T entity) { db.Set ().Attach(entity); db.Entry (entity).State = Microsoft.EntityFrameworkCore.EntityState.Modified; } } }
3、新建仓储类TUserRepository与TOperateLogRepository,TUserRepository用于操作用户表,TOperateLogRepository用于操作用户记录表,对应的User类与OperateLog类根据项目需求自行创建
using System;using System.Collections.Generic;using System.Text;using CMS.Entity.Repository;using CMS.Entity.Entity;using Microsoft.EntityFrameworkCore;using System.Linq;using CMS.Entity.Interfaces;namespace CMS.Entity.Repository { public class TUserRepository :BaseRepository,IUserRepository { public TUserRepository(BcmfDBContext db) : base(db) { } } public interface IUserRepository : IRepository { } }
using System;using System.Collections.Generic;using System.Text;using CMS.Entity.Repository;using CMS.Entity.Entity;using Microsoft.EntityFrameworkCore;using System.Linq;using CMS.Entity.Interfaces;namespace CMS.Entity.Repository { public class TOperateLogRepository : BaseRepository, IOperateLogRepository { public TOperateLogRepository(BcmfDBContext db) : base(db) { } } public interface IOperateLogRepository : IRepository { } }
4、分别在UserController与OperateLogController控制器中的构造函数注入仓储类
using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNetCore.Http;using Microsoft.AspNetCore.Mvc;using CMS.Entity;using CMS.Entity.Entity;using Newtonsoft.Json;using CMS.WebApi.Core;using Microsoft.EntityFrameworkCore.Query;using CMS.Entity.Repository;namespace CMS.WebApi.Controllers { ////// 用户中心 /// //[Produces("application/json")] [Route("api/[controller]")] [ApiController] public class UsersController : ControllerBase { private readonly IUserRepository userRepository; public UsersController(IUserRepository _userRepository) { userRepository = _userRepository; } ////// 获取用户列表 /// ///[HttpGet] public string Get() { var userList= userRepository.GetAll().ToList(); return JsonConvert.SerializeObject(userList); } } }
using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNetCore.Http;using Microsoft.AspNetCore.Mvc;using CMS.Entity.Repository;using Newtonsoft.Json;namespace CMS.WebApi.Controllers { [Route("api/[controller]")] [ApiController] public class OperateLogController : ControllerBase { private readonly IOperateLogRepository operateLogRepository; public OperateLogController(IOperateLogRepository _operateLogRepository) { operateLogRepository = _operateLogRepository; } [HttpGet] public string Get() { var result = operateLogRepository.GetMany(m=>m.ActionLogId<100); return JsonConvert.SerializeObject(result); } } }
5、完成上述操作后,运行获取数据时会系统报错,那是由于还没将仓储类注入到服务中,接下来就实现用AutoFac注入仓储类到项目服务中
添加引用Autofac,Auto.Configuration,Autofac.Extensions.DependencyInjection到项目中
这里贴出Nuget程序控制台命令:
Install-Package Autofac -Version 4.9.2
Install-Package Autofac.Configuration -Version 4.1.0
Install-Package Autofac.Extensions.DependencyInjection -Version 4.4.0
6、打开项目Startup.cs,找到ConfigureServices方法,将void改为IServiceProvider返回值,如下
//先引用命名空间 using Autofac; using Autofac.Extensions.DependencyInjection; builder = builder.RegisterAssemblyTypes(=> t.Name.EndsWith( container =
7、重新生成发布项目,完成