Linq to sql并發與事務

檢測并發

       首先使用下面的SQL語句查詢資料庫的産品表：

select * from products where categoryid=1

       查詢結果如下圖：

       為了看起來清晰，我已經事先把所有分類為1産品的價格和庫存修改為相同值了。然後執行下面的程式：

        var query = from p in ctx.Products where p.CategoryID == 1 select p;

        foreach (var p in query)

            p.UnitsInStock = Convert.ToInt16(p.UnitsInStock - 1);

        ctx.SubmitChanges(); // 在這裡設斷點

       我們使用調試方式啟動，由于設定了斷點，程式并沒有進行更新操作。此時，我們在資料庫中運作下面的語句：

update products

set unitsinstock = unitsinstock -2, unitprice= unitprice + 1

where categoryid = 1

       然後在繼續程式，會得到修改并發（樂觀并發沖突）的異常，提示要修改的行不存在或者已經被改動。當用戶端送出的修改對象自讀取之後已經在資料庫中發生改動，就産生了修改并發。解決并發的包括兩步，一是查明哪些對象發生并發，二是解決并發。如果你僅僅是希望更新時不考慮并發的話可以關閉相關列的更新驗證，這樣在這些列上發生并發就不會出現異常：

[Column(Storage="_UnitsInStock", DbType="SmallInt", UpdateCheck = UpdateCheck.Never)]

[Column(Storage="_UnitPrice", DbType="Money", UpdateCheck = UpdateCheck.Never)]

       為這兩列标注不需要進行更新檢測。假設現在産品價格和庫存分别是27和32。那麼，我們啟動程式（設定端點），然後運作UPDATE語句，把價格+1，庫存-2，然後價格和庫存分别為28和30了，繼續程式可以發現價格和庫存分别是28和31。價格+1是之前更新的功勞，庫存最終是-1是我們程式之後更新的功勞。當在同一個字段上（庫存）發生并發沖突的時候，預設是最後的那次更新獲勝。

解決并發

       如果你希望自己處理并發的話可以把前面對列的定義修改先改回來，看下面的例子：

        try

        {

            ctx.SubmitChanges(ConflictMode.ContinueOnConflict);

        }

        catch (ChangeConflictException)

            foreach (ObjectChangeConflict cc in ctx.ChangeConflicts)

            {

                Product p = (Product)cc.Object;

                Response.Write(p.ProductID + "<br/>");

                cc.Resolve(RefreshMode.OverwriteCurrentValues); // 放棄目前更新，所有更新以原先更新為準

            }

        ctx.SubmitChanges();

       首先可以看到，我們使用try{}catch{}來捕捉并發沖突的異常。在SubmitChanges的時候，我們選擇了ConflictMode.ContinueOnConflict選項。也就是說遇到并發了還是繼續。在catch{}中，我們從ChangeConflicts中擷取了并發的對象，然後經過類型轉化後輸出了産品ID，然後選擇的解決方案是RefreshMode.OverwriteCurrentValues。也就是說，放棄目前的更新，所有更新以原先更新為準。

       我們來測試一下，假設現在産品價格和庫存分别是27和32。那麼，我們啟動程式（在ctx.SubmitChanges(ConflictMode.ContinueOnConflict)這裡設定端點），然後運作UPDATE語句，把價格+1，庫存-2，然後價格和庫存分别為28和30了，繼續程式可以發現價格和庫存分别是28和30。之前SQL語句庫存-2生效了，而我們程式的更新（庫存-1）被放棄了。在頁面上也顯示了所有分類為1的産品ID（因為我們之前的SQL語句是對所有分類為1的産品都進行修改的）。

       然後，我們來修改一下解決并發的方式：

cc.Resolve(RefreshMode.KeepCurrentValues); // 放棄原先更新，所有更新以目前更新為準

       來測試一下，假設現在産品價格和庫存分别是27和32。那麼，我們啟動程式（在ctx.SubmitChanges(ConflictMode.ContinueOnConflict)這裡設定端點），然後運作UPDATE語句，把價格+1，庫存-2，然後價格和庫存分别為28和30了，繼續程式可以發現價格和庫存分别是27和31。産品價格沒有變化，庫存-1了，都是我們程式的功勞，SQL語句的更新被放棄了。

       然後，我們再來修改一下解決并發的方式：

cc.Resolve(RefreshMode.KeepChanges); // 原先更新有效，沖突字段以目前更新為準

       來測試一下，假設現在産品價格和庫存分别是27和32。那麼，我們啟動程式（在ctx.SubmitChanges(ConflictMode.ContinueOnConflict)這裡設定端點），然後運作UPDATE語句，把價格+1，庫存-2，然後價格和庫存分别為28和30了，繼續程式可以發現價格和庫存分别是28和31。這就是預設方式，在保持原先更新的基礎上，對于發生沖突的字段以最後更新為準。

       我們甚至還可以針對不同的字段進行不同的處理政策：

foreach (ObjectChangeConflict cc in ctx.ChangeConflicts)

{

    Product p = (Product)cc.Object;

    foreach (MemberChangeConflict mc in cc.MemberConflicts)

    {

        string currVal = mc.CurrentValue.ToString();

        string origVal = mc.OriginalValue.ToString();

        string databaseVal = mc.DatabaseValue.ToString();

        MemberInfo mi = mc.Member;

        string memberName = mi.Name;

        Response.Write(p.ProductID + " " + mi.Name + " " + currVal + " " + origVal +" "+ databaseVal + "<br/>");

        if (memberName == "UnitsInStock")

            mc.Resolve(RefreshMode.KeepCurrentValues); // 放棄原先更新，所有更新以目前更新為準

        else if (memberName == "UnitPrice")

            mc.Resolve(RefreshMode.OverwriteCurrentValues); // 放棄目前更新，所有更新以原先更新為準

        else

            mc.Resolve(RefreshMode.KeepChanges); // 原先更新有效，沖突字段以目前更新為準

    }

}

       比如上述代碼就對庫存字段作放棄原先更新處理，對價格字段作放棄目前更新處理。我們來測試一下，假設現在産品價格和庫存分别是27和32。那麼，我們啟動程式（在ctx.SubmitChanges(ConflictMode.ContinueOnConflict)這裡設定端點），然後運作UPDATE語句，把價格+1，庫存-2，然後價格和庫存分别為28和30了，繼續程式可以發現價格和庫存分别為28和31了。說明對價格的處理确實保留了原先的更新，對庫存的處理保留了目前的更新。頁面上顯示的結果如下圖：

最後，我們把送出語句修改為：

ctx.SubmitChanges(ConflictMode.FailOnFirstConflict);

       表示第一次發生沖突的時候就不再繼續了，然後并且去除最後的ctx.SubmitChanges();語句。來測試一下，在執行了SQL後再繼續程式可以發現界面上隻輸出了數字1，說明在第一條記錄失敗後，後續的并發沖突就不再處理了。

事務處理

       Linq to sql在送出更新的時候預設會建立事務，一部分修改發生錯誤的話其它修改也不會生效：

        ctx.Customers.Add(new Customer { CustomerID = "abcdf", CompanyName = "zhuye" });

        ctx.Customers.Add(new Customer { CustomerID = "abcde", CompanyName = "zhuye" });

       假設資料庫中已經存在顧客ID為“abcde”的記錄，那麼第二次插入操作失敗将會導緻第一次的插入操作失效。執行程式後會得到一個異常，查詢資料庫發現“abcdf”這個顧客也沒有插入到資料庫中。

       如果每次更新後直接送出修改，那麼我們可以使用下面的方式做事務：

        if (ctx.Connection != null) ctx.Connection.Open();

        DbTransaction tran = ctx.Connection.BeginTransaction();

        ctx.Transaction = tran;

            CreateCustomer(new Customer { CustomerID = "abcdf", CompanyName = "zhuye" });

            CreateCustomer(new Customer { CustomerID = "abcde", CompanyName = "zhuye" });

            tran.Commit();

        catch

            tran.Rollback();

    private void CreateCustomer(Customer c)

        ctx.Customers.Add(c);

       運作程式後發現增加顧客abcdf的操作并沒有成功。或者，我們還可以通過TransactionScope實作事務：

        using (TransactionScope scope = new TransactionScope())

            scope.Complete();