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

Question

使用 Entity Framework 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); 

是否有可能以某种方式从“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，然后将其添加到新的上下文数据库集。此示例不处理关联实体，或从 prod 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();
    }
}