如何使用nifi在mysql中获取最后插入的记录

Question

我试图在mysql数据库中插入一条记录，并在使用nifi插入成功时获取最后插入的记录。下面是流程结构我正在尝试。

convertJsontomysql -> putSQL(insert record) -> executeSQL (query to fetch last inserted record)

但它抛出一个错误，我不知道如何实现这个有人请帮忙。

提前致谢

Answer 1

尝试运行查询SELECT max(id), name FROM table1。如果您仍想使用包装器作为名称，请使用`而不是'（反引号而不是撇号）。

Answer 2

你确定这会有效吗？在新记录之间可能已经插入到表中。因此，您可能无法获得相关记录的ID。

也许更好的解决方案是使用PutSQL结束流程并让第二个获取数据？你可以查看here以获得一些想法。