mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-23 18:20:50 +00:00
d36f52502e
It's still hackish and dirty, but server and client compies. Server starts, but throwes meaningless exception on any query. Client seems to be working fine. Linux compilation might (but shouldn't) be broken (not tested).
60 lines
1.5 KiB
C++
60 lines
1.5 KiB
C++
#pragma once
|
|
|
|
#include <DB/Dictionaries/IDictionarySource.h>
|
|
#include <DB/Dictionaries/ODBCBlockInputStream.h>
|
|
#include <DB/Dictionaries/ExternalQueryBuilder.h>
|
|
#include <ext/range.hpp>
|
|
#include <mysqlxx/Pool.h>
|
|
|
|
#include <Poco/Util/AbstractConfiguration.h>
|
|
#include <Poco/Data/SessionPool.h>
|
|
|
|
|
|
namespace DB
|
|
{
|
|
|
|
|
|
/// Allows loading dictionaries from a ODBC source
|
|
class ODBCDictionarySource final : public IDictionarySource
|
|
{
|
|
static constexpr auto max_block_size = 8192;
|
|
|
|
public:
|
|
ODBCDictionarySource(const DictionaryStructure & dict_struct_,
|
|
const Poco::Util::AbstractConfiguration & config, const std::string & config_prefix,
|
|
const Block & sample_block);
|
|
|
|
/// copy-constructor is provided in order to support cloneability
|
|
ODBCDictionarySource(const ODBCDictionarySource & other);
|
|
|
|
BlockInputStreamPtr loadAll() override;
|
|
|
|
BlockInputStreamPtr loadIds(const std::vector<UInt64> & ids) override;
|
|
|
|
BlockInputStreamPtr loadKeys(
|
|
const ConstColumnPlainPtrs & key_columns, const std::vector<std::size_t> & requested_rows) override;
|
|
|
|
bool isModified() const override;
|
|
|
|
bool supportsSelectiveLoad() const override;
|
|
|
|
DictionarySourcePtr clone() const override;
|
|
|
|
std::string toString() const override;
|
|
|
|
private:
|
|
Logger * log = &Logger::get("ODBCDictionarySource");
|
|
|
|
const DictionaryStructure dict_struct;
|
|
const std::string db;
|
|
const std::string table;
|
|
const std::string where;
|
|
Block sample_block;
|
|
std::shared_ptr<Poco::Data::SessionPool> pool;
|
|
ExternalQueryBuilder query_builder;
|
|
const std::string load_all_query;
|
|
};
|
|
|
|
|
|
}
|