thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 17:41:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

columnar-sender: development [#METR-11888].

Browse Source
This commit is contained in:
Alexey Milovidov 2014-07-11 05:20:39 +04:00
parent 94012f8231
commit 818338872f
1 changed files with 1 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
dbms/src/Client/Connection.cpp
View File

@ -286,24 +286,12 @@ void Connection::sendData(const Block & block, const String & name)
void Connection::sendPreparedData(ReadBuffer & input, const String & name)
{
if (!block_out)
{
if (compression == Protocol::Compression::Enable)
maybe_compressed_out = new CompressedWriteBuffer(*out);
else
maybe_compressed_out = out;
block_out = new NativeBlockOutputStream(*maybe_compressed_out);
}
writeVarUInt(Protocol::Client::Data, *out);
if (server_revision >= DBMS_MIN_REVISION_WITH_TEMPORARY_TABLES)
writeStringBinary(name, *out);
copyData(input, *maybe_compressed_out);
maybe_compressed_out->next();
copyData(input, *out);
out->next();
}