asp.net - NHibernate 事务的不良行为

Question

我有一个在 PostgreSQL 数据库上使用 NHibernate 的 ASP.NET MVC 3 应用程序。

我的网站上有一项操作需要所有实体(我称它们为单位)，如果它们满足特定条件，它会更新它们的一个属性(列)。整个操作包含在事务中。

今天我遇到了一个问题，我注意到有时(确切地)一个单元在操作期间没有得到更新，即使它应该(它满足要求的条件)。

现在我发现这是因为同时有很多其他请求来到服务器，它们也在处理单位(对于这个请求，它总是一个单元，已检查并在需要时修改)。

所以在一个线程中我运行了这段代码:

ISession session = sessionBuilder.GetSession();
using (ITransaction transaction = session.BeginTransaction())
{
    var unitsToBeUpdated = session.QueryOver<Unit>()
            .Where(x => x.Status == STATUS_TRANSLATED)
            .JoinQueryOver<UnitParent>(u => u.Parent)
            .JoinQueryOver<Document>(p => p.Document)
            .Where(d => d.Job == job);

    foreach (Unit unit in unitsToBeUpdated.List<Unit>())
    {
        unit.Status = STATUS_CONFIRMED;
        session.SaveOrUpdate(unit);
    }     

    transaction.Commit();
}

在第二个线程中，我运行这段代码(多次，每次针对不同的 unitId)

Unit unit;
using (ITransaction transaction = sessionBuilder.GetSession().BeginTransaction())
{
    unit = unitRepository.GetById(unitId);
}

using (ITransaction transaction = sessionBuilder.GetSession().BeginTransaction())
{                
    unit.LastCategory = statisticsHarvester.AddWords(job, unit);  
    unitRepository.Update(unit);              
    transaction.Commit();
}

在第二个线程中，交易开启显示了两次，因为实际上这两个交易是在不同的函数中创建的。

所以请求是这样的

Request A started...

Request B(unitId = 0) started...
Request B(unitId = 0) finished

Request B(unitId = 1) started...
Request B(unitId = 1) finished

....

Request B(unitId = n) started...
Request A finished
Request B(unitId = n) finished

Request B(unitId = n+1) started...
Request B(unitId = n+1) finished

....

也许我没有完全了解事务和并发访问的整个世界，但在这种情况下，第一个线程不应该只更新一些单元吗？我预计整个交易会回滚，出了点问题。这里有什么问题？

谢谢。

编辑:最后我用 NHibernate 中的“动态更新”功能解决了这个问题 - 在我的例子中，两个请求不会修改实体的相同字段，所以它是可行的。

Answer 1

我猜你的问题出在这里:

Unit unit;
using (ITransaction transaction = sessionBuilder.GetSession().BeginTransaction())
{
    unit = unitRepository.GetById(unitId);
}

using (ITransaction transaction = sessionBuilder.GetSession().BeginTransaction())
{                
    unit.LastCategory = statisticsHarvester.AddWords(job, unit);  
    unitRepository.Update(unit);              
    transaction.Commit();
}

在这里你做了一个读取然后开始一个新的事务。在两个事务之间，可以在数据库中更改单位。在第二个事务中，您将旧单元保存回数据库中。最后写入在这里获胜。

重写代码如下:

Unit unit;
using (ITransaction transaction = sessionBuilder.GetSession().BeginTransaction())
{
    unit = unitRepository.GetById(unitId); //Add lock mode in you getbyid function LockMode.Upgrade
    unit.LastCategory = statisticsHarvester.AddWords(job, unit);  
    unitRepository.Update(unit);              
    transaction.Commit();
}

您还应该检查您的交易级别。

一个很好的实现模式是乐观锁定(如果事务失败，记录错误)。如果您在锁定时遇到问题，您将在日志中看到错误，并能够调试您的代码。

http://knol.google.com/k/nhibernate-chapter-10-transactions-and-concurrency#10%282E%296%282E%29%28C2%29%28A0%29Pessimistic_Locking