Linq to SQL 语法记录....并发写事务

检测并发

首先使用下面的SQL语句查询数据库的产品表：

select * from products where categoryid=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); // 放弃原先更新，所有更新以当前更新为准

假设现在产品价格和库存分别是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();语句。说明在第一条记录失败后，后续的并发冲突就不再处理了。

事务处理

Linq to sql在提交更新的时候默认会创建事务，一部分修改发生错误的话其它修改也不会生效：

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

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

ctx.SubmitChanges();

假设数据库中已经存在顾客ID为“abcde”的记录，那么第二次插入操作失败将会导致第一次的插入操作失效。执行程序后会得到一个异常，查询数据库发现“abcdf”这个顾客也没有插入到数据库中。

如果每次更新后直接提交修改，那么可以使用下面的方式做事务：

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

DbTransaction tran = ctx.Connection.BeginTransaction();

ctx.Transaction = tran;

try

{

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);

ctx.SubmitChanges();

}

运行程序后发现增加顾客abcdf的操作并没有成功。或者，还可以通过TransactionScope实现事务：

using (TransactionScope scope = new TransactionScope())

{

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

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

scope.Complete();

}

转载于:https://www.cnblogs.com/cryloo/archive/2008/10/21/1316094.html

Linq to SQL 语法记录....并发写事务相关推荐

FreeSql （二十四）Linq To Sql 语法使用介绍
原本不支持 IQueryable 主要出于使用习惯的考虑,如果继承 IQueryable,编写代码的智能总会提示出现一堆你不想使用的方法(对不起,我有强迫症),IQueryable 自身提供了一堆没法 ...
在Linq to Sql中管理并发更新时的冲突（3）：使用记录的时间戳进行检测
我们描述了Linq to Sql检测在更新时是否产生了冲突的基本方法:将该记录每个字段原来的值和更新时的值进行对比,如果稍有不同则意味着记录被修改过,因此产生了更新冲突.不过您是否有这样的感觉,这种方 ...
LINQ To SQL 语法及实例大全
LINQ to SQL语句(1)之Where Where操作适用场景:实现过滤,查询等功能. 说明:与SQL命令中的Where作用相似,都是起到范围限定也就是过滤作用的,而判断条件就是它后面所接的子 ...
【SQL语法基础】初识事务隔离：隔离的级别有哪些，它们都解决了哪些异常问题？
上一篇文章中,我们讲到了事务的四大特性 ACID,分别是原子性.一致性.隔离性和持久性,其中隔离性是事务的基本特性之一,它可以防止数据库在并发处理时出现数据不一致的情况.最严格的情况下,我们可以采用串 ...
转载:LINQ to SQL更新数据库操作
翻译整理ScottGu的关于LINQ to SQL的Part 4: Updating our Database .该Post讲解了如何使用LINQ to SQL更新数据库,以及如何整合业务逻辑和自定义 ...
ScottGu之博客翻译－LINQ to SQL第四部分，更新数据库 LINQ to SQL (Part 4 - Updating our Database)...
原贴链接: http://weblogs.asp.net/scottgu/archive/2007/07/11/linq-to-sql-part-4-updating-our-database.asp ...
手把手教你用好LINQ to SQL(1)
From: http://developer.51cto.com/art/200904/120915.htm 作者写下这篇文章的主要目的不是"一口吃成个胖子"让大家一次就学会LIN ...
LINQ to SQL之Step by Step及新手问题小结
前言最近接连遇到几个朋友问我同一个问题,就是关于.NET平台上ORM框架的选择.我想在这个讲求效率的时代,谁也不想手写SQL或存储过程去访问数据库了.大家都知道,在Java平台上,ORM这一块基本是 ...
是否会成为问题——Linq to Sql的执行可能无法复用查询计划
查询计划 Sql Server在执行一条查询语句之前都对对它进行"编译"并生成"查询计划",查询计划告诉Sql Server的查询引擎应该用什么方式进行工作.S ...

Linq to SQL 语法记录....并发写事务

Linq to SQL 语法记录....并发写事务相关推荐

最新文章

热门文章