#pragma once #include #include #include #include #include #include #include namespace DB { class Context; class ASTCreateQuery; class ASTStorage; struct StorageID; /** Allows to create a table by the name and parameters of the engine. * In 'columns' Nested data structures must be flattened. * You should subsequently call IStorage::startup method to work with table. */ class StorageFactory : private boost::noncopyable, public IHints<1, StorageFactory> { public: static StorageFactory & instance(); struct Arguments { const String & engine_name; ASTs & engine_args; ASTStorage * storage_def; const ASTCreateQuery & query; /// Path to table data. /// Relative to from server config (possibly of some of some for *MergeTree) const String & relative_data_path; const StorageID & table_id; Context & local_context; Context & context; const ColumnsDescription & columns; const ConstraintsDescription & constraints; bool attach; bool has_force_restore_data_flag; }; using Creator = std::function; StoragePtr get( const ASTCreateQuery & query, const String & relative_data_path, Context & local_context, Context & context, const ColumnsDescription & columns, const ConstraintsDescription & constraints, bool has_force_restore_data_flag) const; /// Register a table engine by its name. /// No locking, you must register all engines before usage of get. void registerStorage(const std::string & name, Creator creator); const auto & getAllStorages() const { return storages; } std::vector getAllRegisteredNames() const override { std::vector result; auto getter = [](const auto & pair) { return pair.first; }; std::transform(storages.begin(), storages.end(), std::back_inserter(result), getter); return result; } private: using Storages = std::unordered_map; Storages storages; }; }