在Pentaho Kettle Transformation上添加更新SQL查询

问题描述 投票:0回答:1

我有一个场景,我希望在表输入和表输出作业后运行更新脚本,有人可以协助吗?我尝试了这四个,但我似乎无法弄清楚如何使它们工作。

My Current Transformation

这是场景......

表输入:MySQL数据库表1(*从表1 *中选择*)

表输出:Oracle数据库(创建表1)

(这很好地完成,但后来我必须手动执行更新脚本。我正在寻找一种自动化的方法)

我想运行的更新查询:

*更新odb.table1 set colum1 ='New Value1',其中column1 ='Old Value1'

更新odb.table1 set colum1 ='New Value2',其中column1 ='Old Value2'*

先感谢您。

pentaho kettle pentaho-spoon pentaho-data-integration pdi
1个回答
0
投票

我使用了Execute SQL Script工具。我刚刚添加了以分号分隔的两个更新查询;

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

© www.soinside.com 2019 - 2024. All rights reserved.