mysql - 如何在 Pentaho PDI 工作流程中使用 SQL 函数创建新列？

Question

我有一个 sql 函数，比方说 theFunction(item_id)。它接受一个项目 ID 并计算一个值作为其返回值。我从数据库中读取了一个表，并且考虑到特定于该行的 item_id，我想通过此函数计算一个要附加到每一行的新值。哪个设计 block 会使用以下 SQL(如果没有错误的话)来完成此操作。

select thsFunction(item_id);

我假设该 block 将每行的 item_id 作为变量提供。

Answer 1

您可以使用另一个表输入步骤，并让它接受之前步骤中的字段并针对每一行执行(两个配置选项都位于该步骤窗口的底部)。

请注意，这是一个相当慢的实现。每个查询都是单独执行的，因此每一行都需要与数据库进行往返。

或者，您可以使用行 SQL 脚本。我相信它允许您在一次访问中将所有 SQL 语句传递到数据库。