Spring Batch 5.x升级后JpaPagingItemReader查询Teradata报错

问题原因 #

Spring Batch 5.x依赖的Spring Data JPA/Hibernate版本更新后，JpaPagingItemReader结合JpaNativeQueryProvider处理原生SQL分页时，Hibernate会自动为Teradata方言生成SELECT TOP ?的语句，但Teradata的TOP语法要求必须是固定整数/十进制数，不支持参数占位符，因此触发语法错误。

解决方案 #

方案1：改用JPQL查询替代原生SQL #

如果业务逻辑允许，放弃原生SQL，使用JPQL查询，让Hibernate自动适配Teradata的分页语法：

// 替换JpaNativeQueryProvider为JpaQueryProvider
JpaQueryProvider<SomeEntity> provider = new JpaQueryProvider<>();
provider.setQueryString("SELECT e FROM SomeEntity e");
provider.setEntityClass(SomeEntity.class);

// 构建JpaPagingItemReader
JpaPagingItemReader<SomeEntity> r = new JpaPagingItemReaderBuilder<SomeEntity>()
        .name(someName)
        .entityManagerFactory(someEntityManagerFactory)
        .queryProvider(provider)
        .pageSize(50000)
        .build();
return r;

Hibernate会根据Teradata方言自动生成符合语法的分页查询，避免参数化TOP的问题。

方案2：手动编写带分页的原生SQL（适配Teradata） #

Teradata支持通过ROW_NUMBER()窗口函数实现分页，手动构造分页SQL，避免Hibernate自动添加参数化的TOP：

JpaNativeQueryProvider<SomeEntity> provider = new JpaNativeQueryProvider<>();
// 使用ROW_NUMBER()实现分页，替换为你的表和实际排序字段
String sql = """
    SELECT * FROM (
        SELECT t.*, ROW_NUMBER() OVER (ORDER BY your_sort_column) AS row_num 
        FROM table_name t
    ) temp 
    WHERE row_num BETWEEN ? AND ?
    """;
provider.setSqlQuery(sql);
provider.setEntityClass(SomeEntity.class);

// 构建Reader时自定义分页参数绑定
JpaPagingItemReader<SomeEntity> r = new JpaPagingItemReaderBuilder<SomeEntity>()
        .name(someName)
        .entityManagerFactory(someEntityManagerFactory)
        .queryProvider(provider)
        .pageSize(50000)
        .parameterValuesProvider(page -> {
            int start = (page.getPageNumber() * page.getPageSize()) + 1;
            int end = start + page.getPageSize() - 1;
            return Map.of("start", start, "end", end);
        })
        .build();
return r;

注意：your_sort_column需要替换为实际的排序字段，确保分页结果的稳定性。

方案3：自定义Hibernate Teradata方言修改分页逻辑 #

如果必须使用原生SQL且保留JpaPagingItemReader的自动分页，可以自定义方言，重写分页语句生成逻辑，避免参数化TOP：

public class CustomTeradataDialect extends TeradataDialect {
    @Override
    public String getLimitString(String sql, boolean hasOffset) {
        StringBuilder sb = new StringBuilder(sql.trim());
        // 插入TOP子句，这里需要结合实际分页逻辑调整，示例为固定pageSize写法
        int insertPosition = sql.toUpperCase().indexOf("SELECT") + 6;
        sb.insert(insertPosition, " TOP " + 50000 + " ");
        if (hasOffset) {
            // 适配Teradata的OFFSET语法（需确认版本支持）
            sb.append(" OFFSET ? ROWS");
        }
        return sb.toString();
    }
}

然后在Spring配置中指定自定义方言：

spring.jpa.properties.hibernate.dialect=com.yourpackage.CustomTeradataDialect

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