thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-14 10:22:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Check query_settings nullptr

Browse Source
This commit is contained in:
Кирилл Гарбар 2024-03-27 23:09:14 +03:00
parent f2e0a3be1c
commit 500379801b
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Databases/DatabaseOrdinary.cpp
View File

@ -31,7 +31,6 @@
#include <Common/CurrentMetrics.h> #include <Common/CurrentMetrics.h>
#include <Core/Defines.h> #include <Core/Defines.h>
#include <Storages/StorageReplicatedMergeTree.h> #include <Storages/StorageReplicatedMergeTree.h>
#include <Storages/MergeTree/MergeTreeSettings.h>
#include <boost/algorithm/string/replace.hpp> #include <boost/algorithm/string/replace.hpp>
@ -128,10 +127,10 @@ void DatabaseOrdinary::convertMergeTreeToReplicatedIfNeeded(ASTPtr ast, const Qu
/// Get table's storage policy /// Get table's storage policy
MergeTreeSettings default_settings = getContext()->getMergeTreeSettings(); MergeTreeSettings default_settings = getContext()->getMergeTreeSettings();
auto * query_settings = create_query->storage->settings->as<ASTSetQuery>();
auto policy = getContext()->getStoragePolicy(default_settings.storage_policy); auto policy = getContext()->getStoragePolicy(default_settings.storage_policy);
if (Field * policy_setting = query_settings->changes.tryGet("storage_policy")) if (auto * query_settings = create_query->storage->settings->as<ASTSetQuery>())
policy = getContext()->getStoragePolicy(policy_setting->get<String>()); if (Field * policy_setting = query_settings->changes.tryGet("storage_policy"))
policy = getContext()->getStoragePolicy(policy_setting->safeGet<String>());
auto convert_to_replicated_flag_path = getConvertToReplicatedFlagPath(qualified_name.table, policy, false); auto convert_to_replicated_flag_path = getConvertToReplicatedFlagPath(qualified_name.table, policy, false);