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

Всем привет, у меня есть несколько вопросов по "native" протоколу

работы с сервером (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 работы и описания формаов/пакетов )

1 ответов

19 просмотров

Привет, вы можете посмотреть код здесь: https://github.com/artpaul/clickhouse-cpp/blob/master/clickhouse/client.cpp Он работает на приём данных. Отправку ещё не сделал.

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

Обсуждают сегодня

а через ESC-код ?
Alexey Kulakov
29
30500 за редактор? )
Владимир
47
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
13
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Как передать управляющий символ в открытую через CreateProcess консоль? Собсна, есть процедура: procedure TRedirectThread.WriteData(Data: OEMString); var Written: Cardinal;...
Serjone
6
в JclConsole объявлено так: function CtrlHandler(CtrlType: DWORD): BOOL; stdcall; - где ваше объявление с stdcall? у вас на картинке нет stdcall
Karagy
8
Ребят в СИ можно реализовать ООП?
Николай
33
program test; {$mode delphi} procedure proc(v: int32); overload; begin end; procedure proc(v: int64); overload; begin end; var x: uint64; begin proc(x); end. Уж не знаю...
notme
6
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта