首先,在数据流转换的输入源中,使用“查询”选项添加一个由内嵌SQL查询定义的查询。
选择“从嵌套查询映射值创建新列”,并将嵌套SQL查询中返回的列映射到新列。
在数据流转换的下一步中,可以使用SQL表达式语言来访问和过滤嵌套查询返回的数据。这可以在“导致”选项卡上完成。
下面是一个简单的示例,说明如何在数据流转换中实现嵌套SQL查询。
准备输入和输出数据集。
创建数据流。选择输入和输出数据集,然后选择“数据流转换”。
在“数据流转换”页面上,选择输入源。然后,选择“添加查询”。
SELECT * FROM sales WHERE sales_id IN
(SELECT sales_id FROM sales_detail WHERE item_qty > 10)
将返回的列映射到新列。在“嵌套查询映射”中选择“从嵌套查询映射值创建新列”。
在“表达式”选项卡上,可以使用SQL表达式语言来访问和过滤内部查询的数据。例如,可以使用以下表达式来过滤“销售日期”列中为“2021-01-01”的行:
iif(tostring([sales_date]) == "2021-01-01", true, false)