2017-06-22 15:44:19 +00:00
|
|
|
#include <Databases/DatabaseDictionary.h>
|
|
|
|
#include <Interpreters/Context.h>
|
|
|
|
#include <Interpreters/ExternalDictionaries.h>
|
2017-06-23 15:55:45 +00:00
|
|
|
#include <Storages/StorageDictionary.h>
|
|
|
|
#include <common/logger_useful.h>
|
2017-06-22 15:44:19 +00:00
|
|
|
|
|
|
|
namespace DB
|
|
|
|
{
|
|
|
|
namespace ErrorCodes
|
|
|
|
{
|
|
|
|
extern const int TABLE_ALREADY_EXISTS;
|
|
|
|
extern const int UNKNOWN_TABLE;
|
|
|
|
extern const int LOGICAL_ERROR;
|
2018-01-30 17:47:04 +00:00
|
|
|
extern const int CANNOT_GET_CREATE_TABLE_QUERY;
|
2017-06-22 15:44:19 +00:00
|
|
|
}
|
|
|
|
|
2017-06-23 15:55:45 +00:00
|
|
|
DatabaseDictionary::DatabaseDictionary(const String & name_, const Context & context)
|
|
|
|
: name(name_),
|
|
|
|
external_dictionaries(context.getExternalDictionaries()),
|
|
|
|
log(&Logger::get("DatabaseDictionary(" + name + ")"))
|
|
|
|
{
|
|
|
|
}
|
|
|
|
|
2017-12-01 20:21:35 +00:00
|
|
|
void DatabaseDictionary::loadTables(Context &, ThreadPool *, bool)
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
2017-06-23 15:55:45 +00:00
|
|
|
}
|
2017-06-22 15:44:19 +00:00
|
|
|
|
2017-06-23 15:55:45 +00:00
|
|
|
Tables DatabaseDictionary::loadTables()
|
|
|
|
{
|
2017-10-06 10:31:06 +00:00
|
|
|
auto objects_map = external_dictionaries.getObjectsMap();
|
2017-10-26 14:26:03 +00:00
|
|
|
const auto & dictionaries = objects_map.get();
|
2017-06-22 15:44:19 +00:00
|
|
|
|
2017-06-23 15:55:45 +00:00
|
|
|
Tables tables;
|
2017-10-06 10:31:06 +00:00
|
|
|
for (const auto & pair : dictionaries)
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
|
|
|
const std::string & name = pair.first;
|
2017-06-23 15:55:45 +00:00
|
|
|
if (deleted_tables.count(name))
|
|
|
|
continue;
|
2017-10-06 10:31:06 +00:00
|
|
|
auto dict_ptr = std::static_pointer_cast<IDictionaryBase>(pair.second.loadable);
|
2017-06-22 15:44:19 +00:00
|
|
|
if (dict_ptr)
|
|
|
|
{
|
2017-10-06 10:31:06 +00:00
|
|
|
const DictionaryStructure & dictionary_structure = dict_ptr->getStructure();
|
2017-06-22 15:44:19 +00:00
|
|
|
auto columns = StorageDictionary::getNamesAndTypes(dictionary_structure);
|
2017-12-30 00:36:06 +00:00
|
|
|
tables[name] = StorageDictionary::create(name,
|
|
|
|
columns, NamesAndTypesList{}, NamesAndTypesList{}, ColumnDefaults{}, dictionary_structure, name);
|
2017-06-22 15:44:19 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2017-06-23 15:55:45 +00:00
|
|
|
return tables;
|
2017-06-22 15:44:19 +00:00
|
|
|
}
|
|
|
|
|
2017-09-11 12:39:01 +00:00
|
|
|
bool DatabaseDictionary::isTableExist(
|
2017-12-01 20:21:35 +00:00
|
|
|
const Context & /*context*/,
|
2017-09-11 12:39:01 +00:00
|
|
|
const String & table_name) const
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
2017-10-06 10:31:06 +00:00
|
|
|
auto objects_map = external_dictionaries.getObjectsMap();
|
2017-10-26 14:26:03 +00:00
|
|
|
const auto & dictionaries = objects_map.get();
|
2017-10-06 10:31:06 +00:00
|
|
|
return dictionaries.count(table_name) && !deleted_tables.count(table_name);
|
2017-06-22 15:44:19 +00:00
|
|
|
}
|
|
|
|
|
2017-09-11 12:39:01 +00:00
|
|
|
StoragePtr DatabaseDictionary::tryGetTable(
|
2017-12-01 20:21:35 +00:00
|
|
|
const Context & /*context*/,
|
2018-01-30 17:47:04 +00:00
|
|
|
const String & table_name) const
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
2017-10-06 10:31:06 +00:00
|
|
|
auto objects_map = external_dictionaries.getObjectsMap();
|
2017-10-26 14:26:03 +00:00
|
|
|
const auto & dictionaries = objects_map.get();
|
2017-06-23 15:55:45 +00:00
|
|
|
|
|
|
|
if (deleted_tables.count(table_name))
|
2017-06-22 15:44:19 +00:00
|
|
|
return {};
|
2017-06-23 15:55:45 +00:00
|
|
|
{
|
2017-10-06 10:31:06 +00:00
|
|
|
auto it = dictionaries.find(table_name);
|
|
|
|
if (it != dictionaries.end())
|
2017-06-23 15:55:45 +00:00
|
|
|
{
|
2017-10-06 10:31:06 +00:00
|
|
|
const auto & dict_ptr = std::static_pointer_cast<IDictionaryBase>(it->second.loadable);
|
2017-06-23 15:55:45 +00:00
|
|
|
if (dict_ptr)
|
|
|
|
{
|
2017-10-06 10:31:06 +00:00
|
|
|
const DictionaryStructure & dictionary_structure = dict_ptr->getStructure();
|
2017-06-23 15:55:45 +00:00
|
|
|
auto columns = StorageDictionary::getNamesAndTypes(dictionary_structure);
|
2017-12-30 00:36:06 +00:00
|
|
|
return StorageDictionary::create(table_name,
|
|
|
|
columns, NamesAndTypesList{}, NamesAndTypesList{}, ColumnDefaults{}, dictionary_structure, table_name);
|
2017-06-23 15:55:45 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return {};
|
2017-06-22 15:44:19 +00:00
|
|
|
}
|
|
|
|
|
2017-12-01 20:21:35 +00:00
|
|
|
DatabaseIteratorPtr DatabaseDictionary::getIterator(const Context & /*context*/)
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
2017-06-23 15:55:45 +00:00
|
|
|
return std::make_unique<DatabaseSnaphotIterator>(loadTables());
|
2017-06-22 15:44:19 +00:00
|
|
|
}
|
|
|
|
|
2017-12-01 20:21:35 +00:00
|
|
|
bool DatabaseDictionary::empty(const Context & /*context*/) const
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
2017-10-06 10:31:06 +00:00
|
|
|
auto objects_map = external_dictionaries.getObjectsMap();
|
2017-10-26 14:26:03 +00:00
|
|
|
const auto & dictionaries = objects_map.get();
|
2017-10-06 10:31:06 +00:00
|
|
|
for (const auto & pair : dictionaries)
|
|
|
|
if (pair.second.loadable && !deleted_tables.count(pair.first))
|
2017-06-23 15:55:45 +00:00
|
|
|
return false;
|
|
|
|
return true;
|
2017-06-22 15:44:19 +00:00
|
|
|
}
|
|
|
|
|
2017-12-01 20:21:35 +00:00
|
|
|
StoragePtr DatabaseDictionary::detachTable(const String & /*table_name*/)
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
|
|
|
throw Exception("DatabaseDictionary: detachTable() is not supported", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
2017-12-01 20:21:35 +00:00
|
|
|
void DatabaseDictionary::attachTable(const String & /*table_name*/, const StoragePtr & /*table*/)
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
|
|
|
throw Exception("DatabaseDictionary: attachTable() is not supported", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
2017-09-11 12:39:01 +00:00
|
|
|
void DatabaseDictionary::createTable(
|
2017-12-01 20:21:35 +00:00
|
|
|
const Context & /*context*/,
|
|
|
|
const String & /*table_name*/,
|
|
|
|
const StoragePtr & /*table*/,
|
|
|
|
const ASTPtr & /*query*/)
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
2017-06-23 15:55:45 +00:00
|
|
|
throw Exception("DatabaseDictionary: createTable() is not supported", ErrorCodes::NOT_IMPLEMENTED);
|
2017-06-22 15:44:19 +00:00
|
|
|
}
|
|
|
|
|
2017-09-11 12:39:01 +00:00
|
|
|
void DatabaseDictionary::removeTable(
|
|
|
|
const Context & context,
|
|
|
|
const String & table_name)
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
2017-09-11 12:39:01 +00:00
|
|
|
if (!isTableExist(context, table_name))
|
2017-06-23 15:55:45 +00:00
|
|
|
throw Exception("Table " + name + "." + table_name + " doesn't exist.", ErrorCodes::UNKNOWN_TABLE);
|
|
|
|
|
2017-10-06 10:31:06 +00:00
|
|
|
auto objects_map = external_dictionaries.getObjectsMap();
|
2017-06-23 15:55:45 +00:00
|
|
|
deleted_tables.insert(table_name);
|
2017-06-22 15:44:19 +00:00
|
|
|
}
|
|
|
|
|
2017-09-11 12:39:01 +00:00
|
|
|
void DatabaseDictionary::renameTable(
|
2017-12-01 20:21:35 +00:00
|
|
|
const Context &,
|
|
|
|
const String &,
|
|
|
|
IDatabase &,
|
|
|
|
const String &)
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
|
|
|
throw Exception("DatabaseDictionary: renameTable() is not supported", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
2017-09-11 12:39:01 +00:00
|
|
|
void DatabaseDictionary::alterTable(
|
2017-12-01 20:21:35 +00:00
|
|
|
const Context &,
|
|
|
|
const String &,
|
2017-12-25 21:57:29 +00:00
|
|
|
const NamesAndTypesList &,
|
|
|
|
const NamesAndTypesList &,
|
|
|
|
const NamesAndTypesList &,
|
2017-12-01 20:21:35 +00:00
|
|
|
const ColumnDefaults &,
|
|
|
|
const ASTModifier &)
|
2017-09-11 12:39:01 +00:00
|
|
|
{
|
|
|
|
throw Exception("DatabaseDictionary: alterTable() is not supported", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
|
|
|
time_t DatabaseDictionary::getTableMetadataModificationTime(
|
2017-12-01 20:21:35 +00:00
|
|
|
const Context &,
|
|
|
|
const String &)
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
|
|
|
return static_cast<time_t>(0);
|
|
|
|
}
|
|
|
|
|
2017-09-11 12:39:01 +00:00
|
|
|
ASTPtr DatabaseDictionary::getCreateQuery(
|
2017-12-01 20:21:35 +00:00
|
|
|
const Context &,
|
|
|
|
const String &) const
|
2017-06-22 15:44:19 +00:00
|
|
|
{
|
2018-01-30 17:47:04 +00:00
|
|
|
throw Exception("There is no CREATE TABLE query for DatabaseDictionary tables", ErrorCodes::CANNOT_GET_CREATE_TABLE_QUERY);
|
2017-06-22 15:44:19 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void DatabaseDictionary::shutdown()
|
|
|
|
{
|
|
|
|
}
|
|
|
|
|
|
|
|
void DatabaseDictionary::drop()
|
|
|
|
{
|
|
|
|
/// Additional actions to delete database are not required.
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|