thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 09:32:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Supported cluster macros inside table function 'cluster'

Browse Source
This commit is contained in:
Vadim Volodin 2021-07-28 15:33:40 +03:00 committed by Vadim Volodin
parent feeb278b65
commit 918a4e8ab3
4 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/TableFunctions/TableFunctionRemote.cpp
View File

@ -12,6 +12,7 @@
#include <Interpreters/IdentifierSemantic.h>
#include <Common/typeid_cast.h>
#include <Common/parseRemoteDescription.h>
#include <Common/Macros.h>
#include <TableFunctions/TableFunctionFactory.h>
#include <Core/Defines.h>
#include <common/range.h>
@ -156,10 +157,11 @@ void TableFunctionRemote::parseArguments(const ASTPtr & ast_function, ContextPtr
if (!cluster_name.empty())
{
/// Use an existing cluster from the main config
String cluster_name_expanded = context->getMacros()->expand(cluster_name);
if (name != "clusterAllReplicas")
cluster = context->getCluster(cluster_name);
cluster = context->getCluster(cluster_name_expanded);
else
cluster = context->getCluster(cluster_name)->getClusterWithReplicasAsShards(context->getSettings());
cluster = context->getCluster(cluster_name_expanded)->getClusterWithReplicasAsShards(context->getSettings());
}
else
{

1
tests/config/config.d/macros.xml
View File

@ -1,6 +1,7 @@
<yandex>
<macros>
<test>Hello, world!</test>
<default_cluster_macro>test_shard_localhost</default_cluster_macro>
<shard>s1</shard>
<replica>r1</replica>
<default_path_test>/clickhouse/tables/{database}/{shard}/</default_path_test>

2
tests/queries/0_stateless/02000_table_function_cluster_macros.reference Normal file
View File

@ -0,0 +1,2 @@
1
1

2
tests/queries/0_stateless/02000_table_function_cluster_macros.sql Normal file
View File

@ -0,0 +1,2 @@
SELECT _shard_num FROM cluster("{default_cluster_macro}", system.one);
SELECT _shard_num FROM clusterAllReplicas("{default_cluster_macro}", system.one);