thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-28 02:21:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'bugfix/kql-distributed-tables' of github.com:ClibMouse/ClickHouse into ClibMouse-bugfix/kql-distributed-tables

Browse Source
This commit is contained in:
Alexey Milovidov 2024-02-27 23:31:25 +01:00
commit 142a857281
4 changed files with 45 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Client/HedgedConnections.cpp
View File

@ -177,6 +177,9 @@ void HedgedConnections::sendQuery(
{
Settings modified_settings = settings;
/// Queries in foreign languages are transformed to ClickHouse-SQL. Ensure the setting before sending.
modified_settings.dialect.resetValueToDefault();
if (disable_two_level_aggregation)
{
/// Disable two-level aggregation due to version incompatibility.

3
src/Client/MultiplexedConnections.cpp
View File

@ -126,6 +126,9 @@ void MultiplexedConnections::sendQuery(
Settings modified_settings = settings;
/// Queries in foreign languages are transformed to ClickHouse-SQL. Ensure the setting before sending.
modified_settings.dialect.resetValueToDefault();
for (auto & replica : replica_states)
{
if (!replica.connection)

9
tests/queries/0_stateless/02985_dialects_with_distributed_tables.reference Normal file
View File

@ -0,0 +1,9 @@
123
234
315
123
234
315
123
234
315

30
tests/queries/0_stateless/02985_dialects_with_distributed_tables.sql Normal file
View File

@ -0,0 +1,30 @@
-- Tags: no-fasttest, distributed
DROP TABLE IF EXISTS shared_test_table;
DROP TABLE IF EXISTS distributed_test_table;
CREATE TABLE shared_test_table (id UInt64)
ENGINE = MergeTree
ORDER BY (id);
CREATE TABLE distributed_test_table
ENGINE = Distributed(test_cluster_two_shard_three_replicas_localhost, currentDatabase(), shared_test_table);
INSERT INTO shared_test_table VALUES (123), (651), (446), (315), (234), (764);
SELECT id FROM distributed_test_table LIMIT 3;
SET dialect = 'kusto';
distributed_test_table | take 3;
SET dialect = 'prql';
from distributed_test_table
select {id}
take 1..3;
SET dialect = 'clickhouse';
DROP TABLE distributed_test_table;
DROP TABLE shared_test_table;