update xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java.

调整preparedStatement和conn关闭的顺序,我们在做达梦数据库兼容时,这个顺序导致定时周期任务程序假死(在1秒执行一次),调整后解决。
pull/17/head
lingyun304 6 years ago committed by Gitee
parent c8fd64cb91
commit e367a02e8e

@ -146,36 +146,34 @@ public class JobScheduleHelper {
logger.error(">>>>>>>>>>> xxl-job, JobScheduleHelper#scheduleThread error:{}", e); logger.error(">>>>>>>>>>> xxl-job, JobScheduleHelper#scheduleThread error:{}", e);
} }
} finally { } finally {
// close PreparedStatement
// commit if (null != preparedStatement) {
if (conn != null) {
try { try {
conn.commit(); preparedStatement.close();
} catch (SQLException e) { } catch (SQLException e) {
if (!scheduleThreadToStop) { if (!scheduleThreadToStop) {
logger.error(e.getMessage(), e); logger.error(e.getMessage(), e);
} }
} }
}
// commit
if (conn != null) {
try { try {
conn.setAutoCommit(connAutoCommit); conn.commit();
} catch (SQLException e) { } catch (SQLException e) {
if (!scheduleThreadToStop) { if (!scheduleThreadToStop) {
logger.error(e.getMessage(), e); logger.error(e.getMessage(), e);
} }
} }
try { try {
conn.close(); conn.setAutoCommit(connAutoCommit);
} catch (SQLException e) { } catch (SQLException e) {
if (!scheduleThreadToStop) { if (!scheduleThreadToStop) {
logger.error(e.getMessage(), e); logger.error(e.getMessage(), e);
} }
} }
}
// close PreparedStatement
if (null != preparedStatement) {
try { try {
preparedStatement.close(); conn.close();
} catch (SQLException e) { } catch (SQLException e) {
if (!scheduleThreadToStop) { if (!scheduleThreadToStop) {
logger.error(e.getMessage(), e); logger.error(e.getMessage(), e);

Loading…
Cancel
Save