エンティティフレームワーク-並行性
データアクセスの開発者は、「複数の人が同じデータを同時に編集しているとどうなるか」というデータの同時実行性に関する質問に答える際に困難に直面します。
私たちの中でより幸運なのは、「問題ありません。最後の1つが勝ちです」というビジネスルールを扱っていることです。
この場合、並行性は問題ではありません。おそらく、それはそれほど単純ではなく、すべてのシナリオを一度に解決する特効薬はありません。
デフォルトでは、Entity Frameworkは「最後の勝ち」のパスを取ります。つまり、データが取得されてから保存されるまでの間に他の誰かがデータを更新した場合でも、最新の更新が適用されます。
それをよりよく理解するために例を見てみましょう。次の例では、Courseテーブルに新しい列VersionNoを追加します。
デザイナに移動し、デザイナウィンドウを右クリックして、データベースからモデルの更新を選択します…
コースエンティティに別の列が追加されていることがわかります。
次の図に示すように、新しく作成された列VersionNoを右クリックし、[プロパティ]を選択して、ConcurrencyModeをFixedに変更します。
Course.VersionNoのConcurrencyModeがFixedに設定されている場合、コースが更新されるたびに、UpdateコマンドはEntityKeyとVersionNoプロパティを使用してコースを検索します。
簡単なシナリオを見てみましょう。2人のユーザーが同時に同じコースを取得し、ユーザー1がそのコースのタイトルをMathsに変更し、ユーザー2の前に変更を保存します。後でユーザー2が、ユーザー1が変更を保存する前に取得したコースのタイトルを変更すると、ケースユーザー2は同時実行例外を取得します"User2: Optimistic Concurrency exception occured"。
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");
}
}
}
}
}