如何在EF Core中按AdvertId批量删除数据库记录？（CQRS+Repository架构）

问题核心 #

现有代码存在3处核心错误导致无法完成按AdvertId批量删除的需求：

• 查询返回的mapped是符合过滤条件的实体集合，现有代码直接将集合强转为单个实体，必然触发类型转换异常
• DeleteAllAsync接口定义与实现逻辑不匹配批量删除场景：入参为单个实体，内部也仅处理单条删除逻辑，完全不支持批量操作
• EF Core单实体删除方法Remove无法处理集合入参，需要替换为批量删除方法

修复方案 #

1. 修正IRepository接口定义 #

将原本的单实体入参删除方法，调整为支持集合入参的批量删除接口：

// 替换原有DeleteAllAsync定义
Task<IEnumerable<T>> DeleteAllAsync(IEnumerable<T> entities);

2. 修正Repository实现 #

替换单实体删除逻辑为批量删除逻辑：

public async Task<IEnumerable<T>> DeleteAllAsync(IEnumerable<T> entities)
{
    // EF Core内置RemoveRange会自动标记所有传入实体为待删除状态
    Context.Set<T>().RemoveRange(entities);
    await Context.SaveChangesAsync();
    return entities;
}

3. 修正Handler调用逻辑 #

修复类型转换错误，直接传入查询到的实体集合：

public async Task<ApiResponse> Handle(Advert_CategoryPropertyDetailJunctionDelete 
request, CancellationToken cancellationToken)
{
    var mapped = await 
    _repo.AdvertCategoryPropertyDetailJunctions.GetAllAsync(request.predicate);

    // 新增集合非空校验，避免空集合传入删除方法
    if (mapped == null || !mapped.Any())
        return new ErrorApiResponse(ResultMessage.NotDeletedUser);

    // 直接传入集合，无需强制类型转换
    await _repo.AdvertCategoryPropertyDetailJunctions.DeleteAllAsync(mapped);

    return new SuccessApiResponse();
}

可选性能优化 #

如果待删除数据量较大，无需先查询到内存再删除，可以直接新增按条件批量删除的Repository方法，减少一次数据库查询：

// IRepository新增定义
Task<int> DeleteByPredicateAsync(Expression<Func<T, bool>> predicate);

// Repository实现
public async Task<int> DeleteByPredicateAsync(Expression<Func<T, bool>> predicate)
{
    return await Context.Set<T>().Where(predicate).ExecuteDeleteAsync();
}

Handler中可直接调用该方法，省略查询步骤即可完成批量删除。

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