summaryrefslogtreecommitdiffstats
path: root/contrib/clickhouse/src/Databases/DatabaseDictionary.cpp
diff options
context:
space:
mode:
authorAlexSm <[email protected]>2024-01-04 15:09:05 +0100
committerGitHub <[email protected]>2024-01-04 15:09:05 +0100
commitdab291146f6cd7d35684e3a1150e5bb1c412982c (patch)
tree36ef35f6cacb6432845a4a33f940c95871036b32 /contrib/clickhouse/src/Databases/DatabaseDictionary.cpp
parent63660ad5e7512029fd0218e7a636580695a24e1f (diff)
Library import 5, delete go dependencies (#832)
* Library import 5, delete go dependencies * Fix yt client
Diffstat (limited to 'contrib/clickhouse/src/Databases/DatabaseDictionary.cpp')
-rw-r--r--contrib/clickhouse/src/Databases/DatabaseDictionary.cpp143
1 files changed, 0 insertions, 143 deletions
diff --git a/contrib/clickhouse/src/Databases/DatabaseDictionary.cpp b/contrib/clickhouse/src/Databases/DatabaseDictionary.cpp
deleted file mode 100644
index 04529ff5293..00000000000
--- a/contrib/clickhouse/src/Databases/DatabaseDictionary.cpp
+++ /dev/null
@@ -1,143 +0,0 @@
-#include <Databases/DatabaseDictionary.h>
-#include <Interpreters/Context.h>
-#include <Interpreters/ExternalDictionariesLoader.h>
-#include <Dictionaries/DictionaryStructure.h>
-#include <Storages/StorageDictionary.h>
-#include <Common/logger_useful.h>
-#include <IO/WriteBufferFromString.h>
-#include <IO/Operators.h>
-#include <Parsers/ParserCreateQuery.h>
-#include <Parsers/parseQuery.h>
-#include <Parsers/IAST.h>
-
-
-namespace DB
-{
-namespace ErrorCodes
-{
- extern const int SYNTAX_ERROR;
- extern const int CANNOT_GET_CREATE_DICTIONARY_QUERY;
-}
-
-namespace
-{
- StoragePtr createStorageDictionary(const String & database_name, const ExternalLoader::LoadResult & load_result, ContextPtr context)
- {
- try
- {
- if (!load_result.config)
- return nullptr;
-
- DictionaryStructure dictionary_structure = ExternalDictionariesLoader::getDictionaryStructure(*load_result.config);
- auto comment = load_result.config->config->getString("dictionary.comment", "");
-
- return std::make_shared<StorageDictionary>(
- StorageID(database_name, load_result.name),
- load_result.name,
- dictionary_structure,
- comment,
- StorageDictionary::Location::DictionaryDatabase,
- context);
- }
- catch (Exception & e)
- {
- throw Exception(e.code(),
- "Error while loading dictionary '{}.{}': {}",
- database_name, load_result.name, e.displayText());
- }
- }
-}
-
-DatabaseDictionary::DatabaseDictionary(const String & name_, ContextPtr context_)
- : IDatabase(name_), WithContext(context_->getGlobalContext())
- , log(&Poco::Logger::get("DatabaseDictionary(" + database_name + ")"))
-{
-}
-
-Tables DatabaseDictionary::listTables(const FilterByNameFunction & filter_by_name) const
-{
- Tables tables;
- auto load_results = getContext()->getExternalDictionariesLoader().getLoadResults(filter_by_name);
- String db_name = getDatabaseName();
- for (auto & load_result : load_results)
- {
- auto storage = createStorageDictionary(db_name, load_result, getContext());
- if (storage)
- tables.emplace(storage->getStorageID().table_name, storage);
- }
- return tables;
-}
-
-bool DatabaseDictionary::isTableExist(const String & table_name, ContextPtr) const
-{
- return getContext()->getExternalDictionariesLoader().getCurrentStatus(table_name) != ExternalLoader::Status::NOT_EXIST;
-}
-
-StoragePtr DatabaseDictionary::tryGetTable(const String & table_name, ContextPtr) const
-{
- auto load_result = getContext()->getExternalDictionariesLoader().getLoadResult(table_name);
- return createStorageDictionary(getDatabaseName(), load_result, getContext());
-}
-
-DatabaseTablesIteratorPtr DatabaseDictionary::getTablesIterator(ContextPtr, const FilterByNameFunction & filter_by_table_name) const
-{
- return std::make_unique<DatabaseTablesSnapshotIterator>(listTables(filter_by_table_name), getDatabaseName());
-}
-
-bool DatabaseDictionary::empty() const
-{
- return !getContext()->getExternalDictionariesLoader().hasObjects();
-}
-
-ASTPtr DatabaseDictionary::getCreateTableQueryImpl(const String & table_name, ContextPtr, bool throw_on_error) const
-{
- String query;
- {
- WriteBufferFromString buffer(query);
-
- auto load_result = getContext()->getExternalDictionariesLoader().getLoadResult(table_name);
- if (!load_result.config)
- {
- if (throw_on_error)
- throw Exception(ErrorCodes::CANNOT_GET_CREATE_DICTIONARY_QUERY, "Dictionary {} doesn't exist", backQuote(table_name));
- return {};
- }
-
- auto names_and_types = StorageDictionary::getNamesAndTypes(ExternalDictionariesLoader::getDictionaryStructure(*load_result.config));
- buffer << "CREATE TABLE " << backQuoteIfNeed(getDatabaseName()) << '.' << backQuoteIfNeed(table_name) << " (";
- buffer << StorageDictionary::generateNamesAndTypesDescription(names_and_types);
- buffer << ") Engine = Dictionary(" << backQuoteIfNeed(table_name) << ")";
- }
-
- auto settings = getContext()->getSettingsRef();
- ParserCreateQuery parser;
- const char * pos = query.data();
- std::string error_message;
- auto ast = tryParseQuery(parser, pos, pos + query.size(), error_message,
- /* hilite = */ false, "", /* allow_multi_statements = */ false, 0, settings.max_parser_depth);
-
- if (!ast && throw_on_error)
- throw Exception::createDeprecated(error_message, ErrorCodes::SYNTAX_ERROR);
-
- return ast;
-}
-
-ASTPtr DatabaseDictionary::getCreateDatabaseQuery() const
-{
- String query;
- {
- WriteBufferFromString buffer(query);
- buffer << "CREATE DATABASE " << backQuoteIfNeed(getDatabaseName()) << " ENGINE = Dictionary";
- if (const auto comment_value = getDatabaseComment(); !comment_value.empty())
- buffer << " COMMENT " << backQuote(comment_value);
- }
- auto settings = getContext()->getSettingsRef();
- ParserCreateQuery parser;
- return parseQuery(parser, query.data(), query.data() + query.size(), "", 0, settings.max_parser_depth);
-}
-
-void DatabaseDictionary::shutdown()
-{
-}
-
-}