.net - EF 代码首先从 IQueryable 中删除批处理？

Question

我知道这在 LINQ-to-SQL 中是可能的，并且我看到的一些细节让我相信这在 EF 中是可能的。是否有一个扩展可以执行以下操作:

var peopleQuery = Context.People.Where(p => p.Name == "Jim");

peopleQuery.DeleteBatch();

其中 DeleteBatch 只是拆开 peopleQuery 并创建一个 SQL 语句来删除所有相应的记录，然后直接执行查询，而不是将所有这些实体标记为删除并让它逐一执行一。我以为我在下面的代码中找到了类似的内容，但它立即失败，因为实例无法转换为 ObjectSet。有谁知道如何修复此问题以与 EF Code First 一起使用？或者知道任何地方有这样做的例子吗？

public static IQueryable<T> DeleteBatch<T>(this IQueryable<T> instance) where T : class
{
    ObjectSet<T> query = instance as ObjectSet<T>;
    ObjectContext context = query.Context;

    string sqlClause = GetClause<T>(instance);
    context.ExecuteStoreCommand("DELETE {0}", sqlClause);

    return instance;
}

public static string GetClause<T>(this IQueryable<T> clause) where T : class
{
    string snippet = "FROM [dbo].[";

    string sql = ((ObjectQuery<T>)clause).ToTraceString();
    string sqlFirstPart = sql.Substring(sql.IndexOf(snippet));

    sqlFirstPart = sqlFirstPart.Replace("AS [Extent1]", "");
    sqlFirstPart = sqlFirstPart.Replace("[Extent1].", "");

    return sqlFirstPart;
}

Answer 1

Entity Framework 不支持批量操作。我喜欢代码解决问题的方式，但即使它完全符合您的要求(但对于 ObjectContext API)，这也是一个错误的解决方案。

为什么这是错误的解决方案？

它仅在某些情况下有效。它绝对不适用于实体映射到多个表(实体拆分、TPT 继承)的任何高级映射解决方案。我几乎可以肯定，您会发现另一种由于查询的复杂性而无法工作的情况。

它使上下文和数据库保持不一致。这是针对数据库执行的任何 SQL 都会遇到的问题，但在这种情况下，SQL 是隐藏的，使用您的代码的其他程序员可能会错过它。如果您删除同时加载到上下文实例的任何记录，该实体将不会被标记为已删除并从上下文中删除(除非您将该代码添加到您的 DeleteBatch 方法中 - 这将是如果删除的记录实际上映射到多个实体(表拆分)，则尤其复杂。

最重要的问题是 EF 生成的 SQL 查询的修改以及您对该查询所做的假设。您期望 EF 将查询中使用的第一个表命名为 Extent1。是的，它现在确实使用该名称，但它是内部 EF 实现。它可能会在 EF 的任何次要更新中发生更改。围绕任何 API 的内部构建自定义逻辑都被认为是一种不好的做法。

因此，您已经必须在 SQL 级别上使用查询，以便您可以直接调用 SQL 查询，如 @mreyeros 所示，并避免此解决方案中的风险。您将必须处理表和列的真实名称，但这是您可以控制的(您的映射可以定义它们)。

如果您认为这些风险并不严重，您可以对代码进行一些小更改以使其在 DbContext API 中工作:

public static class DbContextExtensions
{
    public static void DeleteBatch<T>(this DbContext context, IQueryable<T> query) where T : class
    {
        string sqlClause = GetClause<T>(query);
        context.Database.ExecuteSqlCommand(String.Format("DELETE {0}", sqlClause));
    }

    private static string GetClause<T>(IQueryable<T> clause) where T : class
    {
        string snippet = "FROM [dbo].[";

        string sql = clause.ToString();
        string sqlFirstPart = sql.Substring(sql.IndexOf(snippet));

        sqlFirstPart = sqlFirstPart.Replace("AS [Extent1]", "");
        sqlFirstPart = sqlFirstPart.Replace("[Extent1].", "");

        return sqlFirstPart;
    }
}

现在您将这样调用批量删除:

context.DeleteBatch(context.People.Where(p => p.Name == "Jim"));