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







 

 

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM