Improve performance of JdbcStepExecutionDao::getLastStepExecution

1. Use SQL order by clause instead of Java Comparator
2. Limit result set size to 1

Signed-off-by: Yanming Zhou <zhouyanming@gmail.com>

Author: quaff

spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/jdbc/JdbcStepExecutionDao.java

@@ -24,7 +24,6 @@
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
-import java.util.Comparator;
 import java.util.Iterator;
 import java.util.List;
 import java.util.concurrent.locks.Lock;
@@ -44,6 +43,7 @@
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.dao.OptimisticLockingFailureException;
 import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.PreparedStatementCallback;
 import org.springframework.jdbc.core.RowMapper;
 import org.springframework.jdbc.support.incrementer.DataFieldMaxValueIncrementer;
 import org.springframework.lang.Nullable;
@@ -102,6 +102,7 @@ public class JdbcStepExecutionDao extends AbstractJdbcBatchMetadataDao implement
 			FROM %PREFIX%JOB_EXECUTION JE
 				JOIN %PREFIX%STEP_EXECUTION SE ON SE.JOB_EXECUTION_ID = JE.JOB_EXECUTION_ID
 			WHERE JE.JOB_INSTANCE_ID = ? AND SE.STEP_NAME = ?
+			ORDER BY SE.CREATE_TIME DESC, SE.STEP_EXECUTION_ID DESC
 			""";
 
 	private static final String CURRENT_VERSION_STEP_EXECUTION = """
@@ -121,10 +122,6 @@ SELECT COUNT(*)
 			WHERE STEP_EXECUTION_ID = ? and VERSION = ?
 			""";
 
-	private static final Comparator<StepExecution> BY_CREATE_TIME_DESC_ID_DESC = Comparator
-		.comparing(StepExecution::getCreateTime, Comparator.reverseOrder())
-		.thenComparing(StepExecution::getId, Comparator.reverseOrder());
-
 	private int exitMessageLength = DEFAULT_EXIT_MESSAGE_LENGTH;
 
 	private DataFieldMaxValueIncrementer stepExecutionIncrementer;
@@ -333,27 +330,34 @@ public StepExecution getStepExecution(JobExecution jobExecution, Long stepExecut
 		}
 	}
 
+	@Nullable
 	@Override
 	public StepExecution getLastStepExecution(JobInstance jobInstance, String stepName) {
-		List<StepExecution> executions = getJdbcTemplate().query(getQuery(GET_LAST_STEP_EXECUTION), (rs, rowNum) -> {
-			Long jobExecutionId = rs.getLong(19);
-			JobExecution jobExecution = new JobExecution(jobExecutionId);
-			jobExecution.setStartTime(rs.getTimestamp(20) == null ? null : rs.getTimestamp(20).toLocalDateTime());
-			jobExecution.setEndTime(rs.getTimestamp(21) == null ? null : rs.getTimestamp(21).toLocalDateTime());
-			jobExecution.setStatus(BatchStatus.valueOf(rs.getString(22)));
-			jobExecution.setExitStatus(new ExitStatus(rs.getString(23), rs.getString(24)));
-			jobExecution.setCreateTime(rs.getTimestamp(25) == null ? null : rs.getTimestamp(25).toLocalDateTime());
-			jobExecution.setLastUpdated(rs.getTimestamp(26) == null ? null : rs.getTimestamp(26).toLocalDateTime());
-			jobExecution.setVersion(rs.getInt(27));
-			return new StepExecutionRowMapper(jobExecution).mapRow(rs, rowNum);
-		}, jobInstance.getInstanceId(), stepName);
-		executions.sort(BY_CREATE_TIME_DESC_ID_DESC);
-		if (executions.isEmpty()) {
-			return null;
-		}
-		else {
-			return executions.get(0);
-		}
+		return getJdbcTemplate().execute(getQuery(GET_LAST_STEP_EXECUTION),
+				(PreparedStatementCallback<StepExecution>) statement -> {
+					statement.setMaxRows(1);
+					statement.setLong(1, jobInstance.getInstanceId());
+					statement.setString(2, stepName);
+					try (ResultSet rs = statement.executeQuery()) {
+						if (rs.next()) {
+							Long jobExecutionId = rs.getLong(19);
+							JobExecution jobExecution = new JobExecution(jobExecutionId);
+							jobExecution.setStartTime(
+									rs.getTimestamp(20) == null ? null : rs.getTimestamp(20).toLocalDateTime());
+							jobExecution
+								.setEndTime(rs.getTimestamp(21) == null ? null : rs.getTimestamp(21).toLocalDateTime());
+							jobExecution.setStatus(BatchStatus.valueOf(rs.getString(22)));
+							jobExecution.setExitStatus(new ExitStatus(rs.getString(23), rs.getString(24)));
+							jobExecution.setCreateTime(
+									rs.getTimestamp(25) == null ? null : rs.getTimestamp(25).toLocalDateTime());
+							jobExecution.setLastUpdated(
+									rs.getTimestamp(26) == null ? null : rs.getTimestamp(26).toLocalDateTime());
+							jobExecution.setVersion(rs.getInt(27));
+							return new StepExecutionRowMapper(jobExecution).mapRow(rs, 0);
+						}
+						return null;
+					}
+				});
 	}
 
 	@Override