调度中心移除SQL中的 "now()" 函数;集群部署时不再依赖DB时钟,仅需要保证调度中心应用节点时钟一致即可;
This commit is contained in:
parent
71cf3f611f
commit
9767174c12
|
@ -19,7 +19,7 @@
|
||||||
t.update_time
|
t.update_time
|
||||||
</sql>
|
</sql>
|
||||||
|
|
||||||
<select id="findDead" parameterType="java.lang.Integer" resultType="java.lang.Integer" >
|
<select id="findDead" parameterType="java.util.HashMap" resultType="java.lang.Integer" >
|
||||||
SELECT t.id
|
SELECT t.id
|
||||||
FROM xxl_job_registry AS t
|
FROM xxl_job_registry AS t
|
||||||
WHERE t.update_time <![CDATA[ < ]]> DATE_ADD(#{nowTime},INTERVAL -#{timeout} SECOND)
|
WHERE t.update_time <![CDATA[ < ]]> DATE_ADD(#{nowTime},INTERVAL -#{timeout} SECOND)
|
||||||
|
@ -33,7 +33,7 @@
|
||||||
</foreach>
|
</foreach>
|
||||||
</delete>
|
</delete>
|
||||||
|
|
||||||
<select id="findAll" parameterType="java.lang.Integer" resultMap="XxlJobRegistry">
|
<select id="findAll" parameterType="java.util.HashMap" resultMap="XxlJobRegistry">
|
||||||
SELECT <include refid="Base_Column_List" />
|
SELECT <include refid="Base_Column_List" />
|
||||||
FROM xxl_job_registry AS t
|
FROM xxl_job_registry AS t
|
||||||
WHERE t.update_time <![CDATA[ > ]]> DATE_ADD(#{nowTime},INTERVAL -#{timeout} SECOND)
|
WHERE t.update_time <![CDATA[ > ]]> DATE_ADD(#{nowTime},INTERVAL -#{timeout} SECOND)
|
||||||
|
|
Loading…
Reference in New Issue