在Pentaho水壶转换上添加更新SQL查询

Question

我有一个场景，我想在表输入和表输出作业之后运行更新脚本，有人可以帮忙吗？我已经尝试了这四个，但我似乎无法弄清楚如何使它们起作用。

My Current Transformation

这是场景...

表输入：MySQL 数据库 Table1 (*Select * from Table1*)

表输出：Oracle 数据库（创建表 1）

（这运行良好，但我必须手动执行更新脚本。我正在寻找一种方法来自动执行此操作）

我要运行的更新查询：

*update odb.table1 set colum1='New Value1' where column1='Old Value1'

更新 odb.table1 set colum1='New Value2' where column1='Old Value2'*

提前谢谢你。

Answer 1

我使用了执行 SQL 脚本工具。我刚刚添加了两个用分号分隔的更新查询；。

我创建了两个转换。一个用于表输入和表输出，另一个用于执行 SQL 脚本工具。 然后我创建了一个 Kettle Job 并将我的查询放在表输出转换之后。