работы с сервером (https://github.com/yandex/ClickHouse/blob/master/dbms/include/DB/Core/Protocol.h).
Я устанавливаю соединене и пересылаю на сервер данные (hello), в случае если все "ОК" сервер отсылает мне версию и таймзону, тут все отлично
Если что-то не так, например некорректное имя базы, то сервер отсылает мне пакет Exception https://github.com/yandex/ClickHouse/blob/1d836b2bf8fef378d47258957ff74ed3a4aff136/dbms/src/IO/WriteHelpers.cpp#L6
например
code [81 0 0 0]
name DB::Exception <nil>
message DB::Exception: Database nodefault doesn't exist <nil>
StackTrace
0. clickhouse-server(StackTrace::StackTrace()+0x16) [0x1160446]
1. clickhouse-server(DB::Exception::Exception(std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&, int)+0x1f) [0x10a528f]
2. clickhouse-server(DB::TCPHandler::runImpl()+0x2ab) [0x10ba50b]
3. clickhouse-server(DB::TCPHandler::run()+0x2b) [0x10bb7cb]
4. clickhouse-server(Poco::Net::TCPServerConnection::start()+0xf) [0x2c2652f]
5. clickhouse-server(Poco::Net::TCPServerDispatcher::run()+0x14b) [0x2c4990b]
6. clickhouse-server(Poco::PooledThread::run()+0xb7) [0x33fe497]
7. clickhouse-server(Poco::ThreadImpl::runnableEntry(void*)+0xa5) [0x33ed9a5]
8. /lib/x86_64-linux-gnu/libpthread.so.0(+0x76ba) [0x7fdfbd59f6ba]
9. /lib/x86_64-linux-gnu/libc.so.6(clone+0x6d) [0x7fdfbcbc082d]
has_nested [0]
Тут у меня вопрос по сериализации типов пересылаемых по сети, со строками все более-менее понятно дина (uvariant) + строка в байтах, меня интересует формат других типов чтоб их можно было рассериализовать на клиенте (например "code" (int) little endian, big endian или что-то еще ...)
Query
Что такое query_id, id "подготовленного" запроса; что за "временные таблицы" которые необходимо отправлять в блоке Data; какое сжатие можно использовать и конечно, хотелось бы некоторое описание этих пакетов чтоб понимать что и зачем отсылается и форматы пересылаемых данных
Для inset запросов сервер отвечает структурой таблицы после чего ожидает начала передачи данных
например у меня есть 2-а запроса
insert into imps (a, b, c, d) values (?, ?, ?, ?)
и
insert into imps values (?, ?, ?, ?)
что я должен отослать на сервер в качестве query
оба
insert into imps
и отсылать данные в зависимости от порядка колонок в запросе
(a, b, c, d)
или сервер сам разберется
для запросов на получение данных как я понимаю 1-я часть идентична, отсылаем query после чего получаем названия и тыпы колонок и рассериализуем полученные данные (но тут тоже хочется описания форматов)
Если коротко: хочется описания некоторого flow работы и описания формаов/пакетов )
Привет, вы можете посмотреть код здесь: https://github.com/artpaul/clickhouse-cpp/blob/master/clickhouse/client.cpp Он работает на приём данных. Отправку ещё не сделал.
Обсуждают сегодня