Атомное приращение с инфраструктурой сущностей

Ответ 1

В Entity Framework вы не можете сделать это "атомной" операцией. У вас есть следующие шаги:

• Загрузить объект из базы данных
• Сменить счетчик в памяти
• Сохранить измененный объект в базе данных

В промежутке между этими шагами другой клиент может загрузить объект из базы данных, которая все еще имеет старое значение.

Лучший способ справиться с этой ситуацией - использовать оптимистичный concurrency. В основном это означает, что изменение на шаге 3 не будет сохранено, если счетчик больше не тот, что был, когда вы загрузили объект на шаге 1. Вместо этого вы получите исключение, которое вы можете обработать, перезагрузив объект и повторное внесение изменений.

Рабочий процесс будет выглядеть следующим образом:

• В объекте Work свойство WordCount должно быть помечено как токен concurrency (аннотации или Fluent API в случае Code-First)
• Загрузить объект из базы данных
• Сменить счетчик в памяти
• Вызвать SaveChanges в блоке try-catch и перехватить исключения типа DbUpdateConcurrencyException
• Если возникает исключение, перезагрузите объект в блоке catch из базы данных, снова примените это изменение и снова вызовите SaveChanges
• Повторите последний шаг, пока не произойдет больше исключений

В этом ответе вы можете найти пример кода для этой процедуры (используя DbContext).

Ответ 2

Следующий способ будет работать, если вы размещаете свой сайт в одном процессе (он не будет работать с веб-фермой или веб-gardsen):

   private static readonly Locker = new object();

   void Foo()
   {
          lock(Locker)
          {
                 dbEntities myEntity = new dbEntities();

                 var currentWork = myEntity.works.Where(xXx => xXx.RID == 208).FirstOrDefault();
                 Console.WriteLine("Access work");

                 if (currentWork != null)
                 {
                     Console.WriteLine("Access is not null");
                     currentWork.WordCount += 5;//Default WordCount is 0
                     Console.WriteLine("Count changed");
                     myEntity.SaveChanges();
                     Console.WriteLine("Save changes");
                 }
                 Console.WriteLine("Current Count:" + currentWork.WordCount);
          }
   }

Что еще вы можете сделать, это использовать необработанный SQL-запрос через ObjectContext:

   if (currentWork != null)
             {
                 Console.WriteLine("Access is not null");
                 myEntity.ExecuteStoredCommand("UPDATE works SET WordCount = WordCount + 5 WHERE RID = @rid", new MySqlParameter("@rid", MySqlDbType.Int32){Value = 208)
                 Console.WriteLine("Count changed");

             }
    var record = myEntity.works.FirstOrDefault(xXx => xXx.RID == 208);
    if(record != null)
        Console.WriteLine("Current Count:" + record .WordCount);