如何使用查询的输出作为另一个查询的输入

Question

我是 Talend 的新手，但我想从事与此类似的工作： 在 tMysqlInput 中，创建 select 语句 returns 单行单列，然后在 tMongoDBInput 查询中使用该值来获取多个文档。
我怎么能在一个单一的工作中做到这一点，因为我无法 link tMysqlInput 到 tMongoDBInput with a row(Main)?

Answer 1

你可以这样做：

tMysqlInput -- main -- tFlowToIterate -- Iterate -- tMongoDBInput -- tMap -- etc

tFlowToIterate 的输入流被转换为全局变量，因此您可以通过引用全局变量在 mongoDB 组件查询中使用它：(String)globalMap.get("rowX.MyColumn")

rowX是tFlowToIterate传入的主行名，MyColumn是列名。确保将变量转换为适当的 java 类型。