Skip to content

Commit

Permalink
fix(engine): use inner join to update byte array removal time on mysql
Browse files Browse the repository at this point in the history
Related to CAM-13992
  • Loading branch information
yT0n1 authored Oct 20, 2021
1 parent 45fba93 commit b95120f
Showing 1 changed file with 5 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -976,13 +976,10 @@
<!-- MySQL specific configuration -->
<update id="updateByteArraysByBatchId_mysql"
parameterType="java.util.Map">
update ${prefix}ACT_GE_BYTEARRAY
set REMOVAL_TIME_ = #{removalTime, jdbcType=TIMESTAMP}
where ID_ IN (
SELECT JOB_EXCEPTION_STACK_ID_
FROM ${prefix}ACT_HI_JOB_LOG
WHERE JOB_DEF_CONFIGURATION_ = #{batchId, jdbcType=VARCHAR}
AND JOB_EXCEPTION_STACK_ID_ IS NOT NULL
)
update ${prefix}ACT_GE_BYTEARRAY BA
INNER JOIN ${prefix}ACT_HI_JOB_LOG JL
ON BA.ID_ = JL.JOB_EXCEPTION_STACK_ID_
AND JL.JOB_DEF_CONFIGURATION_ = #{batchId, jdbcType=VARCHAR}
SET BA.REMOVAL_TIME_ = #{removalTime, jdbcType=TIMESTAMP}
</update>
</mapper>

0 comments on commit b95120f

Please sign in to comment.