common-frame/hcframe
17
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

fix: 修复自增主键并发线程问题

Browse Source
This commit is contained in:
lhc
2026-03-06 15:38:02 +08:00
parent 7eed24c829
commit eb83178701
2 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
hcframe-parent/hcframe-base/src/main/java/com/taixingyiji/base/module/data/dao/TableMapper.java
View File

@@ -56,13 +56,13 @@ public interface TableMapper {
int updateBatchByPk(@Param("sql")String sql); int updateBatchByPk(@Param("sql")String sql);
void lockSequence(@Param("tableName")String tableName); int lockSequence(@Param("tableName")String tableName);
void unlockSequence(@Param("tableName") String tableName); int unlockSequence(@Param("tableName") String tableName);
void lockSequenceDm(@Param("tableName") String tableName); int lockSequenceDm(@Param("tableName") String tableName);
void unlockSequenceDm(@Param("tableName") String tableName); int unlockSequenceDm(@Param("tableName") String tableName);
void createSequenceSafeDm(@Param("tableName") String tableName, @Param("pkName") String pkName); int createSequenceSafeDm(@Param("tableName") String tableName, @Param("pkName") String pkName);
} }

12
hcframe-parent/hcframe-base/src/main/resources/mapping/data/TableMapper.xml
View File

@@ -178,18 +178,18 @@
INCREMENT BY 1 INCREMENT BY 1
CACHE 1; CACHE 1;
</insert> </insert>
<select id="setValForHighGoSequence"> <update id="setValForHighGoSequence">
SELECT setval( '${tableName}_seq', (SELECT COALESCE(MAX(${pkName}),0) + 1 FROM ${tableName}), false); SELECT setval( '${tableName}_seq', (SELECT COALESCE(MAX(${pkName}),0) + 1 FROM ${tableName}), false);
</select> </update>
<!-- 获取锁 --> <!-- 获取锁 -->
<select id="lockSequence"> <update id="lockSequence">
SELECT pg_advisory_lock(hashtext('${tableName}_seq')); SELECT pg_advisory_lock(hashtext('${tableName}_seq'));
</select> </update>
<!-- 释放锁 --> <!-- 释放锁 -->
<select id="unlockSequence" > <update id="unlockSequence" >
SELECT pg_advisory_unlock(hashtext('${tableName}_seq')); SELECT pg_advisory_unlock(hashtext('${tableName}_seq'));
</select> </update>
<update id="lockSequenceDm"> <update id="lockSequenceDm">
DECLARE DECLARE
result INT; result INT;