NiFi中PutSQL执行MERGE返回成功但未修改PG数据库求助

问题背景 #

在NiFi中创建Processor Group（PG），执行以下MERGE语句：

MERGE INTO LIVENESS l
     USING (select ? as cdn from dual) ct 
     ON (ct.cdn = l.cdn)
  WHEN MATCHED THEN 
    UPDATE SET 
      l.LIVENESS_ENABLE  = ?, 
      l.DATETIME_LIVENESS_UPDATE  = TO_DATE(?,'YYYY-MM-DD HH24:MI:SS')
    WHERE (l.DATETIME_LIVENESS_UPDATE < TO_DATE(?,'YYYY-MM-DD HH24:MI:SS'))
  WHEN NOT MATCHED THEN 
    INSERT (CDN, LIVENESS_ENABLE, DATETIME_LIVENESS_UPDATE) 
    VALUES (?, ?, TO_DATE(?,'YYYY-MM-DD HH24:MI:SS'))

已在UpdateAttribute类型的PG中配置参数映射，PutSQL的PG配置也已完成，但MERGE语句所在PG返回执行成功，目标数据库却无任何修改，且无法访问NiFi日志，需排查方向。

排查建议 #

• 验证参数映射的准确性

  1. 核对UpdateAttribute中设置的参数顺序，必须与MERGE语句里的?严格对应：
     • 第1个?：USING子句的cdn值
     • 第2个?：UPDATE的LIVENESS_ENABLE值
     • 第3个?：UPDATE的DATETIME_LIVENESS_UPDATE日期字符串
     • 第4个?：UPDATE WHERE子句的日期字符串
     • 第5个?：INSERT的CDN值
     • 第6个?：INSERT的LIVENESS_ENABLE值
     • 第7个?：INSERT的DATETIME_LIVENESS_UPDATE日期字符串
  2. 临时添加LogAttribute处理器（先禁用PutSQL），将所有属性输出到FlowFile内容中，确认参数值是否符合预期，比如日期格式是否匹配YYYY-MM-DD HH24:MI:SS，cdn值是否正确。

• 排查MERGE语句的逻辑条件

  1. 更新分支：即使cdn匹配，UPDATE的WHERE子句l.DATETIME_LIVENESS_UPDATE < TO_DATE(?, ...)可能不满足，比如传入的日期早于或等于数据库现有记录的日期，导致更新不执行。可以拿着相同参数在数据库客户端手动执行MERGE语句，验证是否触发更新。
  2. 插入分支：如果测试用的cdn值在LIVENESS表中已存在，就不会走INSERT分支，需确认该cdn值在表中是否真的不存在。

• 检查PutSQL的事务配置

  1. 确认PutSQL的Auto Commit属性是否设为true，如果是false且没有后续的CommitSQL处理器，事务会回滚，修改不会生效。
  2. 核对Batch Size设置，若为单条MERGE操作，建议设为1，避免因批量配置问题导致数据未处理。

• 验证数据库权限
  检查NiFi连接数据库所用账号是否拥有LIVENESS表的UPDATE和INSERT权限，部分账号仅具备查询权限时，执行MERGE不会报错，但无法修改数据。

• 确认FlowFile的传递路径
  查看Processor Group间的连接状态，核对PutSQL处理器的FlowFiles In和FlowFiles Out计数，确认FlowFile确实流入并被处理器处理。

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