@@ -281,9 +281,9 @@ public void updateStepExecution(StepExecution stepExecution) {
281281 stepExecution .getWriteSkipCount (), stepExecution .getRollbackCount (), lastUpdated ,
282282 stepExecution .getId (), stepExecution .getVersion () };
283283 int count = getJdbcTemplate ().update (getQuery (UPDATE_STEP_EXECUTION ), parameters ,
284- new int [] { Types .TIMESTAMP , Types .TIMESTAMP , Types .VARCHAR , Types .INTEGER , Types .INTEGER ,
285- Types .INTEGER , Types .INTEGER , Types .VARCHAR , Types .VARCHAR , Types .INTEGER , Types .INTEGER ,
286- Types .INTEGER , Types .INTEGER , Types .INTEGER , Types .TIMESTAMP , Types .BIGINT ,
284+ new int [] { Types .TIMESTAMP , Types .TIMESTAMP , Types .VARCHAR , Types .BIGINT , Types .BIGINT ,
285+ Types .BIGINT , Types .BIGINT , Types .VARCHAR , Types .VARCHAR , Types .INTEGER , Types .BIGINT ,
286+ Types .BIGINT , Types .BIGINT , Types .BIGINT , Types .TIMESTAMP , Types .BIGINT ,
287287 Types .INTEGER });
288288
289289 // Avoid concurrent modifications...
@@ -396,15 +396,15 @@ public StepExecution mapRow(ResultSet rs, int rowNum) throws SQLException {
396396 stepExecution .setStartTime (rs .getTimestamp (3 ) == null ? null : rs .getTimestamp (3 ).toLocalDateTime ());
397397 stepExecution .setEndTime (rs .getTimestamp (4 ) == null ? null : rs .getTimestamp (4 ).toLocalDateTime ());
398398 stepExecution .setStatus (BatchStatus .valueOf (rs .getString (5 )));
399- stepExecution .setCommitCount (rs .getInt (6 ));
400- stepExecution .setReadCount (rs .getInt (7 ));
401- stepExecution .setFilterCount (rs .getInt (8 ));
402- stepExecution .setWriteCount (rs .getInt (9 ));
399+ stepExecution .setCommitCount (rs .getLong (6 ));
400+ stepExecution .setReadCount (rs .getLong (7 ));
401+ stepExecution .setFilterCount (rs .getLong (8 ));
402+ stepExecution .setWriteCount (rs .getLong (9 ));
403403 stepExecution .setExitStatus (new ExitStatus (rs .getString (10 ), rs .getString (11 )));
404- stepExecution .setReadSkipCount (rs .getInt (12 ));
405- stepExecution .setWriteSkipCount (rs .getInt (13 ));
406- stepExecution .setProcessSkipCount (rs .getInt (14 ));
407- stepExecution .setRollbackCount (rs .getInt (15 ));
404+ stepExecution .setReadSkipCount (rs .getLong (12 ));
405+ stepExecution .setWriteSkipCount (rs .getLong (13 ));
406+ stepExecution .setProcessSkipCount (rs .getLong (14 ));
407+ stepExecution .setRollbackCount (rs .getLong (15 ));
408408 stepExecution .setLastUpdated (rs .getTimestamp (16 ) == null ? null : rs .getTimestamp (16 ).toLocalDateTime ());
409409 stepExecution .setVersion (rs .getInt (17 ));
410410 stepExecution .setCreateTime (rs .getTimestamp (18 ) == null ? null : rs .getTimestamp (18 ).toLocalDateTime ());
0 commit comments