Improve "JdbcJobExecutionDao#synchronizeStatus(StepExecution)"

This commit will save one query to improve performance.

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

Author: quaff

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

@@ -23,6 +23,7 @@
 import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
+import java.util.Objects;
 import java.util.Set;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
@@ -79,8 +80,8 @@ SELECT COUNT(*)
 			WHERE JOB_EXECUTION_ID = ?
 			""";
 
-	private static final String GET_STATUS = """
-			SELECT STATUS
+	private static final String GET_VERSION_AND_STATUS = """
+			SELECT VERSION, STATUS
 			FROM %PREFIX%JOB_EXECUTION
 			WHERE JOB_EXECUTION_ID = ?
 			""";
@@ -346,14 +347,13 @@ public Set<JobExecution> findRunningJobExecutions(String jobName) {
 
 	@Override
 	public void synchronizeStatus(JobExecution jobExecution) {
-		int currentVersion = getJdbcTemplate().queryForObject(getQuery(CURRENT_VERSION_JOB_EXECUTION), Integer.class,
-				jobExecution.getId());
-
-		if (currentVersion != jobExecution.getVersion()) {
-			String status = getJdbcTemplate().queryForObject(getQuery(GET_STATUS), String.class, jobExecution.getId());
-			jobExecution.upgradeStatus(BatchStatus.valueOf(status));
-			jobExecution.setVersion(currentVersion);
-		}
+		getJdbcTemplate().query(getQuery(GET_VERSION_AND_STATUS), rs -> {
+			Integer currentVersion = rs.getInt("VERSION");
+			if (!Objects.equals(currentVersion, jobExecution.getVersion())) {
+				jobExecution.upgradeStatus(BatchStatus.valueOf(rs.getString("STATUS")));
+				jobExecution.setVersion(currentVersion);
+			}
+		}, jobExecution.getId());
 	}
 
 	/**