通过 Entity Framework Core 将多个数据库连接到 .NET Core 项目

Question

我正在尝试创建一个连接到多个数据库的 .NET 核心应用程序，但使用一个包含所有 CRUD 操作逻辑的通用存储库。实现这一目标的最佳方法是什么？

    public Repository(ApplicationDbContext dbContext)
    {
        _dbContext = dbContext;
        _set = _dbContext.Set<T>();
    }

上面是我的存储库的构造函数。在这里，我注入了 ApplicationDbContext。我正在寻找一种方法来使这个 ApplicationDbContext 通用，所以我只需要一个存储库，我可以在其中注入不同的上下文来访问多个数据库。基本上我正在寻找这样的东西：

public class Repository_1<T> where T:EntityBase
{
    public Repository_1(IDbContext dbContext)
    {

    }
}

我可以在哪里换出 dbContext 并将其替换为连接到另一个数据库的另一个上下文。

Answer 1

创建基本上下文并将所有设置包含在此 DBSET 中：

public abstract class BaseContext : DbContext
{
    public BaseContext(DbContext options)
    : base(options)
    { }
    public DbSet<object> FirstDbSet { get; set; }
    ...
}

从 BaseContext 继承两个 DB（数据库）：

public class NavaContext : BaseContext
{
    public NavaContext (DbContext<NavaContext> options) : base(options)
    {

    }
}

public class StackContext : BaseContext
{
    public StackContext(DbContext<StackContext> options) : base(options)
    {

    }
}

并在Startup.cs注册：

public IServiceProvider ConfigureServices(IServiceCollection services)
{
    services.AddDbContext<NavaContext>(options => options.UseSqlServer(Configuration.GetConnectionString("LATAMConnectionString")));
    services.AddDbContext<StackContext>(options => options.UseSqlServer(Configuration.GetConnectionString("EUConnectionString")));

    // Autofac
    var builder = new ContainerBuilder();

    // needed only if you plan to inject ICollection<BaseContext>
    builder.RegisterType<NavaContext>().As<BaseContext>();
    builder.RegisterType<StackContext>().As<BaseContext>();

    builder.Populate(services);


    return new AutofacServiceProvider(builder.Build());
}

在appsettings.json中添加连接字符串：

"ConnectionStrings": {
  "NavaConnectionString": "Server=(localdb)\\mssqllocaldb;Database=ContosoUniversity1;Trusted_Connection=True;MultipleActiveResultSets=true",
  "StackConnectionString": "Server=(localdb)\\mssqllocaldb;Database=ContosoUniversity1;Trusted_Connection=True;MultipleActiveResultSets=true"
}

现在您可以注入两种上下文：

public class ReportRepository : IReportRepository
{
    private readonly NavaContext latamDbContext;
    private readonly StackContext euDbContext;

    public ReportRepository(NavaContext latamDbContext, StackContext euDbContext)
    {
        this.latamDbContext = latamDbContext;
        this.euDbContext = euDbContext;
    }
}

或者如果你打算注入 collection 的上下文：

public class ReportRepository : IReportRepository
{
    private readonly ICollection<BaseContext> dbContexts;

    public ReportRepository(ICollection<BaseContext> dbContexts)
    {
        this.dbContexts = dbContexts;
    }
}

访问特定上下文：

var _stackContext= dbContexts.FirstOrDefault(x => x is StackContext) as StackContext;
var _navaContext= dbContexts.FirstOrDefault(x => x is NavaContext) as NavaContext;

Answer 2

您可以为您的存储库设置两个参数并在它们上添加约束，假设您的 dbContext 继承自 DbContext

public class TestRepository<TContext, T> : ITestRepository<TContext,T> 
    where TContext : DbContext
    where T : BaseEntity
{

    private readonly TContext _context;
    private DbSet<T> entities;


    public TestRepository(TContext context)
    {
        _context = context;
        entities = context.Set<T>();
    }



    public List<T> GetAll()
    {

        return entities.AsNoTracking().ToList();
    }
}

ITestReposiroty：

public interface ITestRepository<TContext,T>
    where TContext : DbContext
    where T : BaseEntity
{       
    List<T> GetAll();
}

Startup.cs

services.AddScoped(typeof(ITestRepository<,>), typeof(TestRepository<,>));

控制器：

public class ProductsController : ControllerBase
{
    private readonly ITestRepository<ApplicationDbContext, Product> _repository;

    public TestRepoController(ITestRepository<ApplicationDbContext, Product> repository)
    {
        _repository = repository;
    }
    // GET api/products

    [HttpGet]
    public List<Product> Get()
    {
        return _repository.GetAll();
    }
}

Answer 3

在您的 RepositoryBase 类中：

public abstract class RepositoryBase<TContext, TEntity>
   where TContext : DbContext
   where Entity: class 

public TContext Context { get; private set; }

public RepositoryBase(TContext context)
{
    this.Context = context;
}

public IQueryable<TEntity> GetAll()
{
        return this.Context.Set<TEntity>().AsNoTracking();
}

来自特定存储库的使用：

public class ComputerGroupRepo : RepositoryBase<RequestContext, ComputerGroup> 
{
    public ComputerGroupRepo()
       : base(new RequestContext())
    {
    }

    public IQueryable<ComputerGroup> GetComputerGroups()
    {
        IQueryable<ComputerGroup> result = this.GetAll()
            .Include(v => v.ComputerGroupIps);

        return result;
    }

}

Answer 4

BaseRepository 类可以这样使用，它在数据访问层类上使用继承。

public class GenericRepository<TEntity, TContext> : IGenericRepository<TEntity> 
    where TEntity : class 
    where TContext : DbContext, new()
    {
        private readonly DbContext _context;
        private readonly DbSet<TEntity> _dbSet;
        public GenericRepository()
        {
            _context = new TContext();
            _dbSet = _context.Set<TEntity>();
        }
    
    }

数据访问类；

public class ProductDal:GenericRepository<Product,AppDbContext>,IProductDal
{
}

如果使用依赖注入数据访问类必须注册。 Generic Repository 无法注册，因为它在类中实例化。 _context = new TContext();