#pragma once #include #include #include #include #include namespace Poco { class Logger; namespace Util { class AbstractConfiguration; } } namespace DB { class CStringsHolder; /// Allows loading dictionaries from dynamic libraries (.so) /// Experimental version /// Example: dbms/tests/external_dictionaries/dictionary_library/dictionary_library.cpp class LibraryDictionarySource final : public IDictionarySource { public: LibraryDictionarySource(const DictionaryStructure & dict_struct_, const Poco::Util::AbstractConfiguration & config, const std::string & config_prefix, Block & sample_block, const Context & context); LibraryDictionarySource(const LibraryDictionarySource & other); ~LibraryDictionarySource(); BlockInputStreamPtr loadAll() override; BlockInputStreamPtr loadUpdatedAll() override { throw Exception{"Method loadUpdatedAll is unsupported for LibraryDictionarySource", ErrorCodes::NOT_IMPLEMENTED}; } BlockInputStreamPtr loadIds(const std::vector & ids) override; BlockInputStreamPtr loadKeys(const Columns & key_columns, const std::vector & requested_rows) override; bool isModified() const override; bool supportsSelectiveLoad() const override; ///Not yet supported bool hasUpdateField() const override { return false; } DictionarySourcePtr clone() const override; std::string toString() const override; private: Poco::Logger * log; LocalDateTime getLastModification() const; const DictionaryStructure dict_struct; const std::string config_prefix; const std::string path; Block sample_block; const Context & context; SharedLibraryPtr library; ExternalResultDescription description; std::shared_ptr settings; void * lib_data = nullptr; }; }