Добрый день коллеги, есть вопрос как вставлять данные в таблицу

Question

Добрый день коллеги, есть вопрос как вставлять данные в таблицу

из приложения.
Использую clickhouse-jdbc, есть коллекция объектов, перевожу их в json и пытаюсь вставить.
Код примерно как в примере:
val sb = new StringBuilder()
events.map(ev => json.eventToString(ev)).foreach(s => sb.append(s +"\n"))
val stream = new ByteArrayInputStream(sb.toString().getBytes("UTF-8") )
try {
sth.write().sendToTable(table, stream, ClickHouseFormat.JSONStringEachRow)
} catch {
case ex: java.sql.SQLException => log.error("An error occurred when inserting data into clickhouse", ex)
}
получаю эксептион DB::Exception: Format JSONStringEachRow is not suitable for input (with processors)
в юнит тестах не нашел примера, может кто подсказать?

#backend #clickhouse #database #devops #programming #russian

0

08.07.2021

2 ответов

16 просмотров

Andrey Smirnov Автор вопроса

Vladimir Goncharov
хотел предложить попробовать другой формат вместо ...

да, я сам себе ответил :)

0

08.07.2021

Vladimir Goncharov · Accepted Answer

Vladimir Goncharov

хотел предложить попробовать другой формат вместо ClickHouseFormat.JSONStringEachRow, но смотрю вам уже ответили :) https://github.com/ClickHouse/clickhouse-jdbc/issues/681

0

08.07.2021

184 похожих чатов

Добрый день коллеги, есть вопрос как вставлять данные в таблицу

2 ответов

Похожие вопросы