1

我需要根据用户传入的一组日期将事件记录“批量”插入到数据库中。

我的事件实体有一个 StartTime 属性和一个 StopTime 属性。Event 实体是我的应用程序中的核心实体，因此有许多与之关联的集合和实体引用。这是一个沉重的实体。

所以，我的原始代码让我遍历日期并执行以下操作：

 Session.Save(new Event {StartTime=startdate, StopTime=endDate});

然而，这并没有很好地扩展，我们在插入几百个日期时感受到了性能。

所以我想到了将所有日期插入临时表，但我不知道如何使用 HQL 来完成。

所以我的下一个想法是将所有日期作为子查询包含在内，这让我最接近。这是这种方法：

var hql = "INSERT INTO Event (Code, Comment, Description, Status, StartTime, StopTime)
           SELECT ev.Code, ev.Comment, ev.Description, ev.Status, Dates.SDate, Dates.EDate
           FROM Event ev, 
                (
                    SELECT '1/2/2012 3:00:00 PM' as SDate, '1/2/2012 6:00:00 PM' as EDate
                    UNION ALL SELECT '1/3/2012 3:00:00 PM', '1/3/2012 6:00:00 PM' 
                    UNION ALL SELECT '1/4/2012 3:00:00 PM', '1/4/2012 6:00:00 PM'
                ) as Dates
           WHERE ev.Id = :sourceEventId";

Session.CreateQuery(hql).SetInt32("sourceEventId", @event.Id).ExecuteUpdate();

但是 hql 以非常模糊的错误代码失败。我在网上的研究告诉我，hql 还不支持 UNION 子句。

现在，我将这种方法重写为 SQL 并通过 Session.CreateSQLQuery() 执行它，效果很好。但我不想将它作为 SQL 运行。无论如何，这违背了使用 NHibernate 的目的。

有没有另一种方法可以使用 HQL（或任何其他 NHibernate 技术）来解决这个问题？

非常感谢这里的任何帮助！

更新

  1. 我忘了提到这是一个遗留的 SQL Server 数据库（我在 sqlite 上运行单元测试），并且所有实体都使用 SQL 的 Identity 列生成它们的 ID。所以任何批处理的尝试都会失败。

  2. 正如我在下面的评论中解释的那样，我也尝试了无状态会话方法。NHibernate 将无法告诉我我需要先保存所有延迟加载的实体。我通过删除这些映射暂时解决了这个问题，它确实有效，而且比常规会话更快。但我最终还是不得不一次插入每个实体。

4

2 回答 2

1

尝试使用无状态会话而不是会话

using (var session = sessionFactory.OpenStatelessSession())
using (var tx = session.BeginTransaction())
{
for (int i = 0; i < count; i++)
{
    session.Insert(yourObjects[i]);
}
tx.Commit();
}

这个链接也很有帮助

此外，您可以使用 ADO.net SqlBulkCopy 代替无状态会话，请检查此。

于 2012-04-04T23:20:35.980 回答
0

那这个呢？

var sdates = new []{ "1/2/2012 3:00:00 PM", "1/3/2012 3:00:00 PM", "1/4/2012 3:00:00 PM" };
var edates = new []{ "1/2/2012 6:00:00 PM", "1/3/2012 6:00:00 PM", "1/4/2012 6:00:00 PM" };

var hql = "INSERT INTO Event (Code, Comment, Description, Status, StartTime, StopTime)
       SELECT ev.Code, ev.Comment, ev.Description, ev.Status, :sdate, :edate
       FROM Event ev
       WHERE ev.Id = :sourceEventId";

for(var i=0;i<sdates.Length;i++)
{
     Session.CreateQuery(hql).SetInt32("sourceEventId", @event.Id)
                             .SetString("sdate", sdates[i])
                             .SetString("edate", edates[i])
                             .ExecuteUpdate();
}

可能您需要使用 DateTime 而不是字符串并对代码进行一些调整，但这是一个想法。基本上，您将执行三个命令而不是一个命令，而不是 n+1（这就是您的扩展问题，对吗？）

希望能帮助到你。

于 2012-04-05T15:43:06.960 回答