#pragma once #include #include namespace DB { /** Default engine of databases. * It stores tables list in filesystem using list of .sql files, * that contain declaration of table represented by SQL ATTACH TABLE query. */ class DatabaseOrdinary : public DatabaseWithDictionaries //DatabaseWithOwnTablesBase { public: DatabaseOrdinary(String name_, const String & metadata_path_, const Context & context); String getEngineName() const override { return "Ordinary"; } void loadStoredObjects( Context & context, bool has_force_restore_data_flag) override; void createTable( const Context & context, const String & table_name, const StoragePtr & table, const ASTPtr & query) override; void createDictionary( const Context & context, const String & dictionary_name, const ASTPtr & query) override; void removeTable( const Context & context, const String & table_name) override; void removeDictionary( const Context & context, const String & table_name) override; void renameTable( const Context & context, const String & table_name, IDatabase & to_database, const String & to_table_name, TableStructureWriteLockHolder &) override; void alterTable( const Context & context, const String & name, const ColumnsDescription & columns, const IndicesDescription & indices, const ConstraintsDescription & constraints, const ASTModifier & engine_modifier) override; time_t getObjectMetadataModificationTime( const Context & context, const String & table_name) override; ASTPtr getCreateDatabaseQuery(const Context & context) const override; String getDataPath() const override; String getMetadataPath() const override; String getObjectMetadataPath(const String & table_name) const override; void drop(const Context & context) override; protected: ASTPtr getCreateTableQueryImpl(const Context & context, const String & table_name, bool throw_on_error) const override; ASTPtr getCreateDictionaryQueryImpl(const Context & context, const String & name, bool throw_on_error) const override; private: const String metadata_path; const String data_path; Poco::Logger * log; void startupTables(ThreadPool & thread_pool); }; }