NHibernate 没有接受更改

Question

我想知道在什么情况下以下 NHibernate 代码可能会失败：

var session = NHibernateSessionManager.CurrentSession;

var foo = session.Linq<Foo>.ToList()[0];

foo.SomeProperty = "test";

session.SaveOrUpdate(foo);

var reloadedFoos = session.Linq<Foo>
                         .Where(x => x.SomeProperty == "test");

Assert.That(reloadedFoos.Count > 0);

Assert 语句总是失败。

如果我在SaveOrUpdate之后手动调用session.Flush，那么select查询会成功，但是我认为我们不必手动调用flush？据我了解，NHibernate 应该足够聪明，能够意识到 Foo 已更新，因此第二个选择查询应该成功。

观察生成的 SQL，似乎第二个选择查询的 SQL 在第一个 SaveOrUpdate 的 SQL 之前执行。

事实上，如果我将整个方法包装在一个事务中，那么它就会成功：

using(NHibernateSessionManager.CurrentSession.BeginTransaction()
{
    // Same code as above
}

现在 SaveOrUpdate 的 sql 将在 Linq.Where sql 之前执行。这有点奇怪，因为我什至不必在两者之间提交事务。

到底是怎么回事？

Answer 1

请注意，您需要一个事务才能使 NHibernate 变得“智能”。

它的工作原理如下：

var session = NHibernateSessionManager.CurrentSession;
using(NHibernateSessionManager.CurrentSession.BeginTransaction()) {
    var foo = session.Linq<Foo>.ToList()[0];
    foo.SomeProperty = "test";
    var reloadedFoos = session.Linq<Foo>()
        .Where(x => x.SomeProperty == "test");
    Assert.That(reloadedFoos.Count > 0);
}

另请注意，您不在需要时调用 Save、Update 或 SaveOrUpdate保存您对 Session 已跟踪回数据库的对象所做的更改。 NHibernate 的工作方式与其他 ORM 不同：如果它正在跟踪一个对象，那么它会确定何时将更改发送到数据库，并且您不需要告诉它这样做。

Answer 2

“我想知道在什么情况下以下 NHibernate 代码可能会失败：”我认为您已经为自己的问题提供了至少一个答案：当代码在隐式事务中运行时。请参阅Ayende 的这篇文章，其中提到了隐式事务中的不一致行为。我有许多类似于您的代码的单元测试，除了测试驱动程序提供包装事务，例如，

[Test]
public void Can_Update_Account() {
        Account account = PersistenceContext.Get<Account>(TEST_ACCOUNT_ID);

        string accountNumber = RandomString(10);
        account.AccountNumber = accountNumber;

        Account account1 = PersistenceContext.GetAll<Account>().Where(x => x.AccountNumber == accountNumber).SingleOrDefault();
        Account account2 = PersistenceContext.Get<Account>(account.Id);
        Assert.AreEqual(account.Id, account1.Id);
        Assert.AreEqual(accountNumber, account2.AccountNumber);
    }

[GetAll<>() 是 Linq<> 上的薄包装器。] 我有许多定期通过的此类测试。

Answer 3

您可能设置了不正确的冲洗模式。您需要将会话上的刷新模式设置为自动，以便在每次查询之前自动刷新会话，否则您需要手动刷新会话以强制保存更改。

Answer 4

您必须关闭会话并在断言之前创建一个 now 会话。

using(var session = NHibernateSessionManager.CurrentSession)
{
  using(var tx = session.BeginTransaction())
  {
    var foo = session.Linq<Foo>.ToList()[0];
    foo.SomeProperty = "test";
    session.SaveOrUpdate(foo);  
    tx.Commit();
  }
}

//create a new session here, the code depend if you use RhinoCommons (like me), no Rhino

using(var session = NHibernateSessionManager.CurrentSession)
{
  using(var tx = session.BeginTransaction())
  {
    var reloadedFoos = session.Linq<Foo>
            .Where(x => x.SomeProperty == "test");
    Assert.That(reloadedFoos.Count > 0);
    tx.Commit();
  }
}

Answer 5

如果我手动调用 session.Flush 之后
SaveOrUpdate，然后选择查询
成功。

首先：甚至不需要调用 SaveOrUpdate()。

使用 NH 会话时需要记住以下几点：

• 当您从会话加载对象时，会话将继续跟踪该对象的更改 调用
• session.Update(entity) 仅告诉 NHibernate 会话它应该启动 跟踪对象，它不会将更改写入数据库

因此，在您的情况下，因为您已经从会话加载了一个对象，所以调用 session.Update() 不会执行任何操作，因为它已经被跟踪。事实上，您只需执行以下操作即可强制更新数据库：

var session = NHibernateSessionManager.CurrentSession;
var foo = session.Linq<Foo>.ToList()[0];
foo.SomeProperty = "test";

session.Flush();

var reloadedFoos = session.Linq<Foo>
                         .Where(x => x.SomeProperty == "test");
Assert.That(reloadedFoos.Count > 0);

Answer 6

我建议您利用 NHibernate 事务。如果不使用它们，NHibernate 完全有可能无法确定何时发出 SaveOrUpdate 调用。

您会发现，使用事务时，即使是只读语句也能表现得更好。请参阅http://nhprof.com/Learn/Alert?name=DoNotUseImplicitTransactions进一步的细节。

例如：

using(var session = NHibernateSessionManager.CurrentSession)
{
  using(var transaction = session.BeginTransaction())
  {
    var foo = session.Linq<Foo>.ToList()[0];

    foo.SomeProperty = "test";

    session.SaveOrUpdate(foo);
    transaction.Commit();
  }
}