mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-18 05:32:52 +00:00
113 lines
3.4 KiB
C++
113 lines
3.4 KiB
C++
#pragma once
|
|
|
|
#include <DB/Databases/IDatabase.h>
|
|
|
|
|
|
namespace DB
|
|
{
|
|
|
|
/** Движок баз данных по-умолчанию.
|
|
* Хранит список таблиц в локальной файловой системе в виде .sql файлов,
|
|
* содержащих определение таблицы в виде запроса ATTACH TABLE.
|
|
*/
|
|
class DatabaseOrdinary : public IDatabase
|
|
{
|
|
private:
|
|
const String name;
|
|
const String path;
|
|
mutable std::mutex mutex;
|
|
Tables tables;
|
|
|
|
Logger * log;
|
|
|
|
public:
|
|
DatabaseOrdinary(const String & name_, const String & path_);
|
|
|
|
String getEngineName() const override { return "Ordinary"; }
|
|
|
|
void loadTables(Context & context, ThreadPool * thread_pool, bool has_force_restore_data_flag) override;
|
|
|
|
bool isTableExist(const String & table_name) const override;
|
|
StoragePtr tryGetTable(const String & table_name) override;
|
|
|
|
DatabaseIteratorPtr getIterator() override;
|
|
|
|
bool empty() const override;
|
|
|
|
void createTable(const String & table_name, const StoragePtr & table, const ASTPtr & query, const String & engine) override;
|
|
void removeTable(const String & table_name) override;
|
|
|
|
void attachTable(const String & table_name, const StoragePtr & table) override;
|
|
StoragePtr detachTable(const String & table_name) override;
|
|
|
|
void renameTable(const Context & context, const String & table_name, IDatabase & to_database, const String & to_table_name) override;
|
|
|
|
time_t getTableMetadataModificationTime(const String & table_name) override;
|
|
|
|
ASTPtr getCreateQuery(const String & table_name) const override;
|
|
|
|
void shutdown() override;
|
|
void drop() override;
|
|
|
|
void alterTable(
|
|
const Context & context,
|
|
const String & name,
|
|
const NamesAndTypesList & columns,
|
|
const NamesAndTypesList & materialized_columns,
|
|
const NamesAndTypesList & alias_columns,
|
|
const ColumnDefaults & column_defaults,
|
|
const ASTModifier & engine_modifier) override;
|
|
};
|
|
|
|
|
|
class DatabaseMemory : public IDatabase
|
|
{
|
|
private:
|
|
const String name;
|
|
mutable std::mutex mutex;
|
|
Tables tables;
|
|
|
|
Logger * log = &Logger::get("DatabaseMemory");
|
|
|
|
public:
|
|
|
|
DatabaseMemory(const String & name_) : name(name_), log(&Logger::get("DatabaseMemory(" + name + ")")) {}
|
|
|
|
String getEngineName() const override { return "Memory"; }
|
|
|
|
void loadTables(Context & context, ThreadPool * thread_pool, bool has_force_restore_data_flag) override {}
|
|
|
|
bool isTableExist(const String & table_name) const override;
|
|
StoragePtr tryGetTable(const String & table_name) override;
|
|
|
|
DatabaseIteratorPtr getIterator() override;
|
|
|
|
bool empty() const override;
|
|
|
|
void createTable(const String & table_name, const StoragePtr & table, const ASTPtr & query, const String & engine) override;
|
|
void removeTable(const String & table_name) override;
|
|
|
|
void attachTable(const String & table_name, const StoragePtr & table) override;
|
|
StoragePtr detachTable(const String & table_name) override;
|
|
|
|
void renameTable(const Context & context, const String & table_name, IDatabase & to_database, const String & to_table_name) override;
|
|
|
|
time_t getTableMetadataModificationTime(const String & table_name) override;
|
|
|
|
ASTPtr getCreateQuery(const String & table_name) const override;
|
|
|
|
void shutdown() override;
|
|
void drop() override;
|
|
|
|
void alterTable(
|
|
const Context & context,
|
|
const String & name,
|
|
const NamesAndTypesList & columns,
|
|
const NamesAndTypesList & materialized_columns,
|
|
const NamesAndTypesList & alias_columns,
|
|
const ColumnDefaults & column_defaults,
|
|
const ASTModifier & engine_modifier) override;
|
|
};
|
|
|
|
}
|