我正在尝试创建一个连接到多个数据库的.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并将其替换为连接到另一个数据库的另一个上下文。
创建基本上下文,并将所有设置包括在其中,DBSET:
public abstract class BaseContext : DbContext
{
public BaseContext(DbContext options)
: base(options)
{ }
public DbSet<object> FirstDbSet { get; set; }
...
}
继承自两个数据库(数据库)的BaseContext:
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;