在同步系统场景下，如何用Entity Framework Core插入父实体并更新嵌套子实体？

针对你的同步场景，我来梳理一套可行的方案，核心要解决EF Core的实体关系配置、Detached实体的状态管理，还有从NoSQL读取后的实体同步逻辑：

1. 先完善实体类与EF关系配置 #

首先你的原实体类缺少主键和外键属性，这会导致EF Core处理关系时出现歧义，建议先补全：

public class Company {
    // 建议加自增主键（或Guid），作为唯一标识
    public int Id { get; set; } 
    public string Name { get; set; }
    // 初始化集合避免null引用
    public HashSet<Worker> Workers { get; set; } = new HashSet<Worker>(); 
}

public class Worker {
    public int Id { get; set; }
    public string LastName { get; set; }
    // 显式外键，EF处理关系更高效
    public int CompanyId { get; set; } 
    public Company Company { get; set; }
}

然后在DbContext的OnModelCreating里配置一对多关系，明确导航属性和外键：

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.Entity<Company>()
        .HasMany(c => c.Workers)
        .WithOne(w => w.Company)
        .HasForeignKey(w => w.CompanyId)
        .OnDelete(DeleteBehavior.Cascade); // 根据业务需求选择删除行为，比如Restrict

    // 可选：给Company.Name加唯一约束，避免重复
    modelBuilder.Entity<Company>()
        .HasIndex(c => c.Name)
        .IsUnique();

    // 可选：给Worker.LastName+CompanyId加唯一约束，避免同公司下重名员工
    modelBuilder.Entity<Worker>()
        .HasIndex(w => new { w.LastName, w.CompanyId })
        .IsUnique();
}

2. 核心同步逻辑：处理从NoSQL读取的实体 #

从NoSQL读取并反序列化后的实体是Detached状态（EF没有跟踪它们的存在），所以需要先判断每个实体是新增还是已存在，再分别处理：

示例同步方法 #

public async Task SyncCompanyAsync(Company companyFromNoSql)
{
    using var dbContext = new YourDbContext();

    // 1. 查找数据库中是否已存在该Company（用主键Id判断最可靠）
    var existingCompany = await dbContext.Companies
        .Include(c => c.Workers) // 加载关联的Worker，方便后续对比
        .FirstOrDefaultAsync(c => c.Id == companyFromNoSql.Id);

    if (existingCompany == null)
    {
        // 新增Company：直接添加，EF会自动关联并插入子实体Worker
        dbContext.Companies.Add(companyFromNoSql);
    }
    else
    {
        // 更新Company的基础属性
        dbContext.Entry(existingCompany).CurrentValues.SetValues(companyFromNoSql);
        
        // 同步Worker的新增、更新、删除（根据业务需求调整）
        SyncWorkers(existingCompany.Workers, companyFromNoSql.Workers, existingCompany, dbContext);
    }

    // 提交所有变更
    await dbContext.SaveChangesAsync();
}

private void SyncWorkers(HashSet<Worker> existingWorkers, 
                         HashSet<Worker> incomingWorkers, 
                         Company parentCompany, 
                         YourDbContext dbContext)
{
    // 处理新增和更新的Worker
    foreach (var incomingWorker in incomingWorkers)
    {
        // 关联到当前的Company实例，避免EF误判为新Company
        incomingWorker.Company = parentCompany;
        incomingWorker.CompanyId = parentCompany.Id;

        // 查找是否已存在该Worker（用主键或唯一约束判断）
        var existingWorker = existingWorkers.FirstOrDefault(w => w.Id == incomingWorker.Id);

        if (existingWorker == null)
        {
            // 新增Worker
            existingWorkers.Add(incomingWorker);
        }
        else
        {
            // 更新Worker的属性
            dbContext.Entry(existingWorker).CurrentValues.SetValues(incomingWorker);
        }
    }

    // 处理需要删除的Worker（如果业务要求同步删除不在 incoming 中的记录）
    var workersToRemove = existingWorkers
        .Where(w => !incomingWorkers.Any(iw => iw.Id == w.Id))
        .ToList();

    foreach (var worker in workersToRemove)
    {
        existingWorkers.Remove(worker);
        dbContext.Workers.Remove(worker);
    }
}

3. 注意JSON反序列化的循环引用问题 #

因为你的实体是双向导航（Company包含Workers，Worker包含Company），JSON序列化/反序列化时会出现循环引用错误，需要配置序列化器忽略循环：

用System.Text.Json的配置 #

var jsonOptions = new JsonSerializerOptions
{
    ReferenceHandler = ReferenceHandler.IgnoreCycles,
    PropertyNameCaseInsensitive = true // 兼容客户端的大小写
};
var companyFromNoSql = JsonSerializer.Deserialize<Company>(jsonStringFromNoSql, jsonOptions);

用Newtonsoft.Json的配置 #

var jsonSettings = new JsonSerializerSettings
{
    ReferenceLoopHandling = ReferenceLoopHandling.Ignore
};
var companyFromNoSql = JsonConvert.DeserializeObject<Company>(jsonStringFromNoSql, jsonSettings);

4. 批量同步的优化建议 #

如果你的同步系统需要处理大量数据，建议：

• 批量从NoSQL读取记录，比如每次取500条，分批处理
• 每批处理完后调用SaveChangesAsync，然后新建DbContext（避免上下文跟踪过多实体导致性能下降）
• 若性能要求极高，可以使用EF Core的第三方批量操作库（比如EFCore.BulkExtensions）来批量插入/更新

内容的提问来源于stack exchange，提问作者MiDaa