0

我正在尝试使用 Castle ActiveRecord 删除表中的所有行。通常，我会这样做：

DB.ParseError.DeleteAll();

然而，这个表恰好有大约 190 万行。上面的命令将做的是为表中的每一行发出一个单独的SELECT和DELETE，看起来像这样：

SELECT page0_.Id as Id29_0_, ... FROM Indexer.Pages page0_ WHERE page0_.Id=:p0;:p0 = b03665aa-37d0-4a2d-a04c-c232ebd94dbc [Type: Guid (0)]
SELECT page0_.Id as Id29_0_, ... FROM Indexer.Pages page0_ WHERE page0_.Id=:p0;:p0 = 11cb69e3-1c6a-4ac1-908b-084dfe859639 [Type: Guid (0)]
--- 1.9 million more of these
DELETE FROM Indexer.ParseErrors WHERE Id = :p0;:p0 = b03665aa-37d0-4a2d-a04c-c232ebd94dbc [Type: Guid (0)]
DELETE FROM Indexer.ParseErrors WHERE Id = :p0;:p0 = 11cb69e3-1c6a-4ac1-908b-084dfe859639 [Type: Guid (0)]
--- 1.9 million more of these

这需要......好吧，我不知道需要多长时间，因为我没有耐心让它真正完成。

我想要它做的是发出一条 SQL 语句；这个：

DELETE FROM Indexer.ParseErrors;

这是我到目前为止所尝试的：

ISessionFactoryHolder holder = ActiveRecordMediator.GetSessionFactoryHolder();
ISession session = holder.CreateSession(typeof(DB.ParseError));
IDbCommand cmd = session.Connection.CreateCommand();
cmd.CommandType = CommandType.Text;
cmd.CommandText = "DELETE FROM Indexer.ParseErrors;";
cmd.CommandTimeout = 600;
cmd.ExecuteNonQuery();
holder.ReleaseSession(session);

这似乎可行，但对我来说似乎是一种 hack，因为它完全避免了模型和 ActiveRecord 框架。另外，这可能不适用于 NHibernate 的任何缓存。

有没有更正式的方法来删除一个表，而不是每行执行 2 条 SQL 语句？

4

4 回答 4

3

对于具有这么多记录的表，您绝对不希望它为每一行创建一个实体然后将其删除——这将花费很长时间。

如果您的映射中没有定义任何未在数据库中强制执行的级联规则，那么最简单的方法是使用 SQL 查询：

ActiveRecordBase<ParseError>.Execute(
    (s, i) => s.CreateSQLQuery("DELETE FROM ParseErrors").ExecuteUpdate(),
                                           null);

这将使 NHibernate 缓存无效（因此它将与 NHibernate 二级缓存很好地配合使用），但它不会执行任何未在 db 中定义的级联（我怀疑这对您的情况很好）。如果数据库中没有任何级联，那么您必须手动执行它们。

如果您真的希望它使用要删除的实体，那么至少使用 StatelessSessionScope 这将阻止它至少将所有实体添加到会话中。

更新：

该Execute()方法是 的受保护成员ActiveRecordBase<T>，因此要从类外部调用它，您必须将其包装在公共静态方法中。

于 2012-06-14T09:27:49.833 回答
1

您可以使用 nHibernate 使用以下语句从表中删除所有记录。取决于级联规则。您可能必须先清除另一个表。

session.Delete("from Indexer.ParseErrors p");

使用完整链接

于 2012-06-14T05:45:11.117 回答
1

每次我过去处理这个问题时，我都做了类似的事情：

session.CreateSQLQuery("DELETE FROM FOO").ExecuteUpdate();

是的，它绕过了各种各样的东西，但我从来没有遇到过问题。

Ayende 有一篇关于此的帖子，它使用批量复制来执行此操作，但似乎没有解决您对缓存的担忧。

于 2012-06-14T15:04:56.807 回答
0

你好迈克克里斯滕森，

是的，有一种方法。这不是一个好方法（我认为），但它比普通 SQL 更好：

session.CreateQuery(@"UPDATE " + typeof(?).FullName + " SET Property = :value")
       .SetParameter("value",valueVariable)
       .ExecuteUpdate();

NHibernate 中的批量更新

问候 Juy Juka

于 2012-06-14T14:37:05.023 回答