Entity Framework Core 6中多对多实体关系的正确更新方式

实体类定义 #

public class Book
{
    public int Id { get; set; }
    public string Name{ get; set; }
    public string ISBN { get; set; }

    public ICollection<Category> Categories { get; set; }
}

public class Category
{
    public int Id { get; set; }
    public string Name{ get; set; }
    public ICollection<Book> Books { get; set; }
}

问题说明 #

使用EF Core 6 + .NET 6更新指定Book的Categories时，遇到两个问题：

• 旧分类未被删除（如原有.NET、C#分类，更新后C#仍保留）
• 保留现有分类（如.NET）时触发Duplicate Error Key重复键错误

无需显式连接实体的正确更新方式 #

EF Core 6支持无显式连接实体的多对多关系，但更新时不能直接覆盖集合，需手动同步关联状态：

1. 加载目标书籍及已关联分类
   必须通过Include加载现有关联，确保EF跟踪实体状态：

   var book = await _context.Books
       .Include(b => b.Categories)
       .FirstOrDefaultAsync(b => b.Id == bookId);
   

2. 移除不需要的旧分类
   对比新分类列表，筛选并移除不再需要的关联：

   // 假设newCategoryNames是目标分类名称集合：{ ".NET", "EF Core", "SqlServer" }
   var categoriesToRemove = book.Categories
       .Where(c => !newCategoryNames.Contains(c.Name))
       .ToList();
   
   foreach (var category in categoriesToRemove)
   {
       book.Categories.Remove(category);
   }
   

3. 添加新分类（避免重复）
   先从数据库查询目标分类，再将未关联的项加入集合：

   var targetCategories = await _context.Categories
       .Where(c => newCategoryNames.Contains(c.Name))
       .ToListAsync();
   
   foreach (var category in targetCategories)
   {
       if (!book.Categories.Any(c => c.Id == category.Id))
       {
           book.Categories.Add(category);
       }
   }
   

4. 保存更改

   await _context.SaveChangesAsync();
   

错误原因解析

• 旧分类未删除：直接覆盖book.Categories = newCategories时，EF无法跟踪集合的移除操作，不会自动删除数据库中的关联记录。
• 重复键错误：直接添加已关联的分类时，EF会尝试创建新的关联记录，导致数据库中出现重复的BookId-CategoryId组合。

是否需要添加连接实体？ #

不是必须的，但如果需要在多对多关联中存储额外属性（如关联创建时间），或需要更精细地控制关联操作，显式定义连接实体会更灵活：

示例连接实体与配置

// 连接实体
public class BookCategory
{
    public int BookId { get; set; }
    public Book Book { get; set; }
    public int CategoryId { get; set; }
    public Category Category { get; set; }
    // 可选额外属性：public DateTime CreatedAt { get; set; }
}

// DbContext配置
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.Entity<BookCategory>()
        .HasKey(bc => new { bc.BookId, bc.CategoryId });

    modelBuilder.Entity<BookCategory>()
        .HasOne(bc => bc.Book)
        .WithMany(b => b.BookCategories)
        .HasForeignKey(bc => bc.BookId);

    modelBuilder.Entity<BookCategory>()
        .HasOne(bc => bc.Category)
        .WithMany(c => c.BookCategories)
        .HasForeignKey(bc => bc.CategoryId);
}

基于连接实体的更新方式

var book = await _context.Books
    .Include(b => b.BookCategories)
    .FirstOrDefaultAsync(b => b.Id == bookId);

// 删除旧关联
book.BookCategories.RemoveAll(bc => !targetCategoryIds.Contains(bc.CategoryId));

// 添加新关联
foreach (var categoryId in targetCategoryIds)
{
    if (!book.BookCategories.Any(bc => bc.CategoryId == categoryId))
    {
        book.BookCategories.Add(new BookCategory { CategoryId = categoryId });
    }
}

await _context.SaveChangesAsync();

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