我有一个csv文件,其中存在插入查询。
我想创建一个作业来执行对DB的查询。
我该怎么做?
使用tFileInputDelimited组件根据文件配置读取csv文件,如字段和行分隔符。使用迭代链接将此组件连接到tFlowToIterate并将tFlowToIterate连接到db组件(tOracleRow,tMySQLRow同样基于您的数据库)。
在tFileInputDelimited中,定义如下的模式:Query
tFlowToIterate将迭代每一行(插入查询)并将其转换为键值对,然后将传递给DB组件以执行。
在DB组件中,((String)globalMap.get(“row3.Query”))
希望这有帮助