Pentaho Data Integrator多表批量同步实现：无需重复配置步骤

方式一：自定义循环遍历表列表（推荐） #

这种方法能精准控制单表同步逻辑，步骤如下：

• 初始化表列表数据源：保留你已创建的Table Input步骤，确保输出字段包含table_name（目标表名）和source_sql（查询源数据的SQL语句）。
• 搭建循环框架：
  1. 用Copy rows to result步骤将Table Input输出的所有表信息存入结果集；
  2. 添加Start步骤作为循环入口，接着用Get rows from result步骤每次取出一行（对应一张表的配置）。
• 动态执行源查询：添加Table Input步骤，在SQL输入框中写入${source_sql}，并在步骤「选项」标签里勾选「替换SQL语句里的变量」，确保每次循环执行当前行的查询语句。
• 动态输出到目标表：添加Table Output步骤，在「目标表名」输入框中写入${table_name}，同样开启变量替换，让查询结果自动插入对应目标表。
• 完成循环闭环：添加Loop步骤，设置循环条件为「直到结果集为空」，将流程连回Get rows from result，实现全表遍历。

方式二：改进Execute row SQL script实现同步 #

针对你之前无法处理结果集的问题，结合动态子转换调用解决：

• 创建子转换：新建一个独立转换，内部包含：
  1. Table Input步骤，用变量${source_sql}获取源数据；
  2. Table Output步骤，用变量${table_name}指定目标表；
  3. 确保两个步骤都开启变量替换功能。
• 主转换调用子转换：
  1. 主转换保留初始的Table Input步骤（输出table_name和source_sql）；
  2. 添加Execute a transformation步骤，选择刚才创建的子转换；
  3. 在「传递参数」配置中，将主转换的table_name和source_sql字段值传递给子转换的同名变量。每一行表配置都会触发一次子转换，完成单表的查询与插入。

关键注意事项 #

• 确认源库与目标库的表结构匹配，若存在字段名/类型差异，可在子转换中添加Select values步骤做字段映射；
• 可添加Logging步骤记录每张表的同步状态，便于后续排查问题；
• 全量同步前建议先测试少量表，验证逻辑无误后再批量运行。

内容的提问来源于stack exchange，提问作者Hernán