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

Question

我是 Talend 的新手，但我想从事与此类似的工作:在 tMysqlInput 中，创建一个返回单行单列的 select 语句，然后在 tMongoDBInput 查询中使用该值来获取多个文档。
我如何才能在单个作业中执行此操作，因为我无法将 tMysqlInput 链接到带有行(主)的 tMongoDBInput？

Answer 1

你可以这样做:

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

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

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