本文介紹如何處理多個用戶併發更新同一實體(同時)時出現的衝突 。 主要是兩種:一種,檢查屬性併發衝突,使用 [ConcurrencyCheck] ;另一種,檢測行的併發衝突,使用 rowversion 跟蹤屬性,如果在保存之前有修改,就報錯 發生併發衝突的情況: 1.用戶導航到實體編輯頁面; 2.第 ...
本文介紹如何處理多個用戶並發更新同一實體(同時)時出現的衝突 。
主要是兩種:一種,檢查屬性併發衝突,使用 [ConcurrencyCheck] ;另一種,檢測行的併發衝突,使用 rowversion 跟蹤屬性,如果在保存之前有修改,就報錯
發生併發衝突的情況:
1.用戶導航到實體編輯頁面;
2.第一個用戶的更改還未寫入資料庫之前,另一個用戶更新同一實體;
此時,如果未啟用併發檢測,當發生更新時:
最後一個更新優先。即最後一個更新的值保存到資料庫。而第一個保存的值將丟失。
舉個例子:
1. Jane 訪問院系編輯頁面,將英語系的預算從 350,000.00 美元更改為 0.00 美元 (第一個用戶把金額改為0)
,
2.在 Jane 單擊“保存”之前,John 訪問了相同頁面,並將開始日期欄位從 2007/1/9 更改為 2013/1/9。 (在第一個用戶保存之前,第二個用戶把時間從07年改為13年,註意此時第二個用戶看到的金額還不是0)
3.Jane 先單擊“保存”,併在瀏覽器顯示索引頁時看到她的更改。 (第一個用戶先保存,並且可以在瀏覽器看到他的修改,金額變0,時間不變)
4.John 單擊“編輯”頁面上的“保存”,但頁面的預算仍顯示為 350,000.00 美元。 (第二個用戶保存,此時的頁面的預算顯示未350000美元,時間為13年)
其實這個結果取決於併發衝突的處理方式
首先聲明,這是一個樂觀併發衝突,那麼什麼是樂觀併發衝突呢?
樂觀併發衝突允許發生併發衝突,併在併發衝突發生時作出正確的反映。
說了這麼多,那麼,併發衝突的處理方式呢?
1. 可以跟蹤用戶已修改的屬性,並只更新資料庫中相應的列。
這樣,當兩個用戶更新了不同的屬性,下次查看時,都將生效。
但是,這種方法,也有一些問題:
- 當對同一個屬性進行競爭性更改的話,無法避免數據丟失
- 通常不適用於web應用。它需要維持重要狀態,以便跟蹤所有提取值和新值。 維持大量狀態可能影響應
用性能。 - 可能會增加應用復雜性(與實體上的並發檢測相比)。
體現在例子中,就是如果下次有人瀏覽英語系時,將看到 Jane 和 John
兩個人的更改。
2.客戶端優先
即客戶端的值優先於資料庫存儲的值。並且如果不對併發處理進行任何編碼,將自動進行客戶端優先
即John 的更改覆蓋 Jane 的更改 。也就是說,下次有人瀏覽英語系時,將看到 2013/9/1 和提取的值 350,000.00 美元
3.存儲優先
這種方式可以阻止在資料庫中John的更改。並且可以
- 顯示錯誤消息
- 顯示數據的當前狀態
- 允許用戶重新應用更改。
處理併發
當屬性配置為並發令牌時:
- EF Core 驗證提取屬性後是否未更改屬性。 調用 SaveChanges 或 SaveChangesAsync 時會執行此檢查。
- 如果提取屬性後更改了屬性,將引發 DbUpdateConcurrencyException。
數據庫和數據模型必須配置為支持引發 DbUpdateConcurrencyException 。
檢測屬性的並發衝突
可使用 ConcurrencyCheck 特性在屬性級別檢測並發衝突。 該特性可應用於模型上的多個屬性 。[ConcurrencyCheck] 特性
檢測行的並發衝突
要檢測並發衝突,請將 rowversion 跟蹤列添加到模型。
註意:rowversion ,
1.它是 SQL Server 特定的。 其他數據庫可能無法提供類似功能。
2.用於確定從數據庫提取實體後未更改實體。
資料庫生成rowversion序號,該數字隨著每次行的更新遞增。
在 update 或 delete 命令中,where 子句中包括 rowversion提取值 的判斷 。
如果要更新的行已經修改,則 rowversion提取值與現在資料庫中rowversion的值不匹配;
update 或 delete 命令不能找到行。引發一個 DbUpdateConcurrencyException 異常
例子
向 Department 實體添加跟蹤屬性
using System; using System.Collections.Generic; using System.ComponentModel.DataAnnotations; using System.ComponentModel.DataAnnotations.Schema; namespace ContosoUniversity.Models { public class Department { public int DepartmentID { get; set; } [StringLength(50, MinimumLength = 3)] public string Name { get; set; } [DataType(DataType.Currency)] [Column(TypeName = "money")] public decimal Budget { get; set; } [DataType(DataType.Date)] [DisplayFormat(DataFormatString = "{0:yyyy-MM-dd}", ApplyFormatInEditMode = true)] [Display(Name = "Start Date")] public DateTime StartDate { get; set; } public int? InstructorID { get; set; }
[Timestamp] public byte[] RowVersion { get; set; } //跟蹤屬性
public Instructor Administrator { get; set; } public ICollection<Course> Courses { get; set; } } }
Timestamp 特性 指定此列包含在 update 和 delete 命令的 where 子句中。
也可以用 Fluent API 指定跟蹤屬性:
modelBuilder.Entity<Department>() .Property<byte[]>("RowVersion") .IsRowVersion();
以下代碼顯示更新 Department 名稱時由 EF Core 生成的部分 T-SQL:
SET NOCOUNT ON;
UPDATE [Department] SET [Name] = @p0 WHERE [DepartmentID] = @p1 AND [RowVersion] = @p2;
SELECT [RowVersion] FROM [Department] WHERE @@ROWCOUNT = 1 AND [DepartmentID] = @p1;
前面的代碼顯示包含 RowVersion 的 WHERE 子句。 如果數據庫 RowVersion 不等於 RowVersion 參數( @p2
),則不更新行。
@@ROWCOUNT 返回受上一語句影響的行數。 在沒有行更新的情況下,EF Core 引發
DbUpdateConcurrencyException
此文主要是為了方便自己記錄學習,如有錯誤,歡迎指正
這裡附上參考資料:
https://docs.microsoft.com/en-us/aspnet/core/data/ef-rp/concurrency?view=aspnetcore-2.2&tabs=visual-studio