Linq to sql：并发与事务

作者：lovecherry博客 2008-01-16

内容导航：

【IT168技术文档】

检测并发

首先使用下面的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是我们程序之后更新的功劳。当在同一个字段上（库存）发生并发冲突的时候，默认是最后的那次更新获胜。

解决并发

如果你希望自己处理并发的话可以把前面对列的定义修改先改回来，看下面的例子：

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);
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); // 放弃原先更新，所有更新以当前更新为准

1 2 3

【内容导航】

第1页：概述	第2页：概述
第3页：概述

[责任编辑：nancy]

进入论坛>>相关论坛贴

热点文章排行