如何使用 NHibernate 进行增量多用户更新

Question

我使用 nhibernate 作为我的 orm，我试图实现一些看起来简单但已经变得不必要的困难。它涉及如何实现对实体的并发更新，预计该实体将在多用户场景中由多个用户同时更新。该实体是某种具有余额的帐户。

一个示例是库存系统，需要根据进出的移动条目更新库存项目的余额。我在下面包含了以下代码的缩短版本。该代码只是保存条目并依赖 nhibernate 级联保存一直到项目。

该系统预计可以处理多个用户。这些对象是在一段时间内在 UI 中创建的。每个项目的余额将根据在 UI 中创建条目和获取项目时的现有数量进行调整。用户最终保存可能需要几分钟。

如果另一个用户对同一项目进行了其他输入，则第一个用户正在使用的余额现在无效。我知道如果尝试保存，NHibernate 将抛出陈旧数据异常。但这不是我想要的，因为并发更新是必要的。我想要的是根据条目数量的需要增加或减少该项目的当前余额。或者在更新时再次获取该项目，锁定，执行重新计算，然后最终更新，但我不知道在这种情况下如何实现这一点以及代码到底驻留在哪里。我想避免它出现在域对象中，因为控制悲观锁定等是应用程序/持久性问题。看起来这应该是一个常见的场景，但我还没有看到任何讨论这个的内容。

PS 我还担心在条目有很多行的情况下如何使用上面概述的重新获取锁定重新计算更新方法。是否会为每个项目发送单独的锁定请求，或者是否有一种方法可以一次性获取条目行的所有项目的锁定。

任何帮助将不胜感激。

class TestConcurrentUpdates
{ 
   ISession session; 
   Entry entry; 
   ItemRepository itemRep; 
   EntryRepository entryRep; 

   void testMethod()
   {
       ...

       Entry entry = new Entry();

       Item item1 = itemRepository.Get(item1ID); 
       Item item2 = itemRepository.Get(item1ID); 
       Item item3 = itemRepository.Get(item1ID); 

       entry.Lines.Add(new EntryLine(this, item1, 10)); 
       entry.Lines.Add(new EntryLine(this, item2, -4)); 
       entry.Lines.Add(new EntryLine(this, item3, 2)); 
       using (ITransaction transaction = session.BeginTransaction()) 
       { 
           entryRep.Save(entry); 
           transaction.Commit(); 
       } 
   }
} 


Item 
{ 
   string name; 
   double balance; 
   IList<EntryLine> entries = new List<EntryLine>(); 

   public double getBalance() { return balance; } 


   void addEntryLine(EntryLine line) 
   { 
       entries.add(line); 
       balance += line.getQuantity(); 
   } 
} 


class Entry 
{ 
   IList<EntryLine> lines = new List<EntryLine>(); 
   public IList<EntryLine> Lines { get { return lines; } } 
} 

class EntryLine 
{ 
   Entry entry; 
   double quantity; 
   Item item; 
   public EntryLine(Entry entry, Item item, double quantity) 
   { 
       this.entry = entry; 
       this.quantity = quantity; 
       this.item = item; 
       item.addEntryLine(this); 
   } 

   public double getQuantity() 
   { 
       return quantity; 
   } 
}