实体框架 - 并发

任何数据访问开发人员在回答关于数据并发的问题时都会遇到困难，“如果多个人同时编辑相同的数据会发生什么？”

• 我们当中比较幸运的人会处理这样的业务规则：“没问题，最后保存的获胜”。

• 在这种情况下，并发不是问题。更可能的是，情况并非如此简单，并且没有万能的解决方案可以一次解决所有场景。

• 默认情况下，实体框架将采用“最后保存的获胜”的方式，这意味着即使有人在检索数据和保存数据之间更新了数据，也会应用最新的更新。

让我们来看一个例子来更好地理解它。下面的例子在Course表中添加了一个新的列VersionNo。

转到设计器，右键单击设计器窗口，然后选择“从数据库更新模型…”。

您将看到在Course实体中添加了另一列。

右键单击新创建的列VersionNo，选择“属性”，并将并发模式更改为“固定”，如下面的图像所示。

将Course.VersionNo的ConcurrencyMode设置为Fixed后，每当更新Course时，Update命令将使用其EntityKey和VersionNo属性查找Course。

让我们来看一个简单的场景。两个用户同时检索相同的课程，用户1将该课程的标题更改为数学并保存更改，然后是用户2。稍后，当用户2更改在用户1保存更改之前检索到的该课程的标题时，用户2将收到并发异常“**用户2：发生了乐观并发异常**”。

using System;
using System.Data.Entity;
using System.Data.Entity.Infrastructure;
using System.Linq;

namespace DatabaseFirstDemo {

   class Program {

      static void Main(string[] args) {

         Course c1 = null;
         Course c2 = null;

         //User 1 gets Course

         using (var context = new UniContextEntities()) {
            context.Configuration.ProxyCreationEnabled = false;
            c1 = context.Courses.Where(s ⇒ s.CourseID == 1).Single();
         }

         //User 2 also get the same Course

         using (var context = new UniContextEntities()) {
            context.Configuration.ProxyCreationEnabled = false;
            c2 = context.Courses.Where(s ⇒ s.CourseID == 1).Single();
         }

         //User 1 updates Course Title
         c1.Title = "Edited from user1";

         //User 2 updates Course Title
         c2.Title = "Edited from user2";

         //User 1 saves changes first

         using (var context = new UniContextEntities()) {

            try {
               context.Entry(c1).State = EntityState.Modified;
               context.SaveChanges();
            } catch (DbUpdateConcurrencyException ex) {
               Console.WriteLine("User1: Optimistic Concurrency exception occurred");
            }
         }

         //User 2 saves changes after User 1.
         //User 2 will get concurrency exection
         //because CreateOrModifiedDate is different in the database

         using (var context = new UniContextEntities()) {

            try {
               context.Entry(c2).State = EntityState.Modified;
               context.SaveChanges();
            } catch (DbUpdateConcurrencyException ex) {
               Console.WriteLine("User2: Optimistic Concurrency exception occurred");
            }
         }
      }
   }
}