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

Merge pull request #60470 from ClickHouse/ClibMouse-bugfix/kql-distributed-tables

Browse Source 
Merging #59674.
This commit is contained in:
Alexey Milovidov 2024-02-28 19:24:14 +03:00 committed by GitHub
commit d93d5c2a00
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 47 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Client/HedgedConnections.cpp
View File

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

4
src/Client/MultiplexedConnections.cpp
View File

@ -126,6 +126,10 @@ void MultiplexedConnections::sendQuery(
Settings modified_settings = settings;
/// Queries in foreign languages are transformed to ClickHouse-SQL. Ensure the setting before sending.
modified_settings.dialect = Dialect::clickhouse;
modified_settings.dialect.changed = false;
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;