68
68
* @author Mahmoud Ben Hassine
69
69
* @author Baris Cubukcuoglu
70
70
* @author Minsoo Kim
71
+ * @author Yanming Zhou
71
72
* @see StepExecutionDao
72
73
*/
73
74
public class JdbcStepExecutionDao extends AbstractJdbcBatchMetadataDao implements StepExecutionDao , InitializingBean {
@@ -88,12 +89,12 @@ public class JdbcStepExecutionDao extends AbstractJdbcBatchMetadataDao implement
88
89
private static final String GET_RAW_STEP_EXECUTIONS = """
89
90
SELECT STEP_EXECUTION_ID, STEP_NAME, START_TIME, END_TIME, STATUS, COMMIT_COUNT, READ_COUNT, FILTER_COUNT, WRITE_COUNT, EXIT_CODE, EXIT_MESSAGE, READ_SKIP_COUNT, WRITE_SKIP_COUNT, PROCESS_SKIP_COUNT, ROLLBACK_COUNT, LAST_UPDATED, VERSION, CREATE_TIME
90
91
FROM %PREFIX%STEP_EXECUTION
91
- WHERE JOB_EXECUTION_ID = ?
92
92
""" ;
93
93
94
- private static final String GET_STEP_EXECUTIONS = GET_RAW_STEP_EXECUTIONS + " ORDER BY STEP_EXECUTION_ID" ;
94
+ private static final String GET_STEP_EXECUTIONS = GET_RAW_STEP_EXECUTIONS
95
+ + " WHERE JOB_EXECUTION_ID = ? ORDER BY STEP_EXECUTION_ID" ;
95
96
96
- private static final String GET_STEP_EXECUTION = GET_RAW_STEP_EXECUTIONS + " AND STEP_EXECUTION_ID = ?" ;
97
+ private static final String GET_STEP_EXECUTION = GET_RAW_STEP_EXECUTIONS + " WHERE STEP_EXECUTION_ID = ?" ;
97
98
98
99
private static final String GET_LAST_STEP_EXECUTION = """
99
100
SELECT SE.STEP_EXECUTION_ID, SE.STEP_NAME, SE.START_TIME, SE.END_TIME, SE.STATUS, SE.COMMIT_COUNT, SE.READ_COUNT, SE.FILTER_COUNT, SE.WRITE_COUNT, SE.EXIT_CODE, SE.EXIT_MESSAGE, SE.READ_SKIP_COUNT, SE.WRITE_SKIP_COUNT, SE.PROCESS_SKIP_COUNT, SE.ROLLBACK_COUNT, SE.LAST_UPDATED, SE.VERSION, SE.CREATE_TIME, JE.JOB_EXECUTION_ID, JE.START_TIME, JE.END_TIME, JE.STATUS, JE.EXIT_CODE, JE.EXIT_MESSAGE, JE.CREATE_TIME, JE.LAST_UPDATED, JE.VERSION
@@ -327,7 +328,7 @@ private String truncateExitDescription(String description) {
327
328
@ Nullable
328
329
public StepExecution getStepExecution (JobExecution jobExecution , Long stepExecutionId ) {
329
330
List <StepExecution > executions = getJdbcTemplate ().query (getQuery (GET_STEP_EXECUTION ),
330
- new StepExecutionRowMapper (jobExecution ), jobExecution . getId (), stepExecutionId );
331
+ new StepExecutionRowMapper (jobExecution ), stepExecutionId );
331
332
332
333
Assert .state (executions .size () <= 1 ,
333
334
"There can be at most one step execution with given name for single job execution" );
0 commit comments