如何在Pentaho Kettle中实现账号区间值的批量生成？

一、修复SQL Server脚本在Kettle中的变量报错问题 #

你遇到的「未声明标量变量@COL_MIN」错误，核心原因是Kettle无法直接识别SQL Server的局部变量语法，需改用Kettle的参数绑定机制解决：

1. 修改SQL脚本，将原有的@COL_MIN、@COL_MAX替换为占位符?：

WITH nums AS (
    SELECT ? AS conta
    UNION ALL
    SELECT conta + 1 FROM nums WHERE conta < ?
)
SELECT conta FROM nums OPTION (MAXRECURSION 0)

2. 在Kettle的「Table Input」步骤中，切换到「参数」选项卡，依次将上游传入的MIN_CONTA和MAX_CONTA字段绑定到两个?占位符。
3. 确保上游步骤已将分类表的MIN_CONTA和MAX_CONTA字段传递到当前SQL步骤，执行即可生成对应区间的账号。

二、Kettle原生组件实现（替代Row Generator方案） #

Row Generator无法成功的关键是它无法动态匹配每行的区间范围，推荐用「User Defined Java Class」步骤实现动态序列生成，流程如下：

1. 读取分类表：用「Table Input」步骤读取包含MIN_CONTA和MAX_CONTA的分类表数据。
2. 添加自定义Java类步骤：
   • 新建「User Defined Java Class」步骤，连接到Table Input的输出。
   • 在「Fields」选项卡中，添加输出字段conta，类型设为与账号匹配的数值类型（如Long）。
   • 在「Script」选项卡中，替换默认代码为：

import java.util.ArrayList;

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {
    Object[] r = getRow();
    if (r == null) {
        setOutputDone();
        return false;
    }

    // 获取当前行的MIN和MAX值
    Long minConta = get(Fields.In, "MIN_CONTA").getLong(r);
    Long maxConta = get(Fields.In, "MAX_CONTA").getLong(r);

    // 遍历区间生成账号并输出
    for (long conta = minConta; conta <= maxConta; conta++) {
        Object[] outputRow = createOutputRow(r, data.outputRowMeta.size());
        get(Fields.Out, "conta").setValue(outputRow, conta);
        putRow(data.outputRowMeta, outputRow);

    }

    return true;
}

3. 执行流程，即可生成每行区间内的所有账号。

补充说明 #

如果账号是带前缀的字符串类型，只需修改Java代码中conta的赋值逻辑，例如：

get(Fields.Out, "conta").setValue(outputRow, "ACC_" + conta);

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