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 已经更新，所以第二个 select 查询应该会成功。

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

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

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

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

发生了什么事？

Answer 1

我建议您利用 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();
  }
}

Answer 2

请注意，您需要 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);
}

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

Answer 3

“我想知道在什么情况下以下 NHibernate 代码可能会失败：”我认为您已经为您自己的问题提供了至少一个答案：当代码在隐式事务中运行时。请参阅this post from 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 4

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

Answer 5

您必须关闭会话并在 Assert 之前创建一个 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 6

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

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

以下是使用 NH 会话时要记住的一些事项：

• 从会话中加载对象后，会话将继续跟踪对该对象的更改
• 调用 session.Update(entity) 只告诉 NHibernate 会话它应该开始跟踪对象，它不会将更改写入 db

因此，在您的情况下，因为您已经从会话中加载了一个对象，所以调用 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);