EF Core中导航属性更新时无法删除关联数据的问题

我有一个Employee实体定义如下：

public class Employee 
{
    public long Id { get; set; }
    public string EmployeeNumber { get; set; }

    [ForeignKey("EmployeesId")]
    public List<PrisonsLkpt> Prisons { get; set; }  

    // 其他无关属性   
}

新增实体时，关联4条Prisons数据可以正常插入；但更新时，从Prisons列表中移除2条数据后，数据库里的关联集合并没有删除这2条，不过新增1条数据却能正常添加。以下是实体的创建/更新代码：

public async Task<BaseOutputDto> CreateOrEditEmployee(CreateUpdateEmployeeInputDto input)
{
    BaseOutputDto response = new BaseOutputDto();
    CreateEditChecks(input, true);
    var prisons = await _prisonsLkptRepo.GetAllListAsync(x => input.PrisonIds.Contains(x.Id));
    try
    {
        Employee employee = _objectMapper.Map<Employee>(input);
        employee.Prisons = prisons;

        if (input.Id != 0)
        {
            await _employeeRepo.UpdateAsync(employee);
        }
        else
        {
            await _employeeRepo.InsertAsync(employee);
        }     

        response.IsSuccessful = true;
        return response;
    }
    catch (Exception ex)
    {
        response.IsSuccessful = false;
        throw new UserFriendlyException(ex.InnerException == null ? ex.Message : ex.InnerException.Message);
    }
}

原因分析 #

更新逻辑存在核心问题：直接通过对象映射创建新的Employee实例，赋值关联集合后调用UpdateAsync，这种方式下EF Core无法跟踪原实体的关联集合变化，只会更新主实体的标量属性，不会处理关联集合的删除操作。

解决方法 #

需要先从数据库获取已被EF Core跟踪的原实体，再手动更新关联集合，让EF Core感知到集合的增减变化：

public async Task<BaseOutputDto> CreateOrEditEmployee(CreateUpdateEmployeeInputDto input)
{
    BaseOutputDto response = new BaseOutputDto();
    CreateEditChecks(input, true);
    var prisons = await _prisonsLkptRepo.GetAllListAsync(x => input.PrisonIds.Contains(x.Id));
    try
    {
        Employee employee;
        if (input.Id != 0)
        {
            // 获取数据库中已存在的实体，并加载关联的Prisons集合（确保EF Core跟踪该实例）
            employee = await _employeeRepo.GetAsync(input.Id, include: e => e.Include(e => e.Prisons));
            // 将输入的标量属性映射到原实体
            _objectMapper.Map(input, employee);
            
            // 移除不在新关联列表中的项
            var prisonsToRemove = employee.Prisons.Where(p => !input.PrisonIds.Contains(p.Id)).ToList();
            foreach (var prison in prisonsToRemove)
            {
                employee.Prisons.Remove(prison);
            }
            
            // 添加新的关联项（避免重复添加已存在的项）
            var existingPrisonIds = employee.Prisons.Select(p => p.Id).ToList();
            var prisonsToAdd = prisons.Where(p => !existingPrisonIds.Contains(p.Id)).ToList();
            foreach (var prison in prisonsToAdd)
            {
                employee.Prisons.Add(prison);
            }
            
            await _employeeRepo.UpdateAsync(employee);
        }
        else
        {
            employee = _objectMapper.Map<Employee>(input);
            employee.Prisons = prisons;
            await _employeeRepo.InsertAsync(employee);
        }     

        response.IsSuccessful = true;
        return response;
    }
    catch (Exception ex)
    {
        response.IsSuccessful = false;
        throw new UserFriendlyException(ex.InnerException == null ? ex.Message : ex.InnerException.Message);
    }
}

额外说明 #

• 必须通过Include加载原实体的Prisons集合，否则EF Core无法知晓原关联项的情况，无法处理删除操作。
• 若使用EF Core 5及以上版本，也可利用ChangeTracker或批量更新方法简化操作，但核心逻辑都是让EF Core跟踪原实体的集合变化。

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