|
|
@ -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);
|
|
|
|