thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-24 18:50:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Processors support for StorageMySQL reading.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-01-31 19:46:27 +03:00
parent dd888f59a7
commit cef9db809f
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
dbms/src/Storages/StorageMySQL.cpp
View File

@ -15,6 +15,8 @@
#include <IO/WriteHelpers.h>
#include <Parsers/ASTLiteral.h>
#include <mysqlxx/Transaction.h>
#include <Processors/Sources/SourceFromInputStream.h>
#include <Processors/Pipe.h>
namespace DB
@ -59,7 +61,7 @@ StorageMySQL::StorageMySQL(
}
BlockInputStreams StorageMySQL::read(
Pipes StorageMySQL::readWithProcessors(
const Names & column_names_,
const SelectQueryInfo & query_info_,
const Context & context_,
@ -78,7 +80,12 @@ BlockInputStreams StorageMySQL::read(
sample_block.insert({ column_data.type, column_data.name });
}
return { std::make_shared<MySQLBlockInputStream>(pool.Get(), query, sample_block, max_block_size_) };
Pipes pipes;
/// TODO: rewrite MySQLBlockInputStream
pipes.emplace_back(std::make_shared<SourceFromInputStream>(
std::make_shared<MySQLBlockInputStream>(pool.Get(), query, sample_block, max_block_size_)));
return pipes;
}

2
dbms/src/Storages/StorageMySQL.h
View File

@ -33,7 +33,7 @@ public:
std::string getName() const override { return "MySQL"; }
BlockInputStreams read(
Pipes readWithProcessors(
const Names & column_names,
const SelectQueryInfo & query_info,
const Context & context,