EF Core v7+：无导航属性时高效删除外键关联表数据

核心逻辑 #

因为遗留数据限制无法添加级联删除，必须保证先删ProductListing关联数据，再删Product主表数据，且全程用事务包裹确保操作原子性。最优方式是用单条关联SQL删除ProductListing，避免逐行操作拖慢百万级数据的处理性能。

具体实现方案 #

方案1：直接执行原生关联SQL（性能最优） #

利用EXISTS关联两张表，一次性删除符合条件的ProductListing数据，再批量删除Product表数据，全程在事务中执行。

代码示例

public async Task BatchDeleteProductsAsync(DateTime dateOf, string productCategory)
{
    using var transaction = await _dbContext.Database.BeginTransactionAsync();
    try
    {
        // 第一步：删除关联的ProductListing数据
        var deleteListingSql = @"
            DELETE FROM ProductListing pl
            WHERE EXISTS (
                SELECT 1 FROM Product p
                WHERE p.Id = pl.ProductId
                AND p.DateOf = @DateOf
                AND p.ProductCategory = @ProductCategory
            )";
        await _dbContext.Database.ExecuteSqlRawAsync(
            deleteListingSql,
            new SqlParameter("@DateOf", dateOf),
            new SqlParameter("@ProductCategory", productCategory)
        );

        // 第二步：删除Product主表数据
        await _dbContext.Products
            .Where(p => p.DateOf == dateOf && p.ProductCategory == productCategory)
            .ExecuteDeleteAsync();

        await transaction.CommitAsync();
    }
    catch
    {
        await transaction.RollbackAsync();
        throw;
    }
}

方案2：用EF Core原生批量删除API（避免写原生SQL） #

如果不想直接写SQL，可以先查询符合条件的ProductId集合（仅取ID避免加载完整实体），再批量删除ProductListing：

代码示例

public async Task BatchDeleteProductsAsync(DateTime dateOf, string productCategory)
{
    using var transaction = await _dbContext.Database.BeginTransactionAsync();
    try
    {
        // 获取符合条件的ProductId（不加载完整实体）
        var productIds = await _dbContext.Products
            .Where(p => p.DateOf == dateOf && p.ProductCategory == productCategory)
            .Select(p => p.Id)
            .ToListAsync();

        // 批量删除ProductListing
        await _dbContext.ProductListings
            .Where(pl => productIds.Contains(pl.ProductId))
            .ExecuteDeleteAsync();

        // 删除Product主表数据
        await _dbContext.Products
            .Where(p => p.DateOf == dateOf && p.ProductCategory == productCategory)
            .ExecuteDeleteAsync();

        await transaction.CommitAsync();
    }
    catch
    {
        await transaction.RollbackAsync();
        throw;
    }
}

性能优化关键点 #

• 给Product表的DateOf + ProductCategory组合创建联合索引，加速主表查询和删除操作。
• 确保ProductListing表的ProductId字段有外键索引，提升关联删除的查询效率。
• 禁止使用RemoveRange（会先将实体加载到内存，百万级数据极易引发内存溢出），必须用ExecuteDeleteAsync或原生SQL的批量删除方式。

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