处理并发

如果一个属性被配置为并发标记，那么在保存属性记录的期间 EF 将会制止其他用户修改该属性在数据库中的值。

提示

你可以在 GitHub 上查阅当前文章涉及的代码样例。

EF Core 是如何处理并发的

关于 Entity Framework Core 是如何处理并发的详细描述请查阅 并发标记。

解决并发冲突

解决并发冲突需要使用算法来将当前用户的挂起更改与数据库变更合并。具体的方法根据不同的应用程序有所不同，通用的办法是向用户显示这些值，让他们决定要存储到数据库中的值。

有三组值集合可以用来协助解决并发冲突 。

  • 当前值（CurrentValue） 是应用程序正在尝试写入数据库的值。
  • 原始值（OriginalValue） 是从数据库遍历出来的、没有作任何编辑的值。
  • 数据库值（DatabaseValue） 是当前存储在数据库中的值。

为了解决并发冲突，需要在 SaveChanges() 期间捕捉 DbUpdateConcurrencyException 异常，然后使用 DbUpdateConcurrencyException.Entries 来准备受影响的实体的新变更集，然后重新尝试 SaveChanges() 操作。

在以下代码样例中，Person.FirstName 和 Person.LastName 被设置成了变更标记。其中有一个 // TODO: 注释，在这里你可以包含应用程序指定的逻辑，选择合适的值来存储到数据。

  1. using Microsoft.EntityFrameworkCore;
  2. using System;
  3. using System.ComponentModel.DataAnnotations;
  4. using System.Linq;
  6. namespace EFSaving.Concurrency
  7. {
  8.     public class Sample
  9.     {
  10.         public static void Run()
  11.         {
  12.             // 确保已经创建了数据库，并且包含一个 person 数据。
  13.             using (var context = new PersonContext())
  14.             {
  15.                 context.Database.EnsureDeleted();
  16.                 context.Database.EnsureCreated();
  18.                 context.People.Add(new Person { FirstName = "John", LastName = "Doe" });
  19.                 context.SaveChanges();
  20.             }
  22.             using (var context = new PersonContext())
  23.             {
  24.                 // 从数据库提取 person 数据并更改其电话号码 PhoneNumber
  25.                 var person = context.People.Single(p => p.PersonId == 1);
  26.                 person.PhoneNumber = "555-555-5555";
  28.                 // 更改更改数据库中 person 的名称 name（这会导致并发冲突）
  29.                 context.Database.ExecuteSqlCommand("UPDATE dbo.People SET FirstName = 'Jane' WHERE PersonId = 1");
  31.                 try
  32.                 {
  33.                     // 尝试保存变更到数据库
  34.                     context.SaveChanges();
  35.                 }
  36.                 catch (DbUpdateConcurrencyException ex)
  37.                 {
  38.                     foreach (var entry in ex.Entries)
  39.                     {
  40.                         if (entry.Entity is Person)
  41.                         {
  42.                             // 使用无跟踪查询意味着我们会获得实体，但它不受上下文跟踪
  43.                             // 并且不会与上下文中的已有实体合并
  44.                             var databaseEntity = context.People.AsNoTracking().Single(p => p.PersonId == ((Person)entry.Entity).PersonId);
  45.                             var databaseEntry = context.Entry(databaseEntity);
  47.                             foreach (var property in entry.Metadata.GetProperties())
  48.                             {
  49.                                 var proposedValue = entry.Property(property.Name).CurrentValue;
  50.                                 var originalValue = entry.Property(property.Name).OriginalValue;
  51.                                 var databaseValue = databaseEntry.Property(property.Name).CurrentValue;
  53.                                 // TODO: 这里编写决定选取哪个值被写到数据库的逻辑
  54.                                 // entry.Property(property.Name).CurrentValue = <value to be saved>;
  56.                                 // 原始值更新为...
  57.                                 entry.Property(property.Name).OriginalValue = databaseEntry.Property(property.Name).CurrentValue;
  58.                             }
  59.                         }
  60.                         else
  61.                         {
  62.                             throw new NotSupportedException("无法处理并发冲突：" + entry.Metadata.Name);
  63.                         }
  64.                     }
  66.                     // 重新尝试保存操作
  67.                     context.SaveChanges();
  68.                 }
  69.             }
  70.         }
  72.         public class PersonContext : DbContext
  73.         {
  74.             public DbSet<Person> People { get; set; }
  76.             protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
  77.             {
  78.                 optionsBuilder.UseSqlServer(@"Server=(localdb)\mssqllocaldb;Database=EFSaving.Concurrency;Trusted_Connection=True;");
  79.             }
  80.         }
  82.         public class Person
  83.         {
  84.             public int PersonId { get; set; }
  86.             [ConcurrencyCheck]
  87.             public string FirstName { get; set; }
  89.             [ConcurrencyCheck]
  90.             public string LastName { get; set; }
  92.             public string PhoneNumber { get; set; }
  93.         }
  95.     }
  96. }