| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| package org.apache.batchee.container.services.persistence.jdbc; |
| |
| import org.apache.batchee.container.impl.controller.PartitionedStepBuilder; |
| import org.apache.batchee.container.services.persistence.jdbc.database.Database; |
| |
| public class Dictionary { |
| public interface SQL { // needs to be kept aligned with JPA mapping, we can't use reflection to find fields since order can change between executions with java 7 |
| String CREATE_TABLE = "create table "; |
| String INSERT_INTO = "insert into "; |
| String SELECT = "select "; |
| String FROM = " from "; |
| String UPDATE = "update "; |
| String WHERE = " where "; |
| String DELETE = "delete from "; |
| |
| String[] CHECKPOINT_COLUMNS = { "id", "data", "stepName", "type", "INSTANCE_JOBINSTANCEID" }; |
| String CREATE_CHECKPOINT = CREATE_TABLE + "%s(%s %s %s , %s %s, %s %s, %s %s, %s %s, primary key(id))"; |
| String INSERT_CHECKPOINT = INSERT_INTO + "%s(%s, %s, %s, %s) values (?, ?, ?, ?)"; |
| String SELECT_CHECKPOINT = SELECT + "%s" + FROM + "%s" + WHERE + "%s = ? and %s = ? and %s = ?"; |
| String UPDATE_CHECKPOINT = UPDATE + "%s set %s = ?" + WHERE + "%s = ? and %s = ? and %s = ?"; |
| String DELETE_CHECKPOINT = DELETE + "%s" + WHERE + "%s = ?"; |
| String DELETE_CHECKPOINT_UNTIL = DELETE + "%s WHERE %s IN (" + SELECT + " DISTINCT t1.%s FROM %s t1 WHERE (SELECT MAX(t0.%s) FROM %s t0 WHERE t0.%s = t1.%s) < ?)"; |
| |
| String[] JOB_INSTANCE_COLUMNS = { "jobInstanceId", "batchStatus", "exitStatus", "jobName", "jobXml", "latestExecution", "restartOn", "step" }; |
| String CREATE_JOB_INSTANCE = CREATE_TABLE + "%s(%s %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, PRIMARY KEY (%s))"; |
| String JOB_INSTANCE_COUNT_FROM_NAME = SELECT + "count(%s) as jobinstancecount" + FROM + "%s" + WHERE + "%s = ?"; |
| String JOB_INSTANCE_BY_ID = SELECT + "*" + FROM + "%s" + WHERE + "%s = ?"; |
| String JOB_INSTANCE_UPDATE_STATUS = UPDATE + "%s set %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ?" + WHERE + "%s = ?"; |
| String JOB_INSTANCE_IDS = SELECT + "%s" + FROM + "%s" + WHERE + "%s = ? order by %s desc"; |
| String JOB_INSTANCE_IDS_FROM_NAME = SELECT + "%s" + FROM + "%s" + WHERE + " %s = ? order by %s desc"; |
| String JOB_NAMES = SELECT + "distinct %s" + FROM + "%s" + WHERE + "%s not like '%s'"; |
| String EXTERNAL_JOB_INSTANCE = SELECT + "distinct %s, %s" + FROM + "%s" + WHERE + "%s not like '%s'"; |
| String JOB_INSTANCE_CREATE = INSERT_INTO + "%s" + "(%s) VALUES(?)"; |
| String JOB_INSTANCE_CREATE_WITH_JOB_XML = INSERT_INTO + "%s" + "(%s, %s) VALUES(?, ?)"; |
| String DELETE_JOB_INSTANCE = DELETE + "%s" + WHERE + "%s = ?"; |
| String DELETE_JOB_INSTANCE_UNTIL = DELETE + "%s" + WHERE + "%s IN (" + SELECT + "distinct t1.%s" + FROM + "%s t1" + WHERE + "(" + SELECT + "max(t0.%s)" + FROM + "%s t0" + |
| WHERE + "t0.%s = t1.%s) < ?)"; |
| |
| String[] JOB_EXECUTION_COLUMNS = { "executionId", "batchStatus", "createTime", "endTime", "exitStatus", "jobProperties", |
| "startTime", "updateTime", "INSTANCE_JOBINSTANCEID" }; |
| String CREATE_JOB_EXECUTION = CREATE_TABLE + "%s(%s %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s)"; |
| String JOB_EXECUTION_TIMESTAMPS = SELECT + " %s, %s, %s, %s" + FROM + "%s" + WHERE + "%s = ?"; |
| String JOB_EXECUTION_BATCH_STATUS = SELECT + "%s" + FROM + "%s" + WHERE + "%s = ?"; |
| String JOB_EXECUTION_EXIT_STATUS = SELECT + "%s" + FROM + "%s" + WHERE + "%s = ?"; |
| String JOB_EXECUTION_PROPERTIES = SELECT + "%s" + FROM + "%s" + WHERE + "%s = ?"; |
| String JOB_EXECUTION_UPDATE = UPDATE + "%s set %s = ?, %s = ? where %s = ?"; |
| String JOB_EXECUTION_SET_FINAL_DATA = UPDATE + "%s set %s = ?, %s = ?, %s = ?, %s = ? where %s = ?"; |
| String JOB_EXECUTION_START = UPDATE + "%s set %s = ?, %s = ?, %s = ? where %s = ?"; |
| |
| String JOB_EXECUTION_FIND_BY_ID = SELECT + "A.%s, A.%s, A.%s, A.%s, A.%s, A.%s, A.%s, A.%s, B.%s" + |
| FROM + "%s as A inner join %s as B on A.%s = B.%s" + WHERE + "%s = ?"; |
| |
| String JOB_EXECUTION_FROM_INSTANCE = SELECT + "A.%s, A.%s, A.%s, A.%s, A.%s, A.%s, A.%s, A.%s, B.%s " + |
| FROM + "%s as A inner join %s as B ON A.%s = B.%s" + WHERE + "B.%s = ?"; |
| String JOB_EXECUTION_RUNNING = SELECT + "A.%s" + FROM + "%s AS A inner join %s AS B ON A.%s = B.%s WHERE A.%s IN (?,?,?) AND B.%s = ?"; |
| String JOB_INSTANCE_STATUS = SELECT + "*" + FROM + "%s as A inner join %s as B on A.%s = B.%s " + WHERE + "B.%s = ?"; |
| String JOB_INSTANCE_FROM_EXECUTION = SELECT + "%s" + FROM + "%s" + WHERE + "%s = ?"; |
| String JOB_EXECUTION_CREATE = INSERT_INTO + "%s(%s, %s, %s, %s, %s) VALUES(?, ?, ?, ?, ?)"; |
| String JOB_EXECUTION_MOST_RECENT = SELECT + "%s" + FROM + "%s" + WHERE + "%s = ? ORDER BY %s DESC"; |
| String DELETE_JOB_EXECUTION = DELETE + "%s" + WHERE + "%s = ?"; |
| String DELETE_JOB_EXECUTION_UNTIL = DELETE + "%s" + WHERE + "%s IN (" + SELECT + "distinct t0.%s" + FROM + "%s t0" + WHERE + "t0.%s < ?)"; |
| |
| String[] STEP_EXECUTION_COLUMNS = { "id", "batchStatus", "exec_commit", "endTime", "exitStatus", "exec_filter", "lastRunStepExecutionId", "numPartitions", |
| "persistentData", "exec_processskip", "exec_read", "exec_readskip", "exec_rollback", "startCount", "startTime", "stepName", |
| "exec_write", "exec_writeskip", "EXECUTION_EXECUTIONID" }; |
| |
| String CREATE_STEP_EXECUTION = CREATE_TABLE + |
| "%s(%s %s %s" + ", %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, %s %s, PRIMARY KEY (id))"; |
| String STEPS_FROM_EXECUTION = SELECT + "*" + FROM + "%s" + WHERE + "%s = ?"; |
| String STEP_FROM_ID = SELECT + "*" + FROM + "%s" + WHERE + "%s = ?"; |
| String STEP_EXECUTION_CREATE = INSERT_INTO + "%s" + "(%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; |
| String STEP_EXECUTION_UPDATE_STATUS = UPDATE + "%s SET %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ? WHERE %s = ?"; |
| |
| String STEP_EXECUTION_UPDATE = UPDATE + |
| "%s SET %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ?, %s = ? WHERE %s = ?"; |
| |
| String STEP_EXECUTION_BY_INSTANCE_AND_STEP = SELECT + |
| "B.%s, B.%s, B.%s, B.%s, B.%s, B.%s, B.%s, B.%s" + FROM + "%s A inner join %s B ON A.%s = B.%s " + WHERE + "A.%s = ? and B.%s = ?"; |
| |
| String DELETE_STEP_EXECUTION = DELETE + "%s A inner join %s B ON A.%s = B.%s " + WHERE + "A.%s = ?"; |
| String DELETE_STEP_EXECUTION_UNTIL = DELETE + "%s" + WHERE + "%s in (" + SELECT + "distinct t0.%s" + FROM + "%s t0 inner join %s t1 ON t0.%s=t1.%s" + WHERE + "t1.%s < ?)"; |
| } |
| |
| private final String checkpointTable; |
| private final String createCheckpointTable; |
| private final String insertCheckpoint; |
| private final String selectCheckpoint; |
| private final String updateCheckpoint; |
| private final String deleteCheckpoint; |
| private final String deleteCheckpointUntil; |
| private final String jobInstanceTable; |
| private final String createJobInstanceTable; |
| private final String countJobInstanceByName; |
| private final String findJobInstance; |
| private final String updateJobInstanceStatus; |
| private final String findJoBInstanceIds; |
| private final String findJobInstanceIdsByName; |
| private final String findJobNames; |
| private final String findExternalJobInstances; |
| private final String createJobInstance; |
| private final String createJobInstanceWithJobXml; |
| private final String deleteJobInstance; |
| private final String deleteJobInstanceUntil; |
| private final String jobExecutionTable; |
| private final String createJobExecutionTable; |
| private final String findJobExecutionTimestamps; |
| private final String findJobExecutionBatchStatus; |
| private final String findJobExecutionExitStatus; |
| private final String findJobExecutionJobProperties; |
| private final String updateJobExecution; |
| private final String setJobExecutionFinalData; |
| private final String updateStartedJobExecution; |
| private final String findJobExecutionById; |
| private final String findJobExecutionByInstance; |
| private final String findRunningJobExecutions; |
| private final String findJobStatus; |
| private final String findJobInstanceFromJobExecution; |
| private final String createJobExecution; |
| private final String findMostRecentJobExecution; |
| private final String deleteJobExecution; |
| private final String deleteJobExecutionUntil; |
| private final String stepExecutionTable; |
| private final String createStepExecutionTable; |
| private final String finStepExecutionFromJobExecution; |
| private final String findStepExecutionFromId; |
| private final String createStepExecution; |
| private final String updateStepExecutionStatus; |
| private final String updateStepExecution; |
| private final String findStepExecutionByJobInstanceAndStepName; |
| private final String deleteStepExecution; |
| private final String deleteStepExecutionUntil; |
| |
| private final String[] checkpointColumns; |
| private final String[] jobInstanceColumns; |
| private final String[] jobExecutionColumns; |
| private final String[] stepExecutionColumns; |
| |
| public Dictionary(final String checkpointTable, final String jobInstanceTable, final String jobExecutionTable, |
| final String stepExecutionTable, final Database database) { |
| this.checkpointTable = checkpointTable; |
| this.jobInstanceTable = jobInstanceTable; |
| this.jobExecutionTable = jobExecutionTable; |
| this.stepExecutionTable = stepExecutionTable; |
| |
| { // ensure to be able to build jointures prebuilding columns |
| checkpointColumns = columns(database, SQL.CHECKPOINT_COLUMNS); |
| jobExecutionColumns = columns(database, SQL.JOB_EXECUTION_COLUMNS); |
| jobInstanceColumns = columns(database, SQL.JOB_INSTANCE_COLUMNS); |
| stepExecutionColumns = columns(database, SQL.STEP_EXECUTION_COLUMNS); |
| } |
| |
| { // checkpoint |
| this.createCheckpointTable = String.format(SQL.CREATE_CHECKPOINT, checkpointTable, |
| checkpointColumns[0], database.bigint(), database.autoIncrementId(), |
| checkpointColumns[1], database.blob(), |
| checkpointColumns[2], database.varchar255(), |
| checkpointColumns[3], database.varchar20(), |
| checkpointColumns[4], database.bigint()); |
| this.insertCheckpoint = String.format(SQL.INSERT_CHECKPOINT, checkpointTable, checkpointColumns[1], checkpointColumns[2], checkpointColumns[3], checkpointColumns[4]); |
| this.selectCheckpoint = String.format(SQL.SELECT_CHECKPOINT, checkpointColumns[1], checkpointTable, checkpointColumns[4], checkpointColumns[3], checkpointColumns[2]); |
| this.updateCheckpoint = String.format(SQL.UPDATE_CHECKPOINT, checkpointTable, checkpointColumns[1], checkpointColumns[4], checkpointColumns[3], checkpointColumns[2]); |
| this.deleteCheckpoint = String.format(SQL.DELETE_CHECKPOINT, checkpointTable, checkpointColumns[4]); |
| // String DELETE_CHECKPOINT_UNTIL = DELETE + "%s WHERE %s IN (" + SELECT + " DISTINCT t1.%s FROM %s t1 WHERE (SELECT MAX(t0.%s) FROM %s t0 WHERE t0.%s = t1.%s) < ?)"; |
| this.deleteCheckpointUntil = String.format(SQL.DELETE_CHECKPOINT_UNTIL, checkpointTable, checkpointColumns[0], checkpointColumns[0], checkpointTable, |
| jobExecutionColumns[3], jobExecutionTable, checkpointColumns[4], jobExecutionColumns[8]); |
| } |
| |
| { // jobInstance |
| this.createJobInstanceTable = String.format(SQL.CREATE_JOB_INSTANCE, jobInstanceTable, |
| jobInstanceColumns[0], database.bigint(), database.autoIncrementId(), |
| jobInstanceColumns[1], database.varchar20(), |
| jobInstanceColumns[2], database.varchar255(), |
| jobInstanceColumns[3], database.varchar255(), |
| jobInstanceColumns[4], database.blob(), |
| jobInstanceColumns[5], database.bigint(), |
| jobInstanceColumns[6], database.varchar255(), |
| jobInstanceColumns[7], database.varchar255(), |
| jobInstanceColumns[0]); |
| this.countJobInstanceByName = String.format(SQL.JOB_INSTANCE_COUNT_FROM_NAME, jobInstanceColumns[0], jobInstanceTable, jobInstanceColumns[3]); |
| this.findJobInstance = String.format(SQL.JOB_INSTANCE_BY_ID, jobInstanceTable, jobInstanceColumns[0]); |
| this.updateJobInstanceStatus = String.format(SQL.JOB_INSTANCE_UPDATE_STATUS, jobInstanceTable, jobInstanceColumns[1], jobInstanceColumns[2], jobInstanceColumns[5], |
| jobInstanceColumns[6], jobInstanceColumns[7], jobInstanceColumns[3], jobInstanceColumns[0]); |
| this.findJoBInstanceIds = String.format(SQL.JOB_INSTANCE_IDS, jobInstanceColumns[0], jobInstanceTable, jobInstanceColumns[3], jobInstanceColumns[0]); |
| this.findJobInstanceIdsByName = String.format(SQL.JOB_INSTANCE_IDS_FROM_NAME, jobInstanceColumns[0], jobInstanceTable, jobInstanceColumns[3], jobInstanceColumns[0]); |
| this.findJobNames = String.format(SQL.JOB_NAMES, jobInstanceColumns[3], jobInstanceTable, jobInstanceColumns[3], PartitionedStepBuilder.JOB_ID_SEPARATOR + "%"); |
| this.findExternalJobInstances = String.format(SQL.EXTERNAL_JOB_INSTANCE, jobInstanceColumns[0], jobInstanceColumns[3], jobInstanceTable, |
| jobInstanceColumns[3], PartitionedStepBuilder.JOB_ID_SEPARATOR + "%"); |
| this.createJobInstance = String.format(SQL.JOB_INSTANCE_CREATE, jobInstanceTable, jobInstanceColumns[3]); |
| this.createJobInstanceWithJobXml = String.format(SQL.JOB_INSTANCE_CREATE_WITH_JOB_XML, jobInstanceTable, jobInstanceColumns[3], jobInstanceColumns[4]); |
| this.deleteJobInstance = String.format(SQL.DELETE_JOB_INSTANCE, jobInstanceTable, jobInstanceColumns[0]); |
| this.deleteJobInstanceUntil = String.format(SQL.DELETE_JOB_INSTANCE_UNTIL, jobInstanceTable, jobInstanceColumns[0], jobInstanceColumns[0], jobInstanceTable, |
| jobExecutionColumns[3], jobExecutionTable, jobExecutionColumns[8], jobInstanceColumns[0]); |
| } |
| |
| { // jobExecution |
| this.createJobExecutionTable = String.format(SQL.CREATE_JOB_EXECUTION, jobExecutionTable, |
| jobExecutionColumns[0], database.bigint(), database.autoIncrementId(), |
| jobExecutionColumns[1], database.varchar20(), |
| jobExecutionColumns[2], database.timestamp(), |
| jobExecutionColumns[3], database.timestamp(), |
| jobExecutionColumns[4], database.varchar255(), |
| jobExecutionColumns[5], database.blob(), |
| jobExecutionColumns[6], database.timestamp(), |
| jobExecutionColumns[7], database.timestamp(), |
| jobExecutionColumns[8], database.bigint()); |
| this.findJobExecutionTimestamps = String.format(SQL.JOB_EXECUTION_TIMESTAMPS, jobExecutionColumns[2], jobExecutionColumns[3], jobExecutionColumns[7], |
| jobExecutionColumns[6], jobExecutionTable, jobExecutionColumns[0]); |
| this.findJobExecutionBatchStatus = String.format(SQL.JOB_EXECUTION_BATCH_STATUS, jobExecutionColumns[1], jobExecutionTable, jobExecutionColumns[0]); |
| this.findJobExecutionExitStatus = String.format(SQL.JOB_EXECUTION_EXIT_STATUS, jobExecutionColumns[4], jobExecutionTable, jobExecutionColumns[0]); |
| this.findJobExecutionJobProperties = String.format(SQL.JOB_EXECUTION_PROPERTIES, jobExecutionColumns[5], jobExecutionTable, jobExecutionColumns[0]); |
| this.updateJobExecution = String.format(SQL.JOB_EXECUTION_UPDATE, jobExecutionTable, jobExecutionColumns[1], jobExecutionColumns[7], jobExecutionColumns[0]); |
| this.setJobExecutionFinalData = String.format(SQL.JOB_EXECUTION_SET_FINAL_DATA, jobExecutionTable, jobExecutionColumns[1], jobExecutionColumns[4], |
| jobExecutionColumns[3], jobExecutionColumns[7], jobExecutionColumns[0]); |
| this.updateStartedJobExecution = String.format(SQL.JOB_EXECUTION_START, jobExecutionTable, jobExecutionColumns[1], jobExecutionColumns[6], |
| jobExecutionColumns[7], jobExecutionColumns[0]); |
| this.findJobExecutionById = String.format(SQL.JOB_EXECUTION_FIND_BY_ID, jobExecutionColumns[2], jobExecutionColumns[6], jobExecutionColumns[3], |
| jobExecutionColumns[7], jobExecutionColumns[5], jobExecutionColumns[8], jobExecutionColumns[1], jobExecutionColumns[4], jobInstanceColumns[3], |
| jobExecutionTable, jobInstanceTable, jobExecutionColumns[8], jobInstanceColumns[0], jobExecutionColumns[0]); |
| this.findRunningJobExecutions = String.format(SQL.JOB_EXECUTION_RUNNING, jobExecutionColumns[0], jobExecutionTable, jobInstanceTable, jobExecutionColumns[8], |
| jobInstanceColumns[0], jobExecutionColumns[1], jobInstanceColumns[3]); |
| this.findJobExecutionByInstance = String.format(SQL.JOB_EXECUTION_FROM_INSTANCE, jobExecutionColumns[0], jobExecutionColumns[2], jobExecutionColumns[6], |
| jobExecutionColumns[3], jobExecutionColumns[7], jobExecutionColumns[5], jobExecutionColumns[1], jobExecutionColumns[4], jobInstanceColumns[3], |
| jobExecutionTable, jobInstanceTable, jobExecutionColumns[8], jobInstanceColumns[0], jobInstanceColumns[0]); |
| this.findJobStatus = String.format(SQL.JOB_INSTANCE_STATUS, jobInstanceTable, jobExecutionTable, jobInstanceColumns[0], jobExecutionColumns[8], |
| jobExecutionColumns[0]); |
| this.findJobInstanceFromJobExecution = String.format(SQL.JOB_INSTANCE_FROM_EXECUTION, jobExecutionColumns[8], jobExecutionTable, jobExecutionColumns[0]); |
| this.createJobExecution = String.format(SQL.JOB_EXECUTION_CREATE, jobExecutionTable, jobExecutionColumns[8], jobExecutionColumns[2], jobExecutionColumns[7], |
| jobExecutionColumns[1], jobExecutionColumns[5]); |
| this.findMostRecentJobExecution = String.format(SQL.JOB_EXECUTION_MOST_RECENT, jobExecutionColumns[0], jobExecutionTable, |
| jobExecutionColumns[8], jobExecutionColumns[2]); |
| this.deleteJobExecution = String.format(SQL.DELETE_JOB_EXECUTION, jobExecutionTable, jobExecutionColumns[8]); |
| this.deleteJobExecutionUntil = String.format(SQL.DELETE_JOB_EXECUTION_UNTIL, jobExecutionTable, jobExecutionColumns[0], jobExecutionColumns[0], |
| jobExecutionTable, jobExecutionColumns[3]); |
| } |
| |
| { // step execution |
| this.createStepExecutionTable = String.format(SQL.CREATE_STEP_EXECUTION, stepExecutionTable, |
| stepExecutionColumns[0], database.bigint(), database.autoIncrementId(), |
| stepExecutionColumns[1], database.varchar20(), |
| stepExecutionColumns[2], database.bigint(), |
| stepExecutionColumns[3], database.timestamp(), |
| stepExecutionColumns[4], database.varchar255(), |
| stepExecutionColumns[5], database.bigint(), |
| stepExecutionColumns[6], database.bigint(), |
| stepExecutionColumns[7], database.integer(), |
| stepExecutionColumns[8], database.blob(), |
| stepExecutionColumns[9], database.bigint(), |
| stepExecutionColumns[10], database.bigint(), |
| stepExecutionColumns[11], database.bigint(), |
| stepExecutionColumns[12], database.bigint(), |
| stepExecutionColumns[13], database.integer(), |
| stepExecutionColumns[14], database.timestamp(), |
| stepExecutionColumns[15], database.varchar255(), |
| stepExecutionColumns[16], database.bigint(), |
| stepExecutionColumns[17], database.bigint(), |
| stepExecutionColumns[18], database.bigint()); |
| this.finStepExecutionFromJobExecution = String.format(SQL.STEPS_FROM_EXECUTION, stepExecutionTable, stepExecutionColumns[18]); |
| this.findStepExecutionFromId = String.format(SQL.STEP_FROM_ID, stepExecutionTable, stepExecutionColumns[0]); |
| this.createStepExecution = String.format(SQL.STEP_EXECUTION_CREATE, stepExecutionTable, stepExecutionColumns[18], stepExecutionColumns[1], |
| stepExecutionColumns[4], stepExecutionColumns[15], |
| stepExecutionColumns[10], stepExecutionColumns[16], stepExecutionColumns[2], stepExecutionColumns[12], stepExecutionColumns[11], |
| stepExecutionColumns[9], stepExecutionColumns[5], |
| stepExecutionColumns[17], stepExecutionColumns[14], stepExecutionColumns[3], stepExecutionColumns[8]); |
| this.updateStepExecutionStatus = String.format(SQL.STEP_EXECUTION_UPDATE_STATUS, stepExecutionTable, stepExecutionColumns[8], stepExecutionColumns[1], |
| stepExecutionColumns[4], stepExecutionColumns[6], |
| stepExecutionColumns[7], stepExecutionColumns[13], stepExecutionColumns[0]); |
| this.updateStepExecution = String.format(SQL.STEP_EXECUTION_UPDATE, stepExecutionTable, stepExecutionColumns[18], stepExecutionColumns[1], |
| stepExecutionColumns[4], stepExecutionColumns[15], |
| stepExecutionColumns[10], stepExecutionColumns[16], stepExecutionColumns[2], stepExecutionColumns[12], stepExecutionColumns[11], |
| stepExecutionColumns[9], stepExecutionColumns[5], |
| stepExecutionColumns[17], stepExecutionColumns[14], stepExecutionColumns[3], stepExecutionColumns[8], stepExecutionColumns[0]); |
| this.findStepExecutionByJobInstanceAndStepName = String.format(SQL.STEP_EXECUTION_BY_INSTANCE_AND_STEP, stepExecutionColumns[0], |
| stepExecutionColumns[13], stepExecutionColumns[1], |
| stepExecutionColumns[4], stepExecutionColumns[8], stepExecutionColumns[6], stepExecutionColumns[7], stepExecutionColumns[18], jobExecutionTable, stepExecutionTable, |
| jobExecutionColumns[0], stepExecutionColumns[18], jobExecutionColumns[8], stepExecutionColumns[15]); |
| this.deleteStepExecution = String.format(SQL.DELETE_STEP_EXECUTION, jobExecutionTable, stepExecutionTable, jobExecutionColumns[0], |
| stepExecutionColumns[18], jobExecutionColumns[8]); |
| this.deleteStepExecutionUntil = String.format(SQL.DELETE_STEP_EXECUTION_UNTIL, stepExecutionTable, stepExecutionColumns[0], stepExecutionColumns[0], |
| stepExecutionTable, jobExecutionTable, stepExecutionColumns[18], jobExecutionColumns[0], jobExecutionColumns[3]); |
| } |
| } |
| |
| private static String[] columns(final Database database, final String[] cols) { |
| final String[] out = new String[cols.length]; |
| for (int i = 0; i < cols.length; i++) { |
| out[i] = database.columnName(cols[i]); |
| } |
| return out; |
| } |
| |
| public String getCheckpointTable() { |
| return checkpointTable; |
| } |
| |
| public String getCreateCheckpointTable() { |
| return createCheckpointTable; |
| } |
| |
| public String getInsertCheckpoint() { |
| return insertCheckpoint; |
| } |
| |
| public String getSelectCheckpoint() { |
| return selectCheckpoint; |
| } |
| |
| public String getUpdateCheckpoint() { |
| return updateCheckpoint; |
| } |
| |
| public String getDeleteCheckpoint() { |
| return deleteCheckpoint; |
| } |
| |
| public String getJobInstanceTable() { |
| return jobInstanceTable; |
| } |
| |
| public String getCreateJobInstanceTable() { |
| return createJobInstanceTable; |
| } |
| |
| public String getCountJobInstanceByName() { |
| return countJobInstanceByName; |
| } |
| |
| public String getFindJobInstance() { |
| return findJobInstance; |
| } |
| |
| public String getUpdateJobInstanceStatus() { |
| return updateJobInstanceStatus; |
| } |
| |
| public String getFindJoBInstanceIds() { |
| return findJoBInstanceIds; |
| } |
| |
| public String getFindJobInstanceIdsByName() { |
| return findJobInstanceIdsByName; |
| } |
| |
| public String getFindExternalJobInstances() { |
| return findExternalJobInstances; |
| } |
| |
| public String getFindJobNames() { |
| return findJobNames; |
| } |
| |
| public String getCreateJobInstance() { |
| return createJobInstance; |
| } |
| |
| public String getCreateJobInstanceWithJobXml() { |
| return createJobInstanceWithJobXml; |
| } |
| |
| public String getDeleteJobInstance() { |
| return deleteJobInstance; |
| } |
| |
| public String getJobExecutionTable() { |
| return jobExecutionTable; |
| } |
| |
| public String getCreateJobExecutionTable() { |
| return createJobExecutionTable; |
| } |
| |
| public String getFindJobExecutionTimestamps() { |
| return findJobExecutionTimestamps; |
| } |
| |
| public String getFindJobExecutionBatchStatus() { |
| return findJobExecutionBatchStatus; |
| } |
| |
| public String getFindJobExecutionExitStatus() { |
| return findJobExecutionExitStatus; |
| } |
| |
| public String getFindJobExecutionJobProperties() { |
| return findJobExecutionJobProperties; |
| } |
| |
| public String getUpdateJobExecution() { |
| return updateJobExecution; |
| } |
| |
| public String getSetJobExecutionFinalData() { |
| return setJobExecutionFinalData; |
| } |
| |
| public String getUpdateStartedJobExecution() { |
| return updateStartedJobExecution; |
| } |
| |
| public String getFindJobExecutionById() { |
| return findJobExecutionById; |
| } |
| |
| public String getFindJobExecutionByInstance() { |
| return findJobExecutionByInstance; |
| } |
| |
| public String getFindRunningJobExecutions() { |
| return findRunningJobExecutions; |
| } |
| |
| public String getFindJobStatus() { |
| return findJobStatus; |
| } |
| |
| public String getFindJobInstanceFromJobExecution() { |
| return findJobInstanceFromJobExecution; |
| } |
| |
| public String getCreateJobExecution() { |
| return createJobExecution; |
| } |
| |
| public String getFindMostRecentJobExecution() { |
| return findMostRecentJobExecution; |
| } |
| |
| public String getDeleteJobExecution() { |
| return deleteJobExecution; |
| } |
| |
| public String getStepExecutionTable() { |
| return stepExecutionTable; |
| } |
| |
| public String getCreateStepExecutionTable() { |
| return createStepExecutionTable; |
| } |
| |
| public String getFinStepExecutionFromJobExecution() { |
| return finStepExecutionFromJobExecution; |
| } |
| |
| public String getFindStepExecutionFromId() { |
| return findStepExecutionFromId; |
| } |
| |
| public String getCreateStepExecution() { |
| return createStepExecution; |
| } |
| |
| public String getUpdateStepExecutionStatus() { |
| return updateStepExecutionStatus; |
| } |
| |
| public String getUpdateStepExecution() { |
| return updateStepExecution; |
| } |
| |
| public String getFindStepExecutionByJobInstanceAndStepName() { |
| return findStepExecutionByJobInstanceAndStepName; |
| } |
| |
| public String getDeleteStepExecution() { |
| return deleteStepExecution; |
| } |
| |
| public String checkpointColumn(final int idx) { |
| return checkpointColumns[idx]; |
| } |
| |
| public String jobInstanceColumns(final int idx) { |
| return jobInstanceColumns[idx]; |
| } |
| |
| public String jobExecutionColumns(final int idx) { |
| return jobExecutionColumns[idx]; |
| } |
| |
| public String stepExecutionColumns(final int idx) { |
| return stepExecutionColumns[idx]; |
| } |
| |
| public String getDeleteCheckpointUntil() { |
| return deleteCheckpointUntil; |
| } |
| |
| public String getDeleteJobInstanceUntil() { |
| return deleteJobInstanceUntil; |
| } |
| |
| public String getDeleteJobExecutionUntil() { |
| return deleteJobExecutionUntil; |
| } |
| |
| public String getDeleteStepExecutionUntil() { |
| return deleteStepExecutionUntil; |
| } |
| } |
| |
