如何仅通过单个Job参数获取Spring Batch的最后一次作业执行？

你的问题核心在于Spring Batch的JobInstance是由JobParameters唯一标识的——仅用userEmail作为参数会导致同一用户只能创建一个JobInstance，无法重复触发作业；添加startTime后虽然允许重复执行，但自带的getLastJobExecution要求匹配完整的JobParameters，无法仅通过userEmail查询。

以下是两种可行的解决方式：

1. 自定义JDBC查询（推荐） #

直接基于Spring Batch的数据库表结构编写SQL查询，通过JdbcTemplate执行，效率远高于全量查询后过滤。

示例代码 #

@Repository
public class CustomJobExecutionDao {

    private final JdbcTemplate jdbcTemplate;
    private final JobExecutionDao jobExecutionDao; // 注入Spring Batch自带的JobExecutionDao映射结果

    public CustomJobExecutionDao(JdbcTemplate jdbcTemplate, JobExecutionDao jobExecutionDao) {
        this.jdbcTemplate = jdbcTemplate;
        this.jobExecutionDao = jobExecutionDao;
    }

    public JobExecution getLastJobExecutionByUserEmail(String jobName, String userEmail) {
        String sql = """
            SELECT je.JOB_EXECUTION_ID
            FROM BATCH_JOB_EXECUTION je
            JOIN BATCH_JOB_INSTANCE ji ON je.JOB_INSTANCE_ID = ji.JOB_INSTANCE_ID
            JOIN BATCH_JOB_EXECUTION_PARAMS jep ON je.JOB_EXECUTION_ID = jep.JOB_EXECUTION_ID
            WHERE ji.JOB_NAME = ?
              AND jep.KEY_NAME = 'userEmail'
              AND jep.STRING_VAL = ?
            ORDER BY je.CREATE_TIME DESC
            LIMIT 1
        """;

        List<Long> executionIds = jdbcTemplate.query(sql, new Object[]{jobName, userEmail},
                (rs, rowNum) -> rs.getLong("JOB_EXECUTION_ID"));

        if (executionIds.isEmpty()) {
            return null;
        }

        return jobExecutionDao.getJobExecution(executionIds.get(0));
    }
}

注：SQL语句需根据数据库类型调整（如Oracle需替换LIMIT 1为ROWNUM = 1），同时确保与你使用的Spring Batch版本表结构一致。

2. 利用JobExplorer结合参数过滤（仅适用于小数据量） #

如果不想写自定义SQL，可以通过JobExplorer获取指定Job的所有JobInstance，逐个检查参数是否匹配userEmail后筛选最新执行记录。但这种方式会加载全量Job实例，数据量大时效率极低，仅作备选：

@Autowired
private JobExplorer jobExplorer;

public JobExecution getLastJobExecutionByUserEmail(String jobName, String userEmail) {
    List<JobInstance> jobInstances = jobExplorer.getJobInstances(jobName, 0, Integer.MAX_VALUE);
    JobExecution lastExecution = null;

    for (JobInstance instance : jobInstances) {
        JobParameters parameters = instance.getJobParameters();
        if (userEmail.equals(parameters.getString("userEmail"))) {
            List<JobExecution> executions = jobExplorer.findJobExecutions(instance);
            for (JobExecution execution : executions) {
                if (lastExecution == null || execution.getCreateTime().after(lastExecution.getCreateTime())) {
                    lastExecution = execution;
                }
            }
        }
    }

    return lastExecution;
}

关键注意事项 #

• 触发作业时必须保证JobParameters唯一性：每次触发都要添加可变参数（如当前时间戳System.currentTimeMillis()），确保同一用户可重复创建JobInstance并执行作业。
• 自定义JDBC查询是最优解，既能保证查询效率，又能满足仅按userEmail查询的需求，无需依赖全量数据加载。

内容的提问来源于stack exchange，提问作者another_CS_guy