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)
{
//執行異常處理
}
}