nhibernate : 批量执行更新

Question

我正在尝试使用 NHibernate 进行批量更新，但它没有进行批量更新，而是对所有行进行单独写入。我必须向 db 写入大约 10k 行。

        using (var session = GetSessionFactory().OpenStatelessSession())
        {
            session.SetBatchSize(100);
            using (var tx = session.BeginTransaction())
            {
                foreach (var pincode in list)
                {
                    session.Update(pincode);
                }
                tx.Commit();
            }
        }

我尝试使用session.SetBatchSize(100); 将批量大小设置为 100，但这无济于事。还尝试使用cfg.SetProperty("adonet.batch_size", "100"); 设置批量大小，但这也无济于事。

我正在使用 GUID 主键，因此我不明白批量更新失败的原因。这正是here 解释的解决方案。但它不适合我。

注意我在所有实体上都映射了乐观并发的版本字段。这会是没有批量更新的罪魁祸首吗？？

编辑

我尝试使用有状态会话，但这也没有帮助

        //example 2
        using (var session = GetSessionFactory().OpenSession())
        {
            session.SetBatchSize(100);
            session.FlushMode = FlushMode.Commit;
            foreach (var pincode in list)
            {
                session.Update(pincode);
            }
            session.Flush();
        }

       //example 3
        using (var session = GetSessionFactory().OpenSession())
        {
            session.SetBatchSize(100);
            using (var tx = session.BeginTransaction())
            {
                foreach (var pincode in list)
                {
                    session.Update(pincode);
                }
                tx.Commit();
            }
        }

example 2 出于某种原因导致了两次往返。

编辑

经过进一步研究我发现，每个 session.Update 实际上都是在更新数据库

        using (var session = SessionManager.GetStatelessSession())
        {
            session.SetBatchSize(100);
            foreach (var record in list)
            {
                session.Update(record);
            }
        }

我怎样才能避免这种情况。

编辑

也尝试过刷新模式，但这也无济于事

        using (var session = SessionManager.GetNewSession())
        {
            session.FlushMode = FlushMode.Never;
            session.SetBatchSize(100);
            session.BeginTransaction();
            foreach (var pincode in list)
            {
                session.SaveOrUpdate(pincode);
            }
            session.Flush();
            session.Transaction.Commit();
        }

编辑 4

即使低于一个也不起作用，因为我正在获取同一会话中的所有实体并仅在该会话中更新和保存它们...

        using (var session = SessionManager.GetSessionFactory().OpenSession())
        {
            session.SetBatchSize(100);
            session.FlushMode = FlushMode.Commit;
            session.Transaction.Begin();
            var list = session.QueryOver<Pincode>().Take(1000).List();
            list.ForEach(x => x.Area = "Abcd" + DateTime.Now.ToString("HHmmssfff"));
            foreach (var pincode in list) session.SaveOrUpdate(pincode);
            session.Flush();
            session.Transaction.Commit();
        }

Answer 1

您正在使用无状态会话。由于无状态会话没有状态，因此它无法记住以后要做的任何事情。因此更新会立即执行。

Answer 2

nhibernate 不批处理版本化实体这是我的问题。

没有办法批量版本实体，唯一的做法是使实体不版本化。

Answer 3

注意：

• 批次在 Sql Server Profiler 中不可见。不要依赖于此。
• 当使用 identity（或本机）ID 生成器插入时，NH 会关闭 ado.net 批量大小。

补充说明：

• 确保您没有针对每个已更改实体的查询，因为它会在查询之前刷新。
• 您可能不应该调用 session.Update。在最好的情况下，它什么也不做。在最坏的情况下，它确实会更新，从而破坏批处理。

当会话中有许多对象时，不要忘记关心刷新和刷新时间。有时刷新比更新更耗时。 NH 在提交之前刷新，当您调用刷新和查询之前，除非您将其关闭或使用无状态会话。确保只冲洗一次。