testing - 从 pentaho pdi 中的输入表捕获执行的 sql

Question

我正在使用 pentaho 进行数据迁移测试。我已经设置了一个“表输入”步骤，其中“表输入”中查询的许多部分都是变量。我一直在寻找一种在运行时执行后捕获该查询的方法。我想知道 sql 是否有任何特定的系统日志变量，或者它是否与元数据有关。需要帮忙!谢谢

Answer 1

也许以下方法会有所帮助:

• 我们假设转换读取 CSV 文件以获取 SELECT 语句的动态部分(例如列)并使用它设置变量 columns。

• 第二个转换使用此变量生成 SELECT 语句并将其存储到变量 sql_statement 中。

• 在主转换中，我们使用${sql_statement} 作为表输入的SELECT 语句，并将数据写入输出文件(可以说是业务流程)。从相同的输入，我们复制输出到另一个路径。在那里，我们将当前时间添加为一个字段(使用元素“获取系统数据”)，我们添加生成的 SQL 语句，将它们作为笛卡尔积连接起来，并将结果按 sql_statement 分组。这样我们就可以计算第一次和最后一次使用该语句的时间。这些结果被写入一个文本文件。

• 我们最不需要的是按顺序调用三个转换的作业。

这是一个示例输出:

sql_statement;min_time;max_time
SELECT my_column FROM test_table;2014/05/08 00:41:21.143;2014/05/08 00:41:21.144