首页 / POSTGRCSQL / postgresql 并发update下导致的死锁问题

postgresql 并发update下导致的死锁问题

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了postgresql 并发update下导致的死锁问题，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含7196字，纯文字阅读大概需要11分钟。

内容图文

一、死锁问题背景

在收据批量打印时，由于采用异步并发触发打印，同时触发打印（九千多数据每隔50ms触发一次），导致了并发执行引起在接口更新打印次数时postgresql发生死锁问题，

具体报错如下：

 1 ### The error occurred while setting parameters
 2 ### SQL: update t_sc_receipt set print_num = coalesce(print_num,0) + 1                       ,print_ts=?
 3 ### Cause: org.postgresql.util.PSQLException: ERROR: deadlock detected
 4   详细：Process 19540 waits for ShareLock on transaction 12520113; blocked by process 19539.
 5 Process 19539 waits for ShareLock on transaction 12520112; blocked by process 19540.
 6   建议：See server log for query details.
 7   在位置：while rechecking updated tuple (329,3) in relation "t_sc_receipt"
 8 ; SQL []; ERROR: deadlock detected
 9   详细：Process 19540 waits for ShareLock on transaction 12520113; blocked by process 19539.
10 Process 19539 waits for ShareLock on transaction 12520112; blocked by process 19540.
11   建议：See server log for query details.
12   在位置：while rechecking updated tuple (329,3) in relation "t_sc_receipt"; nested exception is org.postgresql.util.PSQLException: ERROR: deadlock detected
13   详细：Process 19540 waits for ShareLock on transaction 12520113; blocked by process 19539.
14 Process 19539 waits for ShareLock on transaction 12520112; blocked by process 19540.
15   建议：See server log for query details.
16   在位置：while rechecking updated tuple (329,3) in relation "t_sc_receipt"
17     at org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator.doTranslate(SQLErrorCodeSQLExceptionTranslator.java:263)
18     at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:73)
19     at org.mybatis.spring.MyBatisExceptionTranslator.translateExceptionIfPossible(MyBatisExceptionTranslator.java:73)
20     at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:368)
21     at com.sun.proxy.$Proxy57.update(Unknown Source)
22     at org.mybatis.spring.SqlSessionTemplate.update(SqlSessionTemplate.java:254)
23     at com.xxx.framework.mybatis.dao.impl.MyBatisDaoImpl.updateBySql(MyBatisDaoImpl.java:531)
24     at com.xxx.dscsettle.receipt.ReceiptService.updatePrintNum(ReceiptService.java:160)
25     at com.xxx.dscsettle.receipt.ReceiptService$$FastClassBySpringCGLIB$$82e91731.invoke(<generated>)
26     at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
27     at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:651)
28     at com.xxx.dscsettle.receipt.ReceiptService$$EnhancerBySpringCGLIB$$67b6a353.updatePrintNum(<generated>)
29     at com.alibaba.dubbo.common.bytecode.Wrapper72.invokeMethod(Wrapper72.java)
30     at com.alibaba.dubbo.rpc.proxy.javassist.JavassistProxyFactory$1.doInvoke(JavassistProxyFactory.java:46)
31     at com.alibaba.dubbo.rpc.proxy.AbstractProxyInvoker.invoke(AbstractProxyInvoker.java:72)
32     at com.alibaba.dubbo.rpc.protocol.InvokerWrapper.invoke(InvokerWrapper.java:53)
33     at com.onlyou.framework.log.DubboLogServiceFilter.invoke(DubboLogServiceFilter.java:28)
34     at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
35     at com.alibaba.dubbo.rpc.filter.ExceptionFilter.invoke(ExceptionFilter.java:64)
36     at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
37     at com.alibaba.dubbo.rpc.filter.TimeoutFilter.invoke(TimeoutFilter.java:42)
38     at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
39     at com.alibaba.dubbo.monitor.support.MonitorFilter.invoke(MonitorFilter.java:75)
40     at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
41     at com.alibaba.dubbo.rpc.protocol.dubbo.filter.TraceFilter.invoke(TraceFilter.java:78)
42     at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
43     at com.alibaba.dubbo.rpc.filter.ContextFilter.invoke(ContextFilter.java:61)
44     at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
45     at com.alibaba.dubbo.rpc.filter.GenericFilter.invoke(GenericFilter.java:132)
46     at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
47     at com.alibaba.dubbo.rpc.filter.ClassLoaderFilter.invoke(ClassLoaderFilter.java:38)
48     at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
49     at com.alibaba.dubbo.rpc.filter.EchoFilter.invoke(EchoFilter.java:38)
50     at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
51     at com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol$1.reply(DubboProtocol.java:98)
52     at com.alibaba.dubbo.remoting.exchange.support.header.HeaderExchangeHandler.handleRequest(HeaderExchangeHandler.java:98)
53     at com.alibaba.dubbo.remoting.exchange.support.header.HeaderExchangeHandler.received(HeaderExchangeHandler.java:170)
54     at com.alibaba.dubbo.remoting.transport.DecodeHandler.received(DecodeHandler.java:52)
55     at com.alibaba.dubbo.remoting.transport.dispatcher.ChannelEventRunnable.run(ChannelEventRunnable.java:81)
56     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
57     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
58     at java.lang.Thread.run(Thread.java:745)
59 Caused by: org.postgresql.util.PSQLException: ERROR: deadlock detected
60   详细：Process 19540 waits for ShareLock on transaction 12520113; blocked by process 19539.
61 Process 19539 waits for ShareLock on transaction 12520112; blocked by process 19540.
62   建议：See server log for query details.

二、原因分析

从报错的提示我们知道了在数据库postgresql发生了死锁（ERROR: deadlock detected 侦测到了死锁发生），而且可以定位是在并发更新打印次数的时候发生的，正常的逻辑下，分页去不断更新收据的打印次数应该是不会出错的，在这边批量更新打印次数时出现了错误。

1.死锁是由于资源的相互竞争引起的，在update数据的时候应该是数据库行锁导致的

2.因为批量修改是一个默认的事务，所以如果没有全部修改完，索引是不会被放开的，所以才会在并发的多次访问中出现死锁，

3.研究出现问题的原因，发现最可能得是重复的行锁导致的，最终才查出原因是因为代码逻辑的原因，未传更新idList，而sql当中又进行了空的判断，导致每次都去更新全部的表数据，由于不同事务直接的相互等待，得不到资源，导致了死锁。

三、问题解决与拓展

批量更新的死锁解决方案有以下两种

1.将批量update通过for循环改成单条修改，但是这个方法对服务器的压力增大

2.在更新数据的时候进行一次筛选，将重复的数据剔除出去

在本次问题解决当中，只需将代码中传入正确的idLIst即可解决问题，因为本身进行迭代是没有进行重复upadate的。

疑问：并发update下postgresql就会出现shareLock死锁吗？

一般情况下的多次update应该不会导致死锁，而在事务当中的update则比较可能发生死锁现象。

同时，也看到了一位博主说postgresql 并发update的死锁问题可能是一些版本出现的bug，以及可能可以进行解决的设置以下两个参数进行解决：

autovacuum_vacuum_scale_factor = 0.03
autovacuum_analyze_scale_factor = 0.03

参考地址：http://blog.chinaunix.net/uid-20726500-id-4773950.html
https://blog.51cto.com/372550/2387517

内容总结

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

内容备注

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

内容手机端

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

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

来源：【匿名】

【上一篇】PostgreSQL 修改表字段常用命令【下一篇】PDO扩展连接PostgreSQL对象关系数据库步骤详解

更多 ►

【postgresql 并发update下导致的死锁问题】教程文章相关的互联网学习教程文章

postgresql 数据库 update更新慢的原因（已解决）【代码】【图】

w1.pid as 等待进程, w1.mode as 等待锁模式, w2.usename as 等待用户, w2.query as 等待会话, b1.pid as 锁的进程, b1.mode 锁的锁模式, b2.usename as 锁的用户, b2.query as 锁的会话, b2.application_name 锁的应用, b2.client_addr 锁的IP地址, b2.query_start 锁的语句执行时间 from pg_locks w1 join pg_stat_activity w2 on w1.pid=w2.pid join pg_locks b1 on w1.transactionid=b1.transactionid and w1.pid!=b1.pid join...

postgresql update returning【代码】

: UPDATE weather SET temp_lo = temp_lo+1, temp_hi = temp_lo+15, prcp = DEFAULTWHERE city = ‘San Francisco‘ AND date = ‘2003-07-03‘RETURNING temp_lo, temp_hi, prcp;update returning的是更新后的内容postgresql update returning标签：and cisco return where form postgres lis postgre list 本文系统来源：http://www.cnblogs.com/cdyboke/p/7490077.html

PostgreSQL之INSERT,DELETE,UPDATE

插入数据每一列都赋值的话，可以省略列名 INSERT INTO Product VALUES(value1,value2,DEFAULT,value3,NULL) 只对部分列赋值，需要加上列名。被省略列名的列，如果存在默认值则默认值，如果不存在默认值则NULL。如果既不存在默认值又有非空约束，则执行失败 INSERT INTO Product (column1,column2,column3) VALUES(value1,value2,value3) 删除数据清空表而不删除表 DELETE FROM 表名删除表 DROP TABLE 表名更新表 UPDATE 表名 S...

PostgreSQL的MVCC(5)--In-page vacuum and HOT updates【代码】

在常规更新期间执行in-page vacuum 当因为读取或更新访问页面时，如果PostgreSQL知道该页面空间不足，则可以执行一次快速的in-page vacuum。发生在以下两种情况下： 1.此页面上之前的更新找不到足够的空间来在同一页面中分配新的行版本。在page header中会记录这种情况，下一次将会对页面vacuum。2.该页面已超过fillfactor设定的百分比。在这种情况下，立即执行vacuum，而不会推迟到下一次。 fillfactor是可以为表（和索引）定义的...

PostgreSQL中的heap-only-tuples updates【代码】

为什么要这么做呢？因为数据库必须考虑一个关键问题：并发性。被更新的行可能还在被之前的事务使用。为了解决这个问题：rdbms采用了不同技术：修改行，并将原来的行版本放置到另外一个地方。比如oracle中的undo duplicate该行，通过行的可见性映射信息来标明行对哪个事务可见。这就需要一个清理机制来清理那些对所有事务都不再需要的行。这是通过pg中的vacuum来完成的。下面借助pageinspect扩展来示例：postgres=# create tab...

postgresql saveOrUpdate实现方式

在postgresql9.5以上提供了conflict() 来判断sql语句插入时，是否发生重复 1. saveOrUpdate实现方式主键重复后，执行update操作INSERT INTO user_pages (user_id, page_id, enabled) VALUES (1, 1, TRUE) ON CONFLICT (user_id, page_id) DO UPDATE SET enabled = 0;2.saveOrNothing 主键重复后，不执行任何操作INSERT INTO user_pages (user_id, page_id, enabled) VALUES (1, 1, TRUE) ON CONFLICT (user_id, page_id) ...

PostgreSQL批量update与oracle差异【代码】

此文转载自：https://blog.csdn.net/weixin_39540651/article/details/112259645#commentBox当我们在数据库中有这样的需求时：需要以某列的当前值为判断对象，将其更新成其它值。例如下面一张表：ID INFO ---------- ----------2 a1 b3 c4 d5 e我们最简单的方式就是通过多个update来完成： update t1 set id= 2where id = 1;update t1 set id = 1where id = 2;......看上去很简单，但是上面的更新却存在一个很大的问题，当我们第...

PostgreSQL批量update与oracle差异【代码】

此文转载自：https://blog.csdn.net/weixin_39540651/article/details/112259645当我们在数据库中有这样的需求时：需要以某列的当前值为判断对象，将其更新成其它值。例如下面一张表：ID INFO ---------- ----------2 a1 b3 c4 d5 e我们最简单的方式就是通过多个update来完成： update t1 set id= 2where id = 1;update t1 set id = 1where id = 2;......看上去很简单，但是上面的更新却存在一个很大的问题，当我们第一次执行完u...