实体框架 (MySQL) - 使用两个数据库上下文将数据从一个数据库移动到另一个数据库

Question

使用实体框架6和MySQL，我正在尝试将数据从"生产"数据库表存档到"存档"数据库。我已经为每个数据库创建了两个DBContext。每个数据库具有相同的架构。

我可以使用以下代码将整个数据表从生产数据库移动到存档数据库：

using (MyDBContext archiveContext = 
MyDBContext.CreateEntitiesForSpecificDatabaseName("archive_db"))
using (MyDBContext prodContext = 
MyDBContext.CreateEntitiesForSpecificDatabaseName("prod_db"))
{
if(prodContext.myTable.Any())
{
archiveContext.myTable.AddRange(prodContext.myTable.AsNoTracking());
archiveContext.SaveChanges();
}  
}

但是我不想存档整个表，我只想存档早于某个日期的数据，所以我尝试了以下方法：

using (MyDBContext archiveContext = 
MyDBContext.CreateEntitiesForSpecificDatabaseName("archive_db"))
using (MyDBContext prodContext = 
MyDBContext.CreateEntitiesForSpecificDatabaseName("prod_db"))
{
IQueryable<myTable> dataToArchive =
from mt in prodContext.myTable
where mt.date < DateTimeSixMonths
select mt;
archiveContext.myTable.AddRange(dataToArchive);
archiveContext.SaveChanges();
}       

但是我无法绕过运行此内容时遇到的异常：

System.InvalidOperationException： '实体对象不能 被IEntityChangeTracker的多个实例引用。

它发生在以下行上：

archiveContext.myTable.AddRange(dataToArchive); 

是否有可能以某种方式从"数据存档"中删除跟踪

Answer 1

您是否尝试过在检索数据后释放第一个 DataContext？像这样：

List<myTable> dataToArchive;
using (MyDBContext prodContext = 
MyDBContext.CreateEntitiesForSpecificDatabaseName("prod_db"))
{
dataToArchive = (from mt in prodContext.myTable
where mt.date < DateTimeSixMonths
select mt).ToList();
}
using (MyDBContext archiveContext = 
MyDBContext.CreateEntitiesForSpecificDatabaseName("archive_db"))
{
archiveContext.myTable.AddRange(dataToArchive);
archiveContext.SaveChanges();
}

Answer 2

使用EF 管理存档数据并不理想，最好在数据库级别使用插入选择 + 删除来处理可在数据库之间移动的低到中等数据量或可拆卸分区(即 3-6 个月分区大小(。

若要使用 EF(仅建议用于小型和非复杂域模型(执行此操作，您应该能够通过在读取上下文中禁用代理生成、加载数据AsNoTracking，然后将其添加到新上下文 DbSet 来实现此目的。此示例不处理关联的实体，也不执行从生产 DbSet 中删除的操作。

using (MyDBContext prodContext = 
MyDBContext.CreateEntitiesForSpecificDatabaseName("prod_db"))
{
prodContext.Configuration.ProxyCreationEnabled = false;
dataToArchive = prodContext.myTable.AsNoTracking()
.Where(mt => mt.Date < DateTimeSixMonths);

using (MyDBContext archiveContext = 
MyDBContext.CreateEntitiesForSpecificDatabaseName("archive_db"))
{
archiveContext.myTable.AddRange(dataToArchive);
archiveContext.SaveChanges();
}
}