向 NHibernate 标准添加投影会阻止其执行默认实体选择

Question

我正在编写一个 NHibernate 标准，用于选择支持分页的数据。我使用 SQL Server 2005(+) 中的

COUNT(*) OVER()

表达式来获取可用行的总数，如 Ayende Rahien 建议。我需要这个数字才能计算出总共有多少页。该解决方案的优点在于我不需要执行第二个查询来获取行计数。

但是，我似乎无法编写工作条件（Ayende 只提供 HQL 查询）。

这是一个 SQL 查询，它显示了我想要的内容，并且运行得很好。请注意，我故意省略了实际的分页逻辑以关注问题：

SELECT Items.*, COUNT(*) OVER() AS rowcount
FROM Items

这是 HQL：

select
    item, rowcount()
from 
    Item item

请注意，

rowcount()

函数是在自定义 NHibernate 方言中注册的，并在 SQL 中解析为

COUNT(*) OVER()

。

要求是使用条件来表达查询。不幸的是，我不知道如何做对：

var query = Session
    .CreateCriteria<Item>("item")
    .SetProjection(
       Projections.SqlFunction("rowcount", NHibernateUtil.Int32));

每当我添加投影时，NHibernate 都不会选择

item

（就像没有投影时一样），而只选择

rowcount()

，而我确实需要两者。另外，我似乎无法将

item

作为一个整体来投影，只能投影它的属性，我真的不想列出所有这些。

我希望有人能解决这个问题。不管怎样，谢谢。

Answer 1

我认为这在 Criteria 中是不可能的，它有一些限制。

您可以在后续查询中获取 id 并加载项目：

var query = Session
    .CreateCriteria<Item>("item")
    .SetProjection(Projections.ProjectionList()
       .Add(Projections.SqlFunction("rowcount", NHibernateUtil.Int32))
       .Add(Projections.Id()));

如果你不喜欢它，请使用HQL，你也可以在那里设置最大结果数：

IList<Item> result = Session
    .CreateQuery("select item, rowcount() from item where ..." )
    .SetMaxResult(100)
    .List<Item>();

Answer 2

使用 CreateMultiCriteria。

这样，您只需对数据库进行一次点击就可以执行 2 个简单的语句。

Answer 3

我想知道为什么需要使用 Criteria。你不能使用session.CreateSQLQuery吗？如果您确实必须在一个查询中执行此操作，我建议撤回 Item 对象和计数，例如：

select {item.*}, count(*) over() 
from Item {item}

...这样您就可以从查询中获取 Item 对象以及计数。如果您遇到 Hibernate 缓存问题，您还可以配置与本机查询关联的查询空间（实体/表缓存），以便自动清除过时的查询缓存条目。

Answer 4

如果我正确理解你的问题，我就有一个解决方案。 我在同样的问题上挣扎了很多。

让我快速描述一下我遇到的问题，以确保我们意见一致。 我的问题归结为分页。 我想在 UI 中显示 10 条记录，但我还想知道与过滤条件匹配的记录的total 数。 我想使用 NH criteria API 来完成此任务，但是当添加行数投影时，我的查询不再起作用，并且我不会得到任何结果（我不记得具体的错误，但听起来像你的正在得到）。

这是我的解决方案（从我当前的生产代码复制并粘贴）。 请注意，“SessionError”是我正在检索分页数据的业务实体的名称，根据 3 个过滤条件：IsDev、IsRead 和 IsResolved。

ICriteria crit = CurrentSession.CreateCriteria(typeof (SessionError))
    .Add(Restrictions.Eq("WebApp", this));

if (isDev.HasValue)
    crit.Add(Restrictions.Eq("IsDev", isDev.Value));

if (isRead.HasValue)
    crit.Add(Restrictions.Eq("IsRead", isRead.Value));

if (isResolved.HasValue)
    crit.Add(Restrictions.Eq("IsResolved", isResolved.Value));

// Order by most recent
crit.AddOrder(Order.Desc("DateCreated"));

// Copy the ICriteria query to get a row count as well
ICriteria critCount = CriteriaTransformer.Clone(crit)
    .SetProjection(Projections.RowCountInt64());
critCount.Orders.Clear();

// NOW add the paging vars to the original query
crit = crit
    .SetMaxResults(pageSize)
    .SetFirstResult(pageNum_oneBased * pageSize);

// Set up a multi criteria to get your data in a single trip to the database
IMultiCriteria multCrit = CurrentSession.CreateMultiCriteria()
    .Add(crit)
    .Add(critCount);

// Get the results
IList results = multCrit.List();

List<SessionError> sessionErrors = new List<SessionError>();
foreach (SessionError sessErr in ((IList)results[0]))
    sessionErrors.Add(sessErr);

numResults = (long)((IList)results[1])[0];

因此，我创建了我的基本标准，并带有可选的限制。 然后我对其进行克隆，并将行计数投影添加到克隆条件中。 请注意，我在添加分页限制之前克隆了它。 然后，我设置一个 IMultiCriteria 来包含原始和克隆的 ICriteria 对象，并使用 IMultiCriteria 执行它们。 现在我有了来自原始 ICriteria 的分页数据（并且我只通过网络拖动了我需要的数据），以及有多少实际记录符合我的条件的原始计数（对于显示或创建分页链接等有用）。 这个策略对我来说效果很好。 我希望这有帮助。

Answer 5

Answer 6

<property name="TotalRecords" formula="count(*) over()" type="Int32" not-null="true"/>;

IList<...> result = criteria.SetFirstResult(skip).SetMaxResults(take).List<...>();
totalRecords = (result != null && result.Count > 0) ? result[0].TotalRecords : 0;
return result;