Как получить последнюю вставленную запись в MySQL, используя nifi

Question

я пытаюсь вставить запись в базу данных mysql и извлечь последнюю вставленную запись при успешной вставке, используя nifi.ниже структура потока пытаюсь.

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

но выдает ошибку, я не знаю, как этого добиться, пожалуйста, помогите.

заранее спасибо

Answer 1

Вы уверены, что это будет работать?между новыми записями, возможно, уже были вставлены в таблицу.Таким образом, вы можете не получить идентификатор рассматриваемой записи.

Может быть, лучшим решением было бы завершить поток с помощью PutSQL и иметь второй способ сбора данных?Вы можете проверить здесь , чтобы получить некоторые идеи.

Answer 2

Попробуйте вместо этого выполнить запрос SELECT max(id), name FROM table1.Если вы все еще хотите использовать обертку для имени, используйте `вместо '(обратный удар вместо апострофа).