Simultaneous Changes開放式併發控制
下表介紹 LINQ to SQL 文檔中涉及開放式併發的術語:
術語 | 說明 |
併發 | 兩個或更多使用者同時嘗試更新同一資料庫行的情形。 |
併發衝突 | 兩個或更多用戶同時嘗試向一行的一列或多列提交衝突值的情形。 |
併發控制 | 用於解決併發衝突的技術。 |
開放式併發控制 | 先調查其他事務是否已更改了行中的值,再允許提交更改的技術。相比之下,保守式併發控制則是通過鎖定記錄來避免發生併發衝突。之所以稱作開放式控制,是因為它將一個事務干擾另一事務視為不太可能發生。 |
衝突解決 | 通過重新查詢資料庫刷新出現衝突的項,然後協調差異的過程。刷新物件時,LINQ to SQL 更改跟蹤器會保留以下資料: 最初從資料庫獲取並用於更新檢查的值 通過後續查詢獲得的新資料庫值。 LINQ to SQL 隨後會確定相應物件是否發生衝突(即它的一個或多個成員值是否已發生更改)。如果此物件發生衝突,LINQ to SQL 下一步會確定它的哪些成員發生衝突。LINQ to SQL 發現的任何成員衝突都會添加到衝突清單中。 |
在 LINQ to SQL 物件模型中,當以下兩個條件都得到滿足時,就會發生“開放式併發衝突”:用戶端嘗試向資料庫提交更改;資料庫中的一個或多個更新檢查值自用戶端上次讀取它們以來已得到更新。 此衝突的解決過程包括查明物件的哪些成員發生衝突,然後決定您希望如何進行處理。
開放式併發(Optimistic Concurrency)
說明:這個例子中在你讀取資料之前,另外一個使用者已經修改並提交更新了這個資料,所以不會出現衝突。
//我們打開一個新的連接來模擬另外一個用戶 NorthwindDataContext otherUser_db = new NorthwindDataContext(); var otherUser_product = otherUser_db.Products .First(p => p.ProductID == 1); otherUser_product.UnitPrice = 999.99M; otherUser_db.SubmitChanges(); //我們當前連接 var product = db.Products.First(p => p.ProductID == 1); product.UnitPrice = 777.77M; try { db.SubmitChanges(); //當前連接執行成功 } catch (ChangeConflictException){ }
說明:我們讀取資料之後,另外一個使用者獲取並提交更新了這個資料,這時,我們更新這個資料時,引起了一個併發衝突。系統發生回滾,允許你可以從資料庫檢索新更新的資料,並決定如何繼續進行您自己的更新。
//當前用戶 var product = db.Products.First(p => p.ProductID == 1); //我們打開一個新的連接來模擬另外一個用戶 NorthwindDataContext otherUser_db = new NorthwindDataContext() ; var otherUser_product = otherUser_db.Products.First(p => p.ProductID == 1); otherUser_product.UnitPrice = 999.99M; otherUser_db.SubmitChanges(); //當前用戶修改 product.UnitPrice = 777.77M; try { db.SubmitChanges(); }catch (ChangeConflictException) { //發生異常! }
Transactions事務
LINQ to SQL 支援三種事務模型,分別是:
• 顯式本地事務:
調用 SubmitChanges 時,如果 Transaction 屬性設置為事務,則在同一事務的上下文中執行 SubmitChanges 調用。成功執行事務後,要由您來提交或回滾事務。與事務對應的連接必須與用於構造 DataContext 的連接匹配。如果使用其他連接,則會引發異常。
• 顯式可分發事務:
可以在當前 Transaction 的作用域中調用 LINQ to SQL API(包括但不限於 SubmitChanges)。LINQ to SQL 檢測到調用是在事務的作用域內,因而不會創建新的事務。在這種情況下,<token>vbtecdlinq</token> 還會避免關閉連接。您可以在此類事務的上下文中執行查詢和 SubmitChanges 操作。
• 隱式事務:
當您調用 SubmitChanges 時,LINQ to SQL 會檢查此調用是否在 Transaction 的作用域內或者 Transaction 屬性是否設置為由使用者啟動的本地事務。如果這兩個事務它均未找到,則 LINQ to SQL 啟動本地事務,並使用此事務執行所生成的 SQL 命令。當所有 SQL 命令均已成功執行完畢時,LINQ to SQL 提交本地事務並返回。
1.Implicit(隱式)
說明:這個例子在執行SubmitChanges()操作時,隱式地使用了事務。因為在更新2種產品的庫存數量時,第二個產品庫存數量為負數了,違反了伺服器上的 CHECK 約束。這導致了更新產品全部失敗了,系統回滾到這個操作的初始狀態。
try { Product prod1 = db.Products.First(p => p.ProductID == 4); Product prod2 = db.Products.First(p => p.ProductID == 5); prod1.UnitsInStock -= 3; prod2.UnitsInStock -= 5; //錯誤:庫存數量的單位不能是負數 //要麼全部成功要麼全部失敗 db.SubmitChanges(); }catch (System.Data.SqlClient.SqlException e) { //執行異常處理 }
2.Explicit(顯式)
說明:這個例子使用顯式事務。通過在事務中加入對資料的讀取以防止出現開放式併發異常,顯式事務可以提供更多的保護。如同上一個查詢中,更新 prod2 的 UnitsInStock 欄位將使該欄位為負值,而這違反了資料庫中的 CHECK 約束。這導致更新這兩個產品的事務失敗,此時將回滾所有更改。
using (TransactionScope ts = new TransactionScope()) { try { Product prod1 = db.Products .First(p => p.ProductID == 4); Product prod2 = db.Products .First(p => p.ProductID == 5); prod1.UnitsInStock -= 3; prod2.UnitsInStock -= 5; //錯誤:庫存數量的單位不能是負數 db.SubmitChanges(); } catch (System.Data.SqlClient.SqlException e) { //執行異常處理 } }