下表介绍 LINQ to SQL 文档中涉及开放式并发的术语:数据库
术语 | 说明 |
---|---|
并发 | 两个或更多用户同时尝试更新同一数据库行的情形。 |
并发冲突 | 两个或更多用户同时尝试向一行的一列或多列提交冲突值的情形。 |
并发控制 | 用于解决并发冲突的技术。 |
开放式并发控制 | 先调查其余事务是否已更改了行中的值,再容许提交更改的技术。相比之下,保守式并发控制则是经过锁定记录来避免发生并发冲突。之因此称做开放式控制,是由于它将一个事务干扰另外一事务视为不太可能发生。 |
冲突解决 | 经过从新查询数据库刷新出现冲突的项,而后协调差别的过程。刷新对象时,LINQ to SQL 更改跟踪器会保留如下数据: 最初从数据库获取并用于更新检查的值 经过后续查询得到的新数据库值。 LINQ to SQL 随后会肯定相应对象是否发生冲突(即它的一个或多个成员值是否已发生更改)。若是此对象发生冲突,LINQ to SQL 下一步会肯定它的哪些成员发生冲突。LINQ to SQL 发现的任何成员冲突都会添加到冲突列表中。 |
在 LINQ to SQL 对象模型中,当如下两个条件都获得知足时,就会发生“开放式并发冲突”:客户端尝试向数据库提交更改;数据库中的一个或多个更新检查值自客户端上次读取它们以来已获得更新。 此冲突的解决过程包括查明对象的哪些成员发生冲突,而后决定您但愿如何进行处理。服务器
说明:这个例子中在你读取数据以前,另一个用户已经修改并提交更新了这个数据,因此不会出现冲突。并发
//咱们打开一个新的链接来模拟另一个用户 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) { }
说明:咱们读取数据以后,另一个用户获取并提交更新了这个数据,这时,咱们更新这个数据时,引发了一个并发冲突。系统发生回滚,容许你能够从数据库检索新更新的数据,并决定如何继续进行您本身的更新。spa
//当前用户 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) { //发生异常! }
LINQ to SQL 支持三种事务模型,分别是:code
说明:这个例子在执行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) { //执行异常处理 }
说明:这个例子使用显式事务。经过在事务中加入对数据的读取以防止出现开放式并发异常,显式事务能够提供更多的保护。如同上一个查询中,更新 prod2 的 UnitsInStock 字段将使该字段为负值,而这违反了数据库中的 CHECK 约束。这致使更新这两个产品的事务失败,此时将回滚全部更改。 blog
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) { //执行异常处理 } }