Spring Batch重启时步骤执行上下文从RDBMS批处理元数据表加载的机制及长数据处理疑问

一、超过2500字符的执行上下文如何完整加载？ #

你观察到的short_context列截断是正常现象，但这完全不影响完整数据的存储和加载——因为Spring Batch默认的batch_step_execution_context表设计里，还有一个**long_context字段**（通常是CLOB/TEXT这类大文本类型）。

具体逻辑是：

• 当执行上下文的序列化内容长度≤2500字符时，数据会同时存入short_context和long_context；
• 当内容超过2500字符时，short_context仅作为预览字段被截断并添加省略号，完整的序列化数据会被完整存入long_context；
• 作业重启加载执行上下文时，框架会优先读取long_context中的完整数据，完全不会依赖short_context的截断内容。

如果你的项目使用了自定义schema，一定要确保保留long_context字段，否则才会出现数据丢失的问题。

二、用步骤执行上下文传递分区标识符给读取器的逻辑 #

这是Spring Batch分区场景下的常规用法，整个流程的核心逻辑如下：

1. 主步骤生成分区：在分区步骤（PartitionStep）中，你会通过Partitioner生成多个独立分区，每个分区的唯一标识符（比如分区ID、数据范围的起止值等）会被存入该分区对应的执行上下文中；
2. 子步骤绑定上下文：Spring Batch会为每个分区启动独立的子步骤执行，启动时会自动将该分区的执行上下文绑定到子步骤的StepExecution对象中；
3. 读取器获取分区标识：你的读取器可以通过StepExecution拿到执行上下文，进而获取分区标识符。常用的实现方式有两种：
   • 让读取器实现StepExecutionListener接口，在beforeStep(StepExecution stepExecution)方法中读取上下文；
   • 在读取器的初始化方法（比如afterPropertiesSet()）中注入StepExecution，直接读取上下文参数。

举个简单的代码示例：

public class PartitionedItemReader implements ItemReader<YourData>, StepExecutionListener {
    private StepExecution stepExecution;
    private String partitionId;

    @Override
    public void beforeStep(StepExecution stepExecution) {
        this.stepExecution = stepExecution;
        // 从执行上下文获取预先存入的分区标识符
        this.partitionId = stepExecution.getExecutionContext().getString("partitionId");
    }

    @Override
    public YourData read() throws Exception {
        // 使用partitionId查询对应分区的数据
        return yourDataSource.fetchDataByPartitionId(partitionId);
    }

    // 其他方法实现...
}

这种设计的好处是，每个子步骤的读取器只处理自己分区内的数据，既实现了并行处理的隔离性，又能让Spring Batch自动管理每个分区的执行状态，重启时也能准确恢复到对应分区的执行位置。

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