Entity Framework Core中多对多关系的帖子更新异常问题

定义的实体类 #

基类BaseEntity #

/// <summary>
/// Base entity
/// </summary>
[Index("Uid", IsUnique = true)]
public abstract class BaseEntity
{
    [Key, DatabaseGenerated(DatabaseGeneratedOption.Identity)]
    public virtual int Id { get; set; }

    [Required]
    public virtual Guid Uid { get; set; } = Guid.NewGuid();
}

Post实体 #

public class Post : BaseEntity
{
    [MaxLength(100), MinLength(5)]
    public required string Title { get; set; }
    [MaxLength(3000), MinLength(50)]
    public required string Text { get; set; }
    public required DateTime Date { get; set; } = DateTime.Now;
    public required bool IsAnonymous { get; set; } = false;

    public Guid UserId { get; set; }
    public virtual User User { get; set; }

    public PostCount PostCount { get; set; } = null!;
    public virtual ICollection<Comment>? Comments { get; set; }
    public virtual ICollection<Topic> Topics { get; set; }
    public virtual ICollection<Like> Likes { get; set; }
}

Topic实体 #

public class Topic : BaseEntity
{
    public string Type { get; set; } = string.Empty;
    public virtual ICollection<User> Users { get; set; }
    public virtual ICollection<Post> Posts { get; set; }
}

实体配置 #

public static void ConfigureTopics(this ModelBuilder modelBuilder)
{
    modelBuilder.Entity<Topic>().ToTable("Topics");
    modelBuilder.Entity<Topic>().Property(x => x.Type).IsRequired();
    modelBuilder.Entity<Topic>().HasMany(x => x.Posts)
        .WithMany(x => x.Topics)
        .UsingEntity(t => t.ToTable("PostsTopics"));
}

正常工作的创建帖子方法 #

public async Task<PostModel> Create(CreatePostModel model, Guid userId)
{
    try
    {
        await _createValidator.CheckAsync(model);

        await using var context = await _dbContextFactory.CreateDbContextAsync();
    
        // Create a new Post entity
        var post = _mapper.Map<Post>(model);

        if (post.Date.Kind == DateTimeKind.Local)
            post.Date = post.Date.ToUniversalTime();

        // Create a new PostCount entity
        var postCount = new PostCount
        {
            Post = post
        };

        // Associate the Post and PostCount entities
        post.PostCount = postCount;

        post.UserId = userId;

        // Fetch existing topics by Uid
        post.Topics = await context.Topics
            .Where(t => model.Topics.Contains(t.Uid))
            .ToListAsync();
    
        context.AttachRange(post.Topics);
    
        // Add the entities to the context
        await context.Posts.AddAsync(post);
        await context.PostCounts.AddAsync(postCount);

        // Save changes to the database
        await context.SaveChangesAsync();
        
        post.User = await context.Users.FirstAsync(u => u.Id == userId);
    
        var createdPost = _mapper.Map<PostModel>(post);
    
        return createdPost;
    }
    catch (Exception e)
    {
        _logger.Error($"Error creating post. Error message: {e.Message}");
        throw;
    }
}

数据库表结构（PostsTopics） #

-- auto-generated definition
create table "PostsTopics"
(
    "PostsId"  integer not null
        constraint "FK_PostsTopics_Posts_PostsId"
            references "Posts"
            on delete cascade,
    "TopicsId" integer not null
        constraint "FK_PostsTopics_Topics_TopicsId"
            references "Topics"
            on delete cascade,
    constraint "PK_PostsTopics"
        primary key ("PostsId", "TopicsId");

alter table "PostsTopics"
    owner to postgres;

create index "IX_PostsTopics_TopicsId"
    on "PostsTopics" ("TopicsId");

更新方法的问题 #

更新帖子时，EF Core无法从PostsTopics表移除旧主题，触发如下错误：

Microsoft.EntityFrameworkCore.DbUpdateException: An error occurred while saving the entity changes. See the inner exception for details.
welisten_api-1 | ---> Npgsql.PostgresException (0x80004005): 23505: duplicate key value violates unique constraint "PK_PostsTopics"

即使传入空主题列表，帖子其他属性可正常更新，但旧主题仍保留在关联表中。当前更新方法代码：

public async Task Update(Guid id, Guid userId, UpdatePostModel model)
{
    try
    {
        await _updateValidator.CheckAsync(model);

        await using var context = await _dbContextFactory.CreateDbContextAsync();

        var post = await context.Posts
            .Include(x => x.User)
            .Include(x => x.PostCount)
            .Include(x => x.Topics)
            .FirstOrDefaultAsync(x => x.Uid == id);

        if (post == null)
            throw new ProcessException($"Post with ID: {id} not found");

        if (post.UserId != userId)
            throw new AuthenticationException("Authentication failed");

        context.Entry(post).State = EntityState.Modified;
        
        // Clear existing topics
        post.Topics.Clear();

        // Update other properties of the post
        post.Title = model.Title;
        post.Text = model.Text;
        post.IsAnonymous = model.IsAnonymous;
        
        // Update topics
        post.Topics = await context.Topics
            .Where(t => model.Topics.Contains(t.Uid))
            .ToListAsync();
        
        context.AttachRange(post.Topics);
        
        // Save changes again to update the many-to-many relationship
        await context.SaveChangesAsync();
    }
    catch (Exception e)
    {
        _logger.Error($"Error updating post with ID: {id}. Error message: {e.Message}");
        throw;
    }
}

问题原因与修复方案 #

问题根源 #

直接给post.Topics赋值新集合会覆盖原集合引用，导致EF Core失去对原集合变更的追踪——之前执行的Clear()操作不会被识别，旧关联记录不会被删除；如果新主题和旧主题重复，就会触发唯一约束冲突。

修复后的更新方法 #

不要替换整个集合，而是在原集合实例上执行清空、添加操作：

public async Task Update(Guid id, Guid userId, UpdatePostModel model)
{
    try
    {
        await _updateValidator.CheckAsync(model);

        await using var context = await _dbContextFactory.CreateDbContextAsync();

        var post = await context.Posts
            .Include(x => x.User)
            .Include(x => x.PostCount)
            .Include(x => x.Topics)
            .FirstOrDefaultAsync(x => x.Uid == id);

        if (post == null)
            throw new ProcessException($"Post with ID: {id} not found");

        if (post.UserId != userId)
            throw new AuthenticationException("Authentication failed");

        // 更新帖子基础属性
        post.Title = model.Title;
        post.Text = model.Text;
        post.IsAnonymous = model.IsAnonymous;
        
        // 处理多对多关联：清空旧主题，再添加新主题
        post.Topics.Clear();
        if (model.Topics?.Any() == true)
        {
            var newTopics = await context.Topics
                .Where(t => model.Topics.Contains(t.Uid))
                .ToListAsync();
            foreach (var topic in newTopics)
            {
                post.Topics.Add(topic);
            }
        }

        await context.SaveChangesAsync();
    }
    catch (Exception e)
    {
        _logger.Error($"Error updating post with ID: {id}. Error message: {e.Message}");
        throw;
    }
}

补充说明 #

1. 移除了context.Entry(post).State = EntityState.Modified;：EF Core会自动追踪已加载实体的属性变更，无需手动标记
2. 移除了context.AttachRange(post.Topics);：从上下文查询出的主题已处于被追踪状态，无需手动附加
3. 保留原集合实例操作：EF Core通过集合的Add/Remove/Clear操作来识别多对多关系的变更，从而正确更新关联表

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