尝试从代表不同数据库的 2 个 DbContext 中联接 2 个表时,我遇到了一个问题。
我正在使用 Fluent API 在 2 个表之间创建外键关系。 以下是 Dbcontext 配置和模型。
public class DbContextDemo1: DbContext
{
public DbSet<Agency> Agencies { get; set; }
public DbContextDemo1(DbContextOptions<DbContextDemo1> options)
: base(options)
{
}
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.HasDefaultSchema("db1")
.Entity<Agency>()
.ToTable("agencies")
.HasKey(agency => agency.Id)
.HasOne(agency => agency.AgencyApp)
.WithOne(app => app.Agency)
.HasForeignKey<Agency>(agency => agency.Id);
}
}
public class DbContextDemo2: DbContext
{
public DbSet<AgencyApp> AgencyApps { get; set; }
public DbContextDemo2(DbContextOptions<DbContextDemo2> options)
: base(options)
{
}
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.HasDefaultSchema("db2")
.Entity<AgencyApp>()
.ToTable("agenciesapps")
.HasKey(app => app .Id)
.HasOne(app=> app.Agency)
.WithOne(agency => agency.AgencyApp)
.HasForeignKey<AgencyApp>(app=> app.AgencyId);
}
}
以下是模型:
public class Agency
{
public Guid Id { get; set; }
public AgencyApp AgencyApp { get; set; }
}
public class AgencyApp
{
public Guid Id { get; set; }
public Guid AgencyId { get; set; }
public Agency Agency { get; set; }
}
现在,当我尝试获取代理商数据以及代理商应用程序时。
var result = _dbContextDemo1.Agencies.Include(agency => agency.AgencyApplication)
它抛出一个错误
"表'db2.agencyapps'不存在"。
我可以在服务器控制台中看到它正在这两个表之间进行内部连接。
帮助将不胜感激。谢谢
不能跨数据库联接。您必须使用两个单独的查询:
var agencies = await _dbContextDemo1.Agencies.ToListAsync();
var agencyApps = await _dbContextDemo2.AgencyApps.Where(x => agencies.Select(a => a.Id).Contains(x.AgencyId)).ToListAsync();
注意:由于您选择了所有代理机构,因此从技术上讲,您也可以只选择所有代理机构应用程序,但是如果您最终也过滤了该集,则按所选机构的ID进行过滤效果会更好。
然后,可以将第二个查询中的数据映射到:
agencies.ForEach(x => x.AgencyApp = agencyApps.SingleOrDefault(a => a.AgencyId == x.Id));
不支持包含或联接来自不同上下文的表,因为 上下文可以连接到不同的数据库服务器。
不要使用不同的上下文,而是将实体添加到同一上下文中(为什么您甚至希望为它们使用两个不同的上下文?
public class DbContextDemo1: DbContext
{
public DbSet<Agency> Agencies { get; set; }
public DbSet<AgencyApp> AgencyApps { get; set; }
public DbContextDemo1(DbContextOptions<DbContextDemo1> options)
: base(options)
{
}
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.HasDefaultSchema("db1")
.Entity<Agency>()
.ToTable("agencies")
.HasKey(agency => agency.Id)
.HasOne(agency => agency.AgencyApp)
.WithOne(app => app.Agency)
.HasForeignKey<Agency>(agency => agency.Id);
modelBuilder.HasDefaultSchema("db1")
.Entity<AgencyApp>()
.ToTable("agenciesapps")
.HasKey(app => app .Id)
.HasOne(app=> app.Agency)
.WithOne(agency => agency.AgencyApp)
.HasForeignKey<AgencyApp>(app=> app.AgencyId);
}
}
如果你真的需要将它们放在两个不同的上下文中,那么你需要将所有实体获取到内存,然后将它们连接在一起(这不是一个好主意,因为您需要将所有机构获取到内存中(
var agencies = _dbContextDemo1.Agencies.ToList();
foreach(var agency in agencies)
{
agency.AgencyApps = _dbContextDemo2.AgencyApps.FirstOrDefault(a=> a.AgencyId == agency.Id);
}