diff --git a/scheduled-mysql-persistence/src/main/java/io/github/jas34/scheduledwf/dao/mysql/MySQLScheduledWfMetaDataDao.java b/scheduled-mysql-persistence/src/main/java/io/github/jas34/scheduledwf/dao/mysql/MySQLScheduledWfMetaDataDao.java index e7fe630..adf887f 100644 --- a/scheduled-mysql-persistence/src/main/java/io/github/jas34/scheduledwf/dao/mysql/MySQLScheduledWfMetaDataDao.java +++ b/scheduled-mysql-persistence/src/main/java/io/github/jas34/scheduledwf/dao/mysql/MySQLScheduledWfMetaDataDao.java @@ -109,10 +109,9 @@ private void insertOrUpdatescheduleWorkflowDef(Connection tx, ScheduleWfDef def) .addParameter(def.getStatus() != null ? def.getStatus().name() : null) .addJsonParameter(def).addParameter(def.getCronExpression()).executeUpdate()); } else { - final String UPDATE_WORKFLOW_DEF_QUERY = "UPDATE schedule_wf_def " - + "SET json_input = ?,status=?, cron_expression=?, version=?, updated_on = CURRENT_TIMESTAMP " - + "WHERE name = ?"; - + final String UPDATE_WORKFLOW_DEF_QUERY = "UPDATE schedule_wf_def " + + "SET json_input = ?,status=?, cron_expression=?, version=?, updated_on = CURRENT_TIMESTAMP " + + "WHERE name = ?"; execute(tx, UPDATE_WORKFLOW_DEF_QUERY, q -> q.addJsonParameter(def) .addParameter(def.getStatus() != null ? def.getStatus().name() : null)