The database operation was expected to affect 1 row(s), but actually affected 0 row(s); 解決樂觀並行

2023-08-24 18:00:09

The database operation was expected to affect 1 row(s), but actually affected 0 row(s); 解決樂觀並行

1.樂觀並行

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.

2.設定樂觀鎖

我的程式使用EF Core,然後給實體類設定了樂觀並行 UseIdentityColumn

 public void Configure(EntityTypeBuilder<ChatRecord> builder)
 {
 //在 PostgreSQL 中,表名以及列名是不區分大小寫的。這意味著在資料庫中建立表時,無論您是使用大寫、小寫或混合大小寫的名稱,最終都會使用相同的名稱來存取和操作該表。
 //設定表
 builder.ToTable("ChatRecord");
 //設定表主鍵
 builder.HasKey(e => e.ChatRecordId);
 //設定主鍵自增
 builder.Property(e => e.ChatRecordId)
 .UseIdentityColumn();
}

3.什麼情況下會觸發樂觀並行

樂觀並行允許發生並行衝突,並在並行衝突發生時作出正確反應。 例如,Jane 存取院系編輯頁面,將英語系的預算從 350,000.00 美元更改為 0.00 美元。

在 Jane 單擊「儲存」之前,John 存取了相同頁面,並將開始日期欄位從 2007/1/9 更改為 2013/1/9。

Jane 單擊「儲存」後看到更改生效,因為瀏覽器會顯示預算金額為零的「索引」頁面。

John 單擊「編輯」頁面上的「儲存」,但頁面的預算仍顯示為 350,000.00 美元。 接下來的情況取決於並行衝突的處理方式:

  • 跟蹤使用者已修改的屬性,並僅更新資料庫中相應的列。

    在這種情況下,資料不會丟失。 兩個使用者更新了不同的屬性。 下次有人瀏覽英語系時,將看到 Jane 和 John 兩個人的更改。 這種更新方法可以減少導致資料丟失的衝突數。 這種方法具有一些缺點:

    • 無法避免資料丟失,如果對同一屬性進行競爭性更改的話。
    • 通常不適用於 Web 應用。 它需要維持重要狀態,以便跟蹤所有提取值和新值。 維持大量狀態可能影響應用效能。
    • 可能會增加應用複雜性(與實體上的並行檢測相比)。
  • 讓 John 的更改覆蓋 Jane 的更改。

    下次有人瀏覽英語系時,將看到 2013/9/1 和提取的值 350,000.00 美元。 這種方法稱為「使用者端優先」或「最後一個優先」方案 。 使用者端的所有值優先於資料儲存的值。 基架程式碼不處理並行,「使用者端優先」方案會自動執行。

  • 阻止在資料庫中更新 John 的更改。 應用通常會:

    • 顯示錯誤訊息。
    • 顯示資料的當前狀態。
    • 允許使用者重新應用更改。

    這稱為「儲存優先」方案。 資料儲存值優先於使用者端提交的值。 本教學中使用了「儲存優先」方案。 此方法可確保使用者在未收到警報時不會覆蓋任何更改。

4.解決方案:重寫SaveChanges

在 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