#pragma once #include #include #include #include #include #include namespace Poco { class Logger; } namespace DB { struct DictionaryStructure; struct IDictionaryBase; class ExternalDictionaries; class StorageDictionary : public ext::shared_ptr_helper, public IStorage { friend struct ext::shared_ptr_helper; public: std::string getName() const override { return "Dictionary"; } Pipes read(const Names & column_names, const SelectQueryInfo & query_info, const Context & context, QueryProcessingStage::Enum processed_stage, size_t max_block_size = DEFAULT_BLOCK_SIZE, unsigned threads = 1) override; static NamesAndTypesList getNamesAndTypes(const DictionaryStructure & dictionary_structure); template static std::string generateNamesAndTypesDescription(ForwardIterator begin, ForwardIterator end) { std::string description; { WriteBufferFromString buffer(description); bool first = true; for (; begin != end; ++begin) { if (!first) buffer << ", "; first = false; buffer << begin->name << ' ' << begin->type->getName(); } } return description; } private: using Ptr = MultiVersion::Version; String dictionary_name; Poco::Logger * logger; void checkNamesAndTypesCompatibleWithDictionary(const DictionaryStructure & dictionary_structure) const; protected: StorageDictionary( const StorageID & table_id_, const ColumnsDescription & columns_, const Context & context, bool attach, const String & dictionary_name_); }; }