如何使用Talend TOS实现SQL Server表数据查询、SQL执行及逐行更新

核心作业配置步骤 #

• 第一步：配置TDbInput组件（已完成的部分可直接调整）
  编写查询SQL只拉取待执行的记录，避免重复执行：

  SELECT Query, state, DataInsert, Error, Dataexecution FROM TABLE_FOR_TOS WHERE state = 0
  

• 第二步：将TDbInput的输出流连接到tFlowToIterate组件
  该组件会自动将每行的字段值存入全局变量，变量格式为流名称.字段名，假设TDbInput的输出流名为row1，那么Query字段对应的全局变量为(String)globalMap.get("row1.Query")。
• 第三步：用iterate连接将tFlowToIterate绑定到第一个tDBRow组件（执行动态SQL）
  tDBRow复用SQL Server连接配置，组件内执行语句直接填全局变量即可：
  (String)globalMap.get("row1.Query")
• 第四步：用「组件执行成功」触发器连接第一个tDBRow到第二个tDBRow组件（更新执行状态）
  第二个tDBRow内写入更新语句，建议如果表有自增主键就用主键作为筛选条件，没有的话可以用Query字段匹配：

  UPDATE TABLE_FOR_TOS 
  SET state = 1, Dataexecution = GETDATE()
  WHERE Query = ?
  

  在组件的参数面板中，将第一个占位符参数绑定为(String)globalMap.get("row1.Query")即可。

可选优化配置 #

• 若需要记录执行错误的记录，可添加「组件执行失败」触发器连接第一个tDBRow到第三个tDBRow，写入更新失败状态的SQL：

  UPDATE TABLE_FOR_TOS 
  SET state = 2, Error = ?
  WHERE Query = ?
  

  第一个参数绑定为((Exception)globalMap.get("tDBRow_1_ERROR_MESSAGE")).toString()，第二个参数绑定为Query字段的全局变量即可。
• 可在状态更新的tDBRow后添加tCommit组件提交事务，避免异常时数据不一致。

内容的提问来源于stack exchange，提问作者SmartDev