asp.net core 系列之併發衝突

 

本文介紹如何處理多個用戶並發更新同一實體（同時）時出現的衝突 。

主要是兩種：一種，檢查屬性併發衝突，使用 [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