基于Lookup与时间戳的Informix到Azure SQL DB增量加载问题咨询

• 原查询存在语法逻辑错误，正确逻辑是用Lookup获取的Azure SQL最新时间戳，过滤出Informix中时间戳晚于该值的数据
• 修正后的查询语句：

  SELECT * FROM informixdb 
  WHERE systemtimestamp > @{activity('LookupSYS_TIME').output.firstRow.last_sync_time}
  

• 核心注意事项：
  • 适配Lookup输出结构：Lookup活动返回的结果嵌套在firstRow中，需根据Lookup查询的别名调整字段名（比如Lookup执行的是SELECT MAX(systemtimestamp) AS last_sync_time FROM azure_sql_table，就用last_sync_time）
  • 时间类型匹配：确保Informix的systemtimestamp与Azure SQL存储的时间戳类型、时区一致，避免过滤偏差
  • 首次增量兜底：若Lookup无返回值（首次增量），可通过COALESCE设置默认值：

    SELECT * FROM informixdb 
    WHERE systemtimestamp > COALESCE(@{activity('LookupSYS_TIME').output.firstRow.last_sync_time}, '1970-01-01 00:00:00')
    

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