NiFi插入数据前删除SQL表记录失败，报PostgreSQL列索引错误

你遇到的报错是因为PutSQL-1执行自定义DELETE语句时，流文件里还带着ConvertJSONToSQL生成的INSERT参数（sql.args.*系列属性）。PutSQL会默认尝试把这些参数绑定到你配置的DELETE语句上，但DELETE语句没有对应的占位符，所以触发了"列索引越界"的错误。

方案一：分离DELETE与INSERT的流文件（最稳妥） #

把删除操作和插入操作的流文件分开处理，避免参数干扰：

• 添加GenerateFlowFile处理器：生成一个空内容的流文件（内容设为空字符串即可），专门用来触发删除操作。
• 添加ExecuteSQL处理器：配置和PutSQL一致的数据库连接池，在SQL Statement里填DELETE FROM mytable;，将GenerateFlowFile的成功输出连接到这里。
• 添加Notify处理器：接在ExecuteSQL的成功输出后，设置一个自定义的通知标识（比如delete_done），用来标记删除完成。
• 在ConvertJSONToSQL之后添加Wait处理器：配置同样的通知标识delete_done，让生成好INSERT语句的流文件等删除操作完成后再往下走。
• 将Wait的成功输出连接到PutSQL-2执行插入。

方案二：用PutSQL的预执行SQL（更简洁，需版本支持） #

检查NiFi 1.21.0的PutSQL-2处理器是否有Pre-SQL Statement配置项：

• 如果存在该配置项，直接在PutSQL-2里把这个属性设为DELETE FROM mytable;。
• 这样PutSQL-2会先执行DELETE清空表，再自动执行流文件里的INSERT语句，全程不需要额外处理器，也不会有参数绑定问题。

你提到的NIFI-4522确实支持PutSQL执行自定义SQL后传递原流文件，但前提是流文件里没有多余的参数属性。你当前流程里，流文件经过ConvertJSONToSQL后携带了INSERT的参数，才导致PutSQL误绑定报错，不是NiFi的bug，属于流程配置问题。

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