事务、事务并发 - 数据库编程

8L2VtPjwvdT66zTx1PjxlbT48c3Ryb25nPriyuMe4/NDCPC9zdHJvbmc+PC9lbT48L3U+u+G3osn6o6yyorei0NTE3LrDoaO087K/t9bK/b7dv+K1xMSsyM+49MDrvLax8KOssqK3otDUxNy9z7rDoaM8YnI+Cjx1PjxlbT48c3Ryb25nPlJlcGVhdGFibGUgUmVhZL/J1ti4tLbBPC9zdHJvbmc+PC9lbT48L3U+o7rE3LHcw+I8dT48ZW0+PHN0cm9uZz7U4LbBPC9zdHJvbmc+PC9lbT48L3U+us08dT48ZW0+PHN0cm9uZz6yu7/J1ti4tLbBPC9zdHJvbmc+PC9lbT48L3U+o6y1qzx1PjxlbT48c3Ryb25nPrvDtsE8L3N0cm9uZz48L2VtPjwvdT674beiyfqjrLKit6LQ1MTcu+HK3NOwz+yho9bB09o8dT48ZW0+PHN0cm9uZz64srjHuPzQwjwvc3Ryb25nPjwvZW0+PC91PqOs1PLK08r9vt2/4rb4wtuhozxicj4KPHU+PGVtPjxzdHJvbmc+U2VyaWFsaXphYmxl0PLB0LuvPC9zdHJvbmc+PC9lbT48L3U+o7rE3LHcw+I8dT48ZW0+PHN0cm9uZz7U4LbBPC9zdHJvbmc+PC9lbT48L3U+oaI8dT48ZW0+PHN0cm9uZz6yu7/J1ti4tLbBPC9zdHJvbmc+PC9lbT48L3U+us08dT48ZW0+PHN0cm9uZz67w7bBPC9zdHJvbmc+PC9lbT48L3U+o6yyorei0NTE3LLuoaPWwdPaPHU+PGVtPjxzdHJvbmc+uLK4x7j80MI8L3N0cm9uZz48L2VtPjwvdT6jrNTyytPK/b7dv+K2+MLboaMKPGJyPgrV4tH5v7TAtKOsysLO8bj0wOu8trHwusPP8dPrt+LL+NCt0unKx9K70ru21NOmtcSho7bBzrTM4b270+vSu7y2t+LL+NCt0um21NOmoaK2wdLRzOG9u9Prtv68trfiy/jQrdLpttTTpqGiv8nW2Li0tsHT68j9vLa34sv40K3S6bbU06aho7Wrvq25/bG+yMu1xNHp1qSjrNXiuPayu83qyKvV/ci3o6y49MDrvLax8MrH0ru49rnmt7ajrLb4t+LS6dCt0unKx7nmt7a1xNK71tbKtc/Wt73KvaGjscjI5215c3HNrMqxyrnTw8r9vt3Q0LDmsb7T68v4tcS7+tbGwLTKtc/WuPTA67y2sfC1xKOsREIytaW0v8q508PL+LXEu/rWxsC0yrXP1rj0wOu8trHwoaPO0rvh1tjQwtX7wO3Su8aqzsTVwr2yvbK52NPabXlzcWzT60RCMtTauPTA67y2sfC3vcPmtcTPuL3a0+vH+LHwoaM8YnI+Cjxicj4KztLDx9LRvq3WqrXAwcvP4LnYtcTWqsq2sbO+sKOs1NnAtL+0v7TO0sPHz7XNs7XEzsrM4qGjPGJyPgrPtc2zyrnTw7XEysdEQjKjrMv509DWu7bBysLO8cq508NVUrj0wOu8trHwo6jP4LnY09q2wc60zOG9u6Opo6zG5Mv7ysLO8cq508NSU7j0wOu8trHwo6jP4LnY09q/ydbYuLS2waOpoaO74dSxtcTXyrL6uabE3LzytaW9stPQ1Pa807rNv9u89bLZ1/ehozxicj4K1Pa807LZ1/c8YnI+CjxwcmUgY2xhc3M9"brush:sql;">start transaction //第一步，查询账户可用余额 select ... from account where account_id = ... //第二步，余量加上增加量，并赋值给新变量newBalance set newBalance = dbBalance + changeAmount //第三步，更新会员账户记录 update account set balance = newBalance where account_id = ... //第四步，其它操作 commit
扣减操作

start transaction
//第一步，查询账户可用余额
select ... from account where account_id = ...
//第二步，余量扣去增加量，并赋值给新变量NEW_BALANCE，如果余量不足则报错。
set newBalance = dbBalance - changeAmount
if ( newBalance < 0 ) throw new Exception("...");
//第三步，更新会员账户记录
update account set balance = newBalance where account_id = ...
//第四步，其它操作
commit

上面使用伪语言描述，可以看出，不论是增加还是扣减操作，都是先查询出账户记录，根据记录值作计算，最后再更新记录。当外围系统同时访问同一会员做扣减的时候，死锁就有可能发生了，比如：

事务T1执行第一步，查询了会员的账户记录，因为隔离级别是RS，所以会对会员账户记录加S锁；这时候事务T2也执行了第一步，也对会员的账户记录加了S锁；之后事务T1执行第三步，在准备更新会员账户记录前需要先对其加X锁，但发现记录已经被其它事务（事务T2）加了S锁，所以事务T1挂起，等待事务T2释放账户记录的S锁；接着事务T2也执行到第三步，在准备更新会员账户记录前需要先对其加X锁，但发现记录已经被其它事务（事务T1）加了S锁，所以事务T2也挂起等待事务T1。这样死锁就发生了。

知道了死锁发生的原因，那现在看看如何解决这个问题。死锁发生的原因主要是第一步查询的时候对账户记录加了S锁，所以如何我们把隔离级别降为CS（相当于读已提交），能否解决问题呢？答案是否，把隔离级底降为CS确实可以避免死锁的发生，因为查询操作结束后就会释放S锁，但是却会发生 覆盖更新的问题，所以这个方案不可行。既然问题出在第一步，那就是第一步出法看看吧，如果查询账户的时候，我们显示的对记录加X锁而不是S锁，那问题就解决了？看看：

事务T1执行第一步，查询了会员的账户记录，显式对会员账户记录加X锁；这时候事务T2执行到第一步，在查询会员账户记录尝试加X锁时会等待，因为记录已经被别的事务（事务T1）加了X锁；之后事务T1执行第三步，顺利的更新了记录，因为它已经占有记录的X锁；在事务T1提交之后，事务T2就可以继续往下执行了，所以死锁的问题解决了。

优化后的扣减操作

start transaction
//第一步，查询账户可用余额
select ... from account where account_id = ... for update with rs
//第二步，余量扣去增加量，并赋值给新变量NEW_BALANCE，如果余量不足则报错。
set newBalance = dbBalance - changeAmount
if ( n

事务、事务并发(四)