ASP.NETCore使用AutoFac依賴注入

 

實現代碼

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 IRepository<T> where T:class
    {
        /// <summary>
        /// 添加
        /// </summary>
        /// <param name="entity">實體對象</param>
        void Add(T entity);
        /// <summary>
        /// 更新
        /// </summary>
        /// <param name="entity">實體對象</param>
        void Update(T entity);
        /// <summary>
        /// 刪除
        /// </summary>
        /// <param name="entity">實體對象</param>
        void Delete(T entity);
        /// <summary>
        /// 刪除
        /// </summary>
        /// <param name="where">條件(lambda表達式)</param>
        void Delete(Expression<Func<T, bool>> where);
        /// <summary>
        /// 根據ID獲取一個對象
        /// </summary>
        /// <param name="Id">主鍵ID</param>
        /// <returns>對象</returns>
        T GetById(long Id);
        /// <summary>
        /// 根據ID獲取一個對象
        /// </summary>
        /// <param name="Id">主鍵ID</param>
        /// <returns>對象</returns>
        T GetById(string Id);
        /// <summary>
        /// 根據條件獲取一個對象
        /// </summary>
        /// <param name="where">條件(lambda表達式)</param>
        /// <returns>對象</returns>
        T Get(Expression<Func<T, bool>> where);
        /// <summary>
        /// 獲取所有數據
        /// </summary>
        /// <returns>所有數據</returns>
        IQueryable<T> GetAll();
        /// <summary>
        /// 根據條件獲取數據
        /// </summary>
        /// <param name="where">條件(lambda表達式)</param>
        /// <returns>數據</returns>
        IQueryable<T> GetMany(Expression<Func<T, bool>> where);
        /// <summary>
        /// 根據條件獲取記錄數
        /// </summary>
        /// <param name="where">條件(lambda表達式)</param>
        /// <returns></returns>
        int GetCount(Expression<Func<T, bool>> where);
        /// <summary>
        /// 關閉代理
        /// </summary>
        void CloseProxy();
        /// <summary>
        /// 打開代理
        /// </summary>
        void OpenProxy();
        /// <summary>
        /// 是否有指定條件的元素
        /// </summary>
        /// <param name="where">條件(lambda表達式)</param>
        /// <returns></returns>
        bool IsHasValue(Expression<Func<T, bool>> where);
    }
}

2、新建倉儲基礎操作類RepositoryBase.cs，注意要一一對應實現IRepositroy接口的方法

using System;
using System.Collections.Generic;
using System.Text;
using System.Linq;

namespace CMS.Entity.Interfaces
{
    public abstract class BaseRepository<T>  where 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<T>().Add(entity);
        }

        public virtual void CloseProxy()
        {
            db.Database.CommitTransaction();
        }

        public virtual void Delete(T entity)
        {
            db.Set<T>().Remove(entity);
        }

        public virtual void Delete(System.Linq.Expressions.Expression<Func<T, bool>> where)
        {
            var dataList = db.Set<T>().Where(where).AsEnumerable();
            db.Set<T>().RemoveRange(dataList);
        }

        public virtual T Get(System.Linq.Expressions.Expression<Func<T, bool>> where)
        {
           return db.Set<T>().FirstOrDefault(where);
        }

        public virtual System.Linq.IQueryable<T> GetAll()
        {
            return db.Set<T>();
        }

        public virtual T GetById(long Id)
        {
            return db.Set<T>().Find(Id);
        }

        public virtual T GetById(string Id)
        {
            return db.Set<T>().Find(Id);
        }

        public virtual int GetCount(System.Linq.Expressions.Expression<Func<T, bool>> where)
        {
            return db.Set<T>().Count(where);
        }

        public virtual System.Linq.IQueryable<T> GetMany(System.Linq.Expressions.Expression<Func<T, bool>> where)
        {
            return db.Set<T>().Where(where);
        }

        public virtual bool IsHasValue(System.Linq.Expressions.Expression<Func<T, bool>> where)
        {
            return db.Set<T>().Any(where);
        }

        public virtual void OpenProxy()
        {
            db.Database.BeginTransaction();
        }

        public virtual void Update(T entity)
        {
            db.Set<T>().Attach(entity);
            db.Entry<T>(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<User>,IUserRepository
    {
        public TUserRepository(BcmfDBContext db) : base(db) { }
    }
    public interface IUserRepository : IRepository<User> { }
}

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<OperateLog>, IOperateLogRepository
    {
        public TOperateLogRepository(BcmfDBContext db) : base(db) { }
    }
    public interface IOperateLogRepository : IRepository<OperateLog>
    {
    }
}

 

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
{
    /// <summary>
    /// 用戶中心
    /// </summary>
    //[Produces("application/json")]
    [Route("api/[controller]")]
    [ApiController]
    public class UsersController : ControllerBase
    {

        private readonly IUserRepository userRepository;
        public UsersController(IUserRepository _userRepository)
        {
            userRepository = _userRepository;
        }


        /// <summary>
        /// 獲取用戶列表
        /// </summary>
        /// <returns></returns>
        [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;

public IServiceProvider ConfigureServices(IServiceCollection services)
        {
            ...



            ////批量匹配注入，使用AutoFac提供的容器接管當前項目默認容器
            var builder = new ContainerBuilder();
            //注入entity層的repository類builder.RegisterType(typeof(TUserRepository)).As(typeof(IUserRepository)).InstancePerDependency();
            //批量注入Repository的類
       　　builder.RegisterAssemblyTypes(typeof(TUserRepository).Assembly)
                .Where(t => t.Name.EndsWith("Repository"))
                .AsImplementedInterfaces();
            builder.Populate(services);
            var container = builder.Build();
            //ConfigureServices方法由void改為返回IServiceProvider
            return new AutofacServiceProvider(container);
        }

7、重新生成發布項目，完成