首页 / C# / Linq to sql并发与事务

Linq to sql并发与事务

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Linq to sql并发与事务，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4914字，纯文字阅读大概需要8分钟。

内容图文

本文转载：http://www.cnblogs.com/lovecherry/archive/2007/08/20/862365.html

检测并发

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

来测试一下，假设现在产品价格和库存分别是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();语句。来测试一下，在执行了SQL后再继续程序可以发现界面上只输出了数字1，说明在第一条记录失败后，后续的并发冲突就不再处理了。

事务处理

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

}

原文：http://www.cnblogs.com/zfanlong1314/p/3552613.html

内容总结

以上是互联网集市为您收集整理的Linq to sql并发与事务全部内容，希望文章能够帮你解决Linq to sql并发与事务所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1097636.html

来源：【匿名】

【上一篇】C#常见问题总结（二）【下一篇】assemblyinfo.csC#Assembly类访问程序集信息

更多 ►

【Linq to sql并发与事务】教程文章相关的互联网学习教程文章

c#事务处理（sqlTransaction）【代码】

事务：///<summary>/// 删除考勤///</summary>///<param name="dto">Id</param>///<returns></returns>public ResultEntity<bool> DeleteAttend(DelAttendEditorDTO dto){//SqlConnection con = new SqlConnection(@"Data Source=.SQLEXPRESS;database=aaaa;uid=sa;pwd=jcx");//con.Open();using (var context = new HRModelsContainer()){var trans = context.Database.BeginTransaction();try{foreach (var Id in dto.Ids){//先删...

C# 事务之SqlTransaction【代码】

privatestaticvoid Execute(string connectionString){using (SqlConnection connection = new SqlConnection(connectionString)){connection.Open();SqlTransaction transaction;using (SqlCommand cmd = connection.CreateCommand()){//启动事务transaction = connection.BeginTransaction();cmd.Connection = connection;cmd.Transaction = transaction;try{cmd.CommandText = "sql语句！";cmd.ExecuteNonQuery();//完成提交 ...

ACCESS数据库C#操作类（包含事务）

转自http://blog.csdn.net/allen3010/article/details/6336717 这个是针对ACCESS数据库操作的类，同样也是从SQLHELPER提取而来，分页程序的调用可以参考MSSQL那个类的调用，差不多的，只是提取所有记录的数量的时候有多一个参数，这个需要注意一下！c# 代码using System;? ? using System.Text;? ? using System.Collections;? ? using System.Collections.Specialized;? ? using System.Data;? ? using System.Data.OleDb;? ? usi...

C#事务的使用【代码】

1.引入相应的命名空间using System.Transactions;2.代码事例(using (TransactionScope ts = new TransactionScope())) 1public JsonResult DriverCommentAdd(OrderComment orderComment)2 {3 4try 5 {6using (TransactionScope ts = new TransactionScope())7 {8var order = db.Orders.SingleOrDefault(p => p.ID == orderComment.OrderID);9if (order.OrderStatus == (byte)OrderStatus.Command...

Linq to sql并发与事务

本文转载：http://www.cnblogs.com/lovecherry/archive/2007/08/20/862365.html检测并发首先使用下面的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 qu...

c#访问数据库的两种方法以及事务的两种方法【代码】

1//2015/07/03 2using System;3using System.Collections.Generic;4using System.Linq;5using System.Text;6using System.Threading.Tasks;7using System.Data;8using System.Data.SqlClient;910namespace Ado.netstart_1 11{ 12class Program 13 { 14staticvoid Main(string[] args) 15 { 16//特殊的字符串，数据库连接串 17//第一种18string connectionString = "server=.;database=BookSample;uid=LJK;pwd=123456;"; ...

C#事务【代码】

关于业务有涉及到事务的，例子简单使用，就基本知识而已。只是EF的版本不同，写法不同罢了。 1using (var trans = _db.Database.BeginTransaction()) //EF 6.0版本；EF 4.0版本是：_db.Database.Connection.BeginTransaction() 2{3 4//业务逻辑代码 5 6 _db.Entry<Model>(model).State = System.Data.Entity.EntityState.Add;7}8}9try10{ 11_db.SaveChanges(); 12trans.Commit(); 13} 14catch (Exception) 15{ 16trans.Rollback();...

【读书笔记】C#高级编程第二十五章事务处理【代码】

（一）简介事务的主要特征是，任务要么全部完成，要么都不完成。（二）概述事务由事务管理器来管理和协调。每个影响事务结果的资源都由一个资源管理器来管理。事务管理器与资源管理器通信，以定义事务的结果。 1、事务处理阶段激活阶段：在这个阶段创建事务。准备阶段：在这个阶段，每个资源管理器都可以定义事务的结果。提交阶段：当所有的资源管理器都成功准备好了，就开始这个阶段。 2、ACID属性事务的特征可以用术语ACID来定...

c# 执行事务函数代码

代码如下:/// <summary> /// 执行多条sql语句，实现事务 /// </summary> /// <param name="arraySql">多条sql语句</param> public int ExecutrSqlTran(System.Collections.ArrayList arraySql) { int itemnum; DbOpen(); SqlCommand cm = new SqlCommand(); cm.Connection = scn; SqlTransaction tx = scn.BeginTransaction(); cm.Transaction = tx; try { for (int i = 0; i < arraySql.Count; i++) { string strSql = arraySql[i...

c#访问数据库的两种方法以及事务的两种方法

//2015/07/032 using System;3 using System.Collections.Generic;4 using System.Linq;5 using System.Text;6 using System.Threading.Tasks;7 using System.Data;8 using System.Data.SqlClient;9 10 namespace Ado.netstart_1 11 { 12 class Program 13 { 14 static void Main(string[] args) 15 { 16 //特殊的字符串，数据库连接串 17 //第一种 18 string conne...

C# 执行多条SQL更新语句，实现数据库事务

Program{class Result<T>{public T data;public string Message;public bool Success;public string StackTrace;}struct ExecuteableUnit{public string SQL;public SqlParameter[] param;}/// <summary>/// 执行多条SQL语句，实现数据库事务。/// </summary>/// <param name="SQLStringList">SQL语句的哈希表（key为sql语句，value是该语句的SqlParameter[]）</param>private static Result<int> ExecuteSqlTransaction(params Ex...

C# 事务之SqlTransaction

static void Execute(string connectionString){using (SqlConnection connection = new SqlConnection(connectionString)){connection.Open();SqlTransaction transaction;using (SqlCommand cmd = connection.CreateCommand()){//启动事务transaction = connection.BeginTransaction();cmd.Connection = connection;cmd.Transaction = transaction;try{cmd.CommandText = "sql语句！";cmd.ExecuteNonQuery();//完成提交transacti...

C#实现执行数据库事务案例【代码】

static bool CreateUserOrder(UserOrder model, string Ids){List<string> SQLStringList = new List<string>();List<DbParameter[]> Parameters = new List<DbParameter[]>();StringBuilder strSql = new StringBuilder();//添加OrderInforSqlParameter[] parameters1 = OrderInforDAL.BuildOrderInforAddParameter(model.UserId, model.OrderCode, Ids, ref strSql);SQLStringList.Add(strSql.ToString());Parameters.Add(parame...

C#执行SQL事务用法实例【图】

using System; using System.Collections.Generic; using System.Linq; using System.Web; using System.Web.UI; using System.Web.UI.WebControls; using System.Configuration; using System.Data.SqlClient; namespace 用户激活 { public partial class WebForm3 : System.Web.UI.Page { protected void Page_Load(object sender, EventArgs e) { } protected void Button1_Click(object sender, EventArgs e) { ...

C#调用事务执行sql语句【代码】

#region 调用事务 public static bool UpdateByTran(List sqlList) { SqlConnection conn = new SqlConnection(connString); SqlCommand cmd = new SqlCommand(); cmd.Connection = conn; try { conn.Open(); //开启事务 cmd.Transaction = conn.BeginTransaction(); //遍历所有sql语句,依次执行 foreach (string item in sqlList) { cmd.CommandText = item; cmd.ExecuteNonQuery(); } //如果全部执行完毕,提交事务 cmd.Transacti...

首页 / C# / Linq to sql并发与事务

Linq to sql并发与事务

内容导读

内容图文

内容总结

内容备注

内容手机端

【Linq to sql并发与事务】教程文章相关的互联网学习教程文章

事务 - 相关标签

C# - 技术教程分类

C# - 最新教程

C# - 最热教程