學習ASP.NET Core Razor 編程系列十八——併發解決方案

 public async Task<IActionResult> OnPostAsync()
        {
            if (!ModelState.IsValid)
            {
                return Page();

            }
            _context.Attach(Book).State = EntityState.Modified;

            try
            {
                await _context.SaveChangesAsync();

            }
            catch (DbUpdateConcurrencyException)
            {
                if (!_context.Book.Any(e => e.ID == Book.ID))

                {
                    return NotFound();
                }
                else
                {
                    throw;
                }
            }
            return RedirectToPage("./Index");
        }

2.在Visual Studio 2017中按F5運行應用程式。在瀏覽器中瀏覽書籍信息，併在書籍列表頁面中選擇一條書籍信息。我們假設有兩個用戶要對此條書籍信息進行編輯。首先是管理員，對此條書籍信息修改了“Publishing”的信息。如下圖。

3.在管理員單擊“Save”按鈕之前，Test用戶訪問了相同頁面，並將“出版日期”修改為了“2018-01-08”。如下圖。

4.Test用戶先單擊“保存”，併在瀏覽器的書籍信息列表頁面中看到了他修改的出版日期數據保存到了資料庫。如下圖。

5.此時，管理員單擊“編輯”頁面上的“保存”，但頁面的上的“出版日期”還是“2018-01-13”，按照“客戶端優化”規則會把Test用戶的修改覆蓋掉。如下圖。

二、存儲優先

接下去我們來看看“存儲優先”方案。此方法可確保用戶在未收到警報時不會覆蓋任何更改。

首先我們來瞭解三組值：

“當前值”是應用程式嘗試寫入資料庫的值。
“原始值”是在進行任何編輯之前最初從資料庫中檢索的值。
“資料庫值”是當前存儲在資料庫中的值。

處理併發衝突的常規方法是：

1）在 SaveChanges 期間捕獲 DbUpdateConcurrencyException。

2）使用 DbUpdateConcurrencyException.Entries 為受影響的實體準備一組新更改。

3）刷新併發令牌的原始值以反映資料庫中的當前值。

4）重試該過程，直到不發生任何衝突。

下麵的示例，使用時間戳作為行級版本號。

1. 在Visual Studio 2017的“解決方案資源管理器”中使用滑鼠左鍵雙擊打開 Models /Book.cs文件，對User實體添加跟蹤屬性RowVersion，併在其上添加Timestamp特性。代碼如下:

using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.Linq;
using System.Threading.Tasks; 

namespace RazorMvcBooks.Models
{

    public class Book
    { 

        public int ID { get; set; }
        [Required]
        [StringLength(50, MinimumLength = 2)]

        public string Name { get; set; }
        [Display(Name = "出版日期")]
        [DataType(DataType.Date)]

        public DateTime ReleaseDate { get; set; }
        [Range(1,200)]
        [DataType(DataType.Currency)]
        public decimal Price { get; set; }

        public string Author { get; set; }

        [ Required]
        public string Publishing { get; set; }
        [Timestamp]
        public byte[] RowVersion { get; set; }
    }

}

2.在Visual Studio 2017中選擇“菜單>Nuget包管理器>程式包管理器控制台”，然後在打開的程式包管理器控制台依次執行以下命令

Add-Migration RowVer

Update-Database

3.在SQL Server Management Studio中查看Book表。如下圖。

4.在Visual Studio 2017的“解決方案資源管理器”中使用滑鼠左鍵雙擊打開 Pages/Books/Edit.cshtml.cs文件，對OnPostAsync方法進行修改。Entity Framework Core 使用包含原始 RowVersion 值的 WHERE 子句生成 SQL UPDATE 命令。如果沒有行受到 UPDATE 命令影響（沒有行具有原始 RowVersion 值），將引發 DbUpdateConcurrencyException 異常。代碼如下:

  public async Task<IActionResult> OnPostAsync()
        {

            if (!ModelState.IsValid)
            {
                return Page();
            }

            var updBook = _context.Book.AsNoTracking().Where(u => u.ID == Book.ID).First();
            // 如果為null，則當前用戶信息已經被 刪除
            if (updBook == null)
            {
                return HandDeleteBook();
            }

            _context.Attach(Book).State = EntityState.Modified;
            if (await TryUpdateModelAsync<Book>(
                Book,
                "Book",
                s => s.Name, s =>s.Publishing, s => s.ReleaseDate, s => s.Price))

            {

                try
                {

                    await _context.SaveChangesAsync();
                    return RedirectToPage("./Index");
                }

                catch (DbUpdateConcurrencyException ex)
                {

                    var exceptionEntry = ex.Entries.Single();
                    var clientValues = (Book)exceptionEntry.Entity;
                    var databaseEntry = exceptionEntry.GetDatabaseValues();

                    if (databaseEntry == null)
                    {
                        ModelState.AddModelError(string.Empty, "保存失敗！.當前用戶信息已經被刪除");
                        return Page();
                    }

                    var dbValues = (Book)databaseEntry.ToObject();
                    setDbErrorMessage(dbValues, clientValues, _context);
                    //用資料庫中的 RowVersion 值設置為當前實體對象客戶端界面中的RowVersion值。 用戶下次單擊“保存”時，將僅捕獲最後一次顯示編輯頁後發生的併發錯誤。

                    Book.RowVersion = (byte[])dbValues.RowVersion;
                    //ModelState 具有舊的 RowVersion 值，因此需使用 ModelState.Remove 語句。 在 Razor 頁面中，
                    //當兩者都存在時，欄位的 ModelState 值優於模型屬性值。           

                    ModelState.Remove("Book.RowVersion");
                }
            }

            return Page();
        }

        private PageResult HandDeleteBook()
        {
            Book deletedDepartment = new Book();
            ModelState.AddModelError(string.Empty,
                "保存失敗！.當前書籍信息已經被刪除！");
            return Page();

        }

6.在Edit.cshtml.cs文件，添加setDbErrorMessage方法。為每列添加自定義錯誤消息，當這些列中的資料庫值與客戶端界面上的值不同時，給出相應的錯誤信息。代碼如下:

   private void setDbErrorMessage(Book dbValues,
                Book clientValues, BookContext context)
        {

            if (dbValues.Name != clientValues.Name)
            {
                ModelState.AddModelError("Book.Name",
                    $"資料庫值: {dbValues.Name}");
            }

            if (dbValues.Publishing != clientValues.Publishing)
            {
                ModelState.AddModelError("Book.Publishing",
                    $"資料庫值: {dbValues.Publishing}");
            }

            if (dbValues.ReleaseDate != clientValues.ReleaseDate)
            {
                ModelState.AddModelError("Book.ReleaseDate",
                    $"資料庫值: {dbValues.ReleaseDate}");
            }
            if (dbValues.Price != clientValues.Price)
            {

                ModelState.AddModelError("Book.Price",
                    $"資料庫值: {dbValues.Price}");
            }
            ModelState.AddModelError(string.Empty,"您嘗試編輯的書籍信息記錄被另一個用戶修改了。編輯操作被取消，"
+ "資料庫中的當前值已經顯示。如果仍想編輯此記錄，請單擊“保存”按鈕。");

        }