在没有刷新/提交的情况下强制执行查询

Question

您好，我正在为 asp.net Web 应用程序使用每请求事务（视图中的会话）模式。我在应用程序中有几点要保存 NHibernate 托管实体，然后使用通用 sql 进行更多插入和更新。这些插入/更新取决于 NH 保存的实体将采用的 ID。

问题是生成的 id 不存在于事务的范围内。如果我强制刷新/提交，则 id 将保留，但如果插入/更新失败，我必须回滚，但刷新/提交的实体不会。目前我正在为这些情况进行手动插入，但这是我想要改变的。那么，有没有办法在 Save() 之后执行 SQL 语句（在已经打开的事务中）但不强制刷新/提交？

编辑：我正在添加一个半伪代码示例，我得到了 4 个错误答案，所以我认为人们不明白（NHibernate 是如何工作的） 在开始请求我发出一个

nhsession.BeginTransaction()

然后在某个时候我会这样做

FooClass fc = new FooClass("value");
nhsession.Save(fc);
ITransaction trans = nhsession.Transaction;
SqlCommand sc = new SqlCommand("some insert/update query that depends on fc's id", (SqlConnection)nhsession.Connection);
sc.Parameters.Add("id", fc.Id); //NHibernate generates the id, note i'm using assigned/hi-lo so no round trip to the db takes place
transaction.Enlist(sc);
try {
    sc.ExecuteNonQuery();
}
catch (SqlException ex){
    transaction.RollBack();
    nhsession.Close();
}

在请求结束时我发出CommitTransaction() 和nhsession.Close()

现在这将完全没有任何作用：FooClass (fc) 尚未刷新/提交到数据库。 NH 已经完成的Save() 操作在内存中达到了这一点。这意味着 nhibernate 没有发出任何 sql 命令，这意味着我之后触发的 SqlCommand (sc) 将失败，因为 id 不存在。

如果我在Save() 和SqlCommand 和FooClass(fc) _cannot_be_rolled_back_ 之间进行刷新/提交，这是一件坏事。 目前，为了让它工作，我使用SqlCommand 进行 vanila sql 插入，我想改变它。 （为什么？因为我不想制作香草插入，它们容易因架构/模型更改而出错，我为此得到了 OR/M）

怎么样？我想通知 NHibernate 以某种方式执行 SqlCommand 以对应于 Save() 插入（地狱，它可以执行它收集的所有 SqlCommands）但没有它提交或刷新！。

目前我还在搜索 nhibernate 在刷新/提交保存的对象时生成的准备好的 sql 语句。也许我可以只使用该字符串并在事务中登记的 SqlCommand 中运行它。

Answer 1

也许我不明白，但你不能这样做......

using(var tx = session.BeginTransaction())
{
    session.Save(entity);
    session.Flush();

    //perform non NH operations with entity.id

    tx.Commit();
}//uncommitted transaction would be rolled back on dispose()

Answer 2

您不能使用嵌套事务或事务范围来支持这一点吗？

本质上，您要求 nh 在使用之前分配 id，生成的 id 仅在刷新更改时分配，更改仅在事务边界处刷新，因此您不能创建内部事务范围来包装 nh相关的持久性强制刷新和 id 生成，但仍然允许外部事务失败并在其中一个存储过程失败时回滚所有工作。

How do I do nested transactions in NHibernate? 有一些示例代码演示了使用范围的方法。

Answer 3

听起来您在事务期间需要“脏读”隔离级别。这将允许您阅读“未提交”但“已保存”的内容。但是，我在 NHibernate 中不够流利，无法提供有关如何在那里进行操作的任何见解。

我确信其他人可以了解如何为 NH 设置“脏读”隔离级别。

Answer 4

我在 NHibernate 之上使用 Castle ActiveRecord，但原理应该是相同的，我的 DTC 已禁用，所以我不肯定这可行，但这应该是正确的方向。

Imports Castle.ActiveRecord
imports NHibernate.Expression

<ActiveRecord> _
Public Class Test1
    Inherits ActiveRecordBase(Of Test1)

    Private _id As Guid
    <PrimaryKeyAttribute(PrimaryKeyType.Guid)> _
    Public overridable Property Id as Guid
        Get
            return _id
        End Get

        Set(value As guid)
            _id = value
        End Set
    End Property


    Private _prop1 As String
    <[Property]> _
    Public overridable Property prop1 as String
        Get
            return _prop1
        End Get

        Set(value As String)
            _prop1 = value
        End Set
    End Property

End Class

<ActiveRecord> _
Public Class Test2
    Inherits ActiveRecordBase(Of Test2)

    Private _id As Guid
    <PrimaryKey(PrimaryKeyType.Guid)> _
    Public overridable Property Id as Guid
        Get
            return _id
        End Get

        Set(value As guid)
            _id = value
        End Set
    End Property

    Private _prop1 As String
    <[Property]> _
    Public overridable Property prop1 as String
        Get
            return _prop1
        End Get

        Set(value As String)
            _prop1 = value
        End Set
    End Property

    Private _t1 As Test1
    <BelongsTo()> _
    Public overridable Property t1 as Test1
        Get
            return _t1
        End Get

        Set(value As test1)
            _t1 = value
        End Set
    End Property


End Class

---

Imports Castle.ActiveRecord
Imports NHibernate.Expression
Imports System.Data.SqlClient
Imports System.Transactions
imports System.Configuration

Public Module Module1
    Public Class modMain
        Public Shared Sub Main()
            Castle.ActiveRecord.ActiveRecordStarter.Initialize()
            Using T As New System.Transactions.TransactionScope(ondispose.Rollback)
            Dim x As New Test1()
            x.prop1 = "Hello"
            x.Save

            using c As New SqlConnection()
                c.ConnectionString = ConfigurationManager.ConnectionStrings("Development").ConnectionString
                Dim cmd As SqlCommand = c.CreateCommand()
                cmd.CommandText = "insert into test2(prop1, t1) values(@prop1, @t1)"
                Dim p As SqlParameter = cmd.CreateParameter()
                p.Direction = parameterdirection.Input
                p.DbType = dbtype.Guid
                p.ParameterName = "@prop1"
                p.Value = "Test"

                cmd.Parameters.Add(p)
                p = cmd.CreateParameter()
                p.Direction = parameterdirection.Input
                p.DbType = dbtype.Guid
                p.ParameterName = "@t1"
                p.Value = x.Id

                c.Open
                cmd.ExecuteNonQuery
            end using

            t.Complete
            end using

        End Sub
    End Class
End Module

Answer 5

您是否尝试过使用 NHibernate 的直接 SQL 功能？可以使用 ISession.CreateSQLQuery("native SQL here")，而不是闯入 NHibernate 对您一无所知的 SQLCommand。如果您在您的 Save 方法之后在事务中执行此操作，NHibernate 应该在 Commit 发生时按顺序执行所有语句。因此：

using(var tx = session.BeginTransaction())
{
    try
    {
        FooClass fc = new FooClass("value");
        nhsession.Save(fc);

        var nativeQuery = nhsession.CreateSQLQuery("some insert/update query that depends on fc's id");

        // Add parameters to nativeQuery using SetXXX methods
        nativeQuery.SetXXX(...);

        // Save nativeQuery
        nativeQuery.Save(); // I think...

        tx.Commit();
    }
    catch (...)
    {
        tx.Rollback();
    }
}

有关使用 NH 本地查询的另一个类似问题，请参阅此内容：Hibernate NHibernate - Native SQL