EF Core 實現 樂觀並行,假定並行衝突相對較少。 與 悲觀 方法(即先鎖定資料,然後才繼續修改資料)不同,樂觀並行不需要鎖定,而是安排資料修改在儲存時失敗(如果資料自查詢後已更改)。 此並行故障將報告給應用程式,應用程式可能會通過對新資料重試整個操作來相應地處理它。
在 EF Core 中,樂觀並行是通過將屬性設定為 並行令牌來實現的。 在查詢實體時載入和跟蹤並行令牌,就像任何其他屬性一樣。 然後,在 期間 SaveChanges()執行更新或刪除操作時,資料庫上的並行令牌值與 EF Core 讀取的原始值進行比較。
程式碼觸發樂觀會如下錯誤:
Microsoft.EntityFrameworkCore.DbUpdateConcurrencyException: The database operation was expected to affect 1 row(s), but actually affected 0 row(s); data may have been modified or deleted since entities were loaded. See http://go.microsoft.com/fwlink/?LinkId=527962 for information on understanding and handling optimistic concurrency exceptions.
我的程式使用EF Core,然後給實體類設定了樂觀並行 UseIdentityColumn
public void Configure(EntityTypeBuilder<ChatRecord> builder)
{
//在 PostgreSQL 中,表名以及列名是不區分大小寫的。這意味著在資料庫中建立表時,無論您是使用大寫、小寫或混合大小寫的名稱,最終都會使用相同的名稱來存取和操作該表。
//設定表
builder.ToTable("ChatRecord");
//設定表主鍵
builder.HasKey(e => e.ChatRecordId);
//設定主鍵自增
builder.Property(e => e.ChatRecordId)
.UseIdentityColumn();
}
樂觀並行允許發生並行衝突,並在並行衝突發生時作出正確反應。 例如,Jane 存取院系編輯頁面,將英語系的預算從 350,000.00 美元更改為 0.00 美元。
在 Jane 單擊「儲存」之前,John 存取了相同頁面,並將開始日期欄位從 2007/1/9 更改為 2013/1/9。
Jane 單擊「儲存」後看到更改生效,因為瀏覽器會顯示預算金額為零的「索引」頁面。
John 單擊「編輯」頁面上的「儲存」,但頁面的預算仍顯示為 350,000.00 美元。 接下來的情況取決於並行衝突的處理方式:
跟蹤使用者已修改的屬性,並僅更新資料庫中相應的列。
在這種情況下,資料不會丟失。 兩個使用者更新了不同的屬性。 下次有人瀏覽英語系時,將看到 Jane 和 John 兩個人的更改。 這種更新方法可以減少導致資料丟失的衝突數。 這種方法具有一些缺點:
讓 John 的更改覆蓋 Jane 的更改。
下次有人瀏覽英語系時,將看到 2013/9/1 和提取的值 350,000.00 美元。 這種方法稱為「使用者端優先」或「最後一個優先」方案 。 使用者端的所有值優先於資料儲存的值。 基架程式碼不處理並行,「使用者端優先」方案會自動執行。
阻止在資料庫中更新 John 的更改。 應用通常會:
這稱為「儲存優先」方案。 資料儲存值優先於使用者端提交的值。 本教學中使用了「儲存優先」方案。 此方法可確保使用者在未收到警報時不會覆蓋任何更改。
在 FrameworkDbContext 的DbContext類中重寫SaveChanges方法
程式碼如下:
public override int SaveChanges()
{
var saved = 0;
while (saved !=0) {
try {
base.SaveChanges();
saved++;
}
catch (DbUpdateConcurrencyException ex) {
foreach (var entry in ex.Entries) {
var proposedValues = entry.CurrentValues;
var databaseValues = entry.GetDatabaseValues();
foreach (var property in proposedValues.Properties) {
var proposedValue = proposedValues[property];
var databaseValue = databaseValues[property];
}
// Refresh original values to bypass next concurrency check
entry.OriginalValues.SetValues(databaseValues);
}
}
}
return saved;
}
程式碼可以在github中查詢。我的開源專案修改的類的原始碼,原始碼地址:https://github.com/TerraMours/TerraMours_Gpt_Api/blob/main/TerraMours/TerraMours/Framework/Infrastructure/EFCore/FrameworkDbContext.cs
參考資料:https://learn.microsoft.com/zh-cn/ef/core/saving/concurrency?tabs=fluent-api
閱讀如遇樣式問題,請前往個人部落格瀏覽: https://www.raokun.top
擁抱ChatGPT:https://first.terramours.site
開源專案地址:https://github.com/TerraMours/TerraMours_Gpt_Api