diff options
| author | AlexSm <[email protected]> | 2024-01-04 15:09:05 +0100 |
|---|---|---|
| committer | GitHub <[email protected]> | 2024-01-04 15:09:05 +0100 |
| commit | dab291146f6cd7d35684e3a1150e5bb1c412982c (patch) | |
| tree | 36ef35f6cacb6432845a4a33f940c95871036b32 /contrib/clickhouse/src/Databases/DatabaseDictionary.cpp | |
| parent | 63660ad5e7512029fd0218e7a636580695a24e1f (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.cpp | 143 |
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() -{ -} - -} |
