學習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,"您嘗試編輯的書籍信息記錄被另一個用戶修改了。編輯操作被取消，"
+ "數據庫中的當前值已經顯示。如果仍想編輯此記錄，請單擊“保存”按鈕。");

        }

7.在Visual Studio 2017的“解決方案資源管理器”中使用鼠標左鍵雙擊打開 Pages/Books/Edit.cshtml文件， <form method="post">標簽下面添加添加隱藏的行版本。必須添加 RowVersion，以便回發綁定值。

<input type="hidden" asp-for="Book.RowVersion" />

8.在Visual Studio 2017中按F5運行應用程序。使用兩個瀏覽器打開同一條書籍信息記錄進行編輯，此時兩個瀏覽器顯示的書籍信息是一樣的。瀏覽器1中的書籍信息界面。在修改了“Publishing”的數據由“清華大學出版社”修改為“機械工業出版社”，然后點擊“Save”按鈕。如下圖。

9.在瀏覽器中單擊“保存”之后，瀏覽器會自動跳轉到書籍信息列表頁面中看到了所修改的“Publishing”數據保存到了數據庫。如下圖。

10.在第二個瀏覽器中，修改“出版日期”的值，由“2018-01-13”改為“2018-01-08”。如下圖。

11.然后使用單擊“ Save”按鈕。此時由於客戶端界面上的信息與數據庫中的值不一樣，所以會出現錯誤提示信息。如下圖。

12. 把“Publishing”修改為“機械工業出版社”，再次單擊“保存”，將第二個瀏覽器中輸入的值保存到數據庫。瀏覽器自動跳轉到書籍信息列表，可以看到保存的值。如下圖。

13.當然如果你不做任何修改，再次點擊保存，也會把當前頁面上的數據保存到數據庫中。如下圖。

免責聲明！

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