并行事务同时更新同一条记录
程序大概代码。
sql语句
首先调试程序，等程序断下来之后，在浏览器重新发起一次请求，模拟双线程。这时调试窗口有线程(ps:这里用到的是mysql自带的连接池)
事务开始但还没更新该记录时，该行还未被锁定，这是还可以更新
这时6号线程下一步就执行更新操作了
6号线程执行完之后，由于事务ID为14的记录被锁定，可以看到已经不能修改了，在排队等待事务关闭，如果等待过久直接取消这次操作
这时8号线程也在执行更新ID为14的操作，但是由于上一个事务未关闭，导致被锁，在排队等待。
可以看到mysql取消操作了。
已经异常了，而且连接已经关闭了
这时手动释放事务，由于是连接池，调用Close()并不是真正关闭连接只是放回连接池。所以要释放事务，不然下次获得该连接时会出错。而且还会导致死锁。
最后，总结并行事务第一个事务会锁住更新的记录，下一个事务操作(更新或删除)该记录时排队等待上一个事务释放锁，如果等待过长会取消操作，并且抛出异常，捕获异常进行相应的操作回滚事务或关闭连接释放锁，不然会导致死锁。并且上一个事务提交之后，下一个事务的回滚不会影响到上一个事务的操作。
1 string connString = "Server=localhost;Database=test;Uid=root;Pwd=root;Charset=utf8;pooling=true;Min Pool Size=2;Max Pool Size=20;"; 2 MySqlConnection con = new MySqlConnection(connString); 3 con.Open(); 4 Random r = new Random(); 5 int n = r.Next(100); 6 7 string sql = "update Nc_A set name='gfeng"+n.ToString()+"' where id=14"; 8 MySqlCommand com = new MySqlCommand(sql, con); 9 MySqlTransaction tran = con.BeginTransaction(); 10 try 11 { 12 int rowcount = com.ExecuteNonQuery(); 13 int k = 0; 14 int jk = 0; 15 int jk2 = 0; 16 if (HttpContext.Cache["n"] == null) 17 { 18 tran.Commit(); 19 HttpContext.Cache["n"] = n; 20 } 21 else 22 { 23 tran.Rollback(); 24 } 25 26 con.Close(); 27 } 28 catch 29 { 30 con.Close(); 31 }
当然不是更新同一条记录是各不影响的。主要还是要理解锁和事务的机制(之间是有区别的，用事务比用锁性能要低，毕竟要悬挂事务用于回滚或提交)。
智能推荐
注意！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系我们删除。