Spring Batch 5中如何查看MySQL中编码的Job/Step执行上下文？

问题根源 #

Spring Batch 5默认更换了执行上下文的序列化策略：用Jackson2ExecutionContextStringSerializer替代了旧版本的XStreamExecutionContextStringSerializer。当上下文内容超过2500字符（SHORT_CONTEXT字段默认长度）时，序列化后的JSON会被GZIP压缩+Base64编码后存储，所以直接查看数据库值会显示为编码状态，这和DataGrip无关，是框架的默认行为。

解决方法 #

1. 禁用压缩，直接存储可读JSON #

如果作业上下文内容不长（不超过2500字符），可以关闭压缩，让SHORT_CONTEXT直接存储JSON字符串：

@Bean
public ExecutionContextSerializer executionContextSerializer() {
    Jackson2ExecutionContextStringSerializer serializer = new Jackson2ExecutionContextStringSerializer();
    serializer.setCompressionEnabled(false); // 关闭压缩
    return serializer;
}

注意：若内容超过字段长度限制，仍会被转存到LONG_CONTEXT字段，SHORT_CONTEXT会存储指向长上下文的标识。

2. 手动解码已存储的编码内容 #

如果需要保留压缩策略，可通过以下方式解码查看：

Java工具类解码

import java.util.Base64;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.util.zip.GZIPInputStream;

public class BatchContextDecoder {
    public static String decode(String encodedContext) throws Exception {
        byte[] decodedBytes = Base64.getDecoder().decode(encodedContext);
        try (GZIPInputStream gzipIn = new GZIPInputStream(new ByteArrayInputStream(decodedBytes));
             ByteArrayOutputStream out = new ByteArrayOutputStream()) {
            byte[] buffer = new byte[1024];
            int len;
            while ((len = gzipIn.read(buffer)) != -1) {
                out.write(buffer, 0, len);
            }
            return out.toString();
        }
    }
}

MySQL自定义函数解码（DataGrip中直接使用）

先创建解码函数：

CREATE FUNCTION DECODE_BATCH_CONTEXT(encoded TEXT) RETURNS TEXT
DETERMINISTIC
BEGIN
    DECLARE decoded BLOB;
    SET decoded = FROM_BASE64(encoded);
    RETURN UNCOMPRESS(decoded);
END;

查询时调用函数获取可读内容：

SELECT DECODE_BATCH_CONTEXT(SHORT_CONTEXT) AS readable_context FROM BATCH_JOB_EXECUTION_CONTEXT;

3. 回退到旧序列化器（不推荐） #

如果需要完全兼容旧版本的可读格式，可以切换回XStreamExecutionContextStringSerializer，但该序列化器已被标记为废弃，且存在安全风险，需配置允许序列化的类：

@Bean
public ExecutionContextSerializer executionContextSerializer() {
    XStreamExecutionContextStringSerializer serializer = new XStreamExecutionContextStringSerializer();
    // 配置允许序列化的类，避免安全漏洞
    serializer.setXStream(new com.thoughtworks.xstream.XStream() {{
        allowTypes(new Class[]{/* 你的作业上下文用到的实体类 */});
    }});
    return serializer;
}

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