我必须将以下 SQL 查询转换为 informatica 云逻辑

I have to convert below SQL Query to informatica cloud logic

连接器转换的输出(TestData table name in SQL Query)如下

我需要将数据加载到目标中,如下所示

我写了SQL 查询喜欢

SELECT * 来自 TestData 作为 A 其中 SourceSystem = 'NC' 和 存在 (SELECT * 来自 TestData AS B 其中 B.ClusterID = A.ClusterID 和 B.SourceString = '50012559' 和 B.SourceSystem = 'ACB' )

你能帮我如何将这个 SQL 查询隐藏到 Informatica 云中吗?

假设 testData 是一个连接器输出,这里就是解决方案。我假设,集群 ID 是唯一键。如果它不是唯一键,那么这个解决方案将导致重复。

首先,按 ClusterID 对连接器输出 TestData 进行排序。

然后在 SourceSystem = 'NC' 上放置一个过滤器 (filter1) 并创建管道 1。 将另一个过滤器 (filter2) 连接到 SourceString = '50012559' AND B.SourceSystem = 'ACB' 上的排序器并创建管道 2。 添加另一个加入者 - 条件将为 pipeline1.ClusterID =pipeline2.ClusterID.

joiner 的输出将是您想要的数据。

这就是映射的样子 -

                                    |-Filter 1 ->|  
TestData_Joiner... -SRT_ClusterID-->|-Filter 2 ->| -JNR_ClusterID-> <desired output>

请注意,这将生成如下所示的数据 SQL。 `` SELECT * FROM TestData AS A WHERE SourceSystem = 'NC' 并且存在(SELECT * FROM TestData AS B WHERE B.ClusterID = A.ClusterID AND B.SourceString = '50012559' 和 B.SourceSystem = 'ACB' )