如何在 NiFi PUTSQL 中运行 SQL 更新查询？答案

【问题标题】：How to run SQL Update query in NiFi PUTSQL?如何在 NiFi PUTSQL 中运行 SQL 更新查询？
【发布时间】：2019-02-20 21:08:45
【问题描述】：

我想使用 MySQL 更新查询将 tableB 的列 enum_value 更新为 tableA 中另一列 enum_value 的值，如下所示：

UPDATE tableB t1 
INNER JOIN TableA t2 ON t1.sig_name = t2.sig_name
SET t1.enum_value = t2.enum_value
WHERE t1.dbc_Version = t2.dbc_version

上述 SQL 查询在 MYSQL 工作台中运行良好，但我想执行此查询（使用 NiFi PUTSQL（SQL 语句）属性动态执行此 Update。当我在 NiFi PutSQL 中写了这个，我得到了一个错误。我附上了下面的截图：

我有没有办法使用 NiFi 实现动态（数据库中的动态更新）？如果是，那么控制器服务需要如何以及需要什么提前谢谢！要设置吗？

提前致谢！

【问题讨论】：

【解决方案1】：

如果您直接在 PutSQL 中进行查询，那么在此之前 ConvertJSONToSQL 处理器的用途是什么？该处理器从 JSON 数据生成属性，PutSQL 在尝试使用参数填充准备好的语句时会查找这些属性（您没有这些参数，因为您使用的是没有 ?s 的显式语句）。

更多信息请参见this SO post，基本上你应该使用 UpdateAttribute 删除任何由 ConvertJSONToSQL 创建的属性。

【讨论】：