Я пытаюсь прочитать из Kafka topi c, который должен быть заполнен в несколько таблиц в mem sql.
Ниже я использую процедуру, которая будет вызываться в конвейере:
DELIMITER //
USING my_db_demo
CREATE OR REPLACE PROCEDURE test_batch_json(batch query(my_json json)) AS
BEGIN
INSERT INTO demo_json_table(id)
SELECT my_json::id FROM batch;
INSERT INTO demo_json_table2(name)
SELECT my_json::name FROM batch;
END //
DELIMITER ;
При выполнении про c Я получаю ошибку:
«ОШИБКА 1064 (42000): в синтаксисе SQL возникла ошибка; проверьте руководство, соответствующее вашей версии сервера MySQL, для правильного синтаксиса, чтобы использовать его рядом с 'PROCEDURE test_batch_ json (пакетный запрос (my_json json)) КАК НАЧАТЬ ВСТАВИТЬ В' 'в строке 1 ОШИБКА 1146 (42S02): Таблица «my_db_demo.batch» не существует »
Я новичок в mem sql и сейчас использую версию: 6.7.5. Ниже приведен формат json, который я использую, как устранить ошибку, но не уверен, что таблица представляет собой таблицу:
{"id": 345, "name": "Roony"}
Спасибо