summaryrefslogtreecommitdiffstats
path: root/tests/dialects/test_clickhouse.py
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2023-10-04 12:14:40 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2023-10-04 12:14:40 +0000
commitd7f0758e21b5111b5327f3839c5c9f49a04d272b (patch)
treea425f4ebcc159d6bd9443fe4e0e2f9eb20151027 /tests/dialects/test_clickhouse.py
parentAdding upstream version 18.7.0. (diff)
downloadsqlglot-d7f0758e21b5111b5327f3839c5c9f49a04d272b.tar.xz
sqlglot-d7f0758e21b5111b5327f3839c5c9f49a04d272b.zip
Adding upstream version 18.11.2.upstream/18.11.2
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'tests/dialects/test_clickhouse.py')
-rw-r--r--tests/dialects/test_clickhouse.py43
1 files changed, 43 insertions, 0 deletions
diff --git a/tests/dialects/test_clickhouse.py b/tests/dialects/test_clickhouse.py
index 40a270e..948c00e 100644
--- a/tests/dialects/test_clickhouse.py
+++ b/tests/dialects/test_clickhouse.py
@@ -24,6 +24,9 @@ class TestClickhouse(Validator):
self.assertEqual(expr.sql(dialect="clickhouse"), "COUNT(x)")
self.assertIsNone(expr._meta)
+ self.validate_identity("SELECT * FROM (SELECT a FROM b SAMPLE 0.01)")
+ self.validate_identity("SELECT * FROM (SELECT a FROM b SAMPLE 1 / 10 OFFSET 1 / 2)")
+ self.validate_identity("SELECT sum(foo * bar) FROM bla SAMPLE 10000000")
self.validate_identity("CAST(x AS Nested(ID UInt32, Serial UInt32, EventTime DATETIME))")
self.validate_identity("CAST(x AS Enum('hello' = 1, 'world' = 2))")
self.validate_identity("CAST(x AS Enum('hello', 'world'))")
@@ -83,6 +86,16 @@ class TestClickhouse(Validator):
)
self.validate_all(
+ "SELECT '\\0'",
+ read={
+ "mysql": "SELECT '\0'",
+ },
+ write={
+ "clickhouse": "SELECT '\\0'",
+ "mysql": "SELECT '\0'",
+ },
+ )
+ self.validate_all(
"DATE_ADD('day', 1, x)",
read={
"clickhouse": "dateAdd(day, 1, x)",
@@ -224,6 +237,33 @@ class TestClickhouse(Validator):
self.validate_identity(
"SELECT s, arr_external FROM arrays_test ARRAY JOIN [1, 2, 3] AS arr_external"
)
+ self.validate_all(
+ "SELECT quantile(0.5)(a)",
+ read={"duckdb": "SELECT quantile(a, 0.5)"},
+ write={"clickhouse": "SELECT quantile(0.5)(a)"},
+ )
+ self.validate_all(
+ "SELECT quantiles(0.5, 0.4)(a)",
+ read={"duckdb": "SELECT quantile(a, [0.5, 0.4])"},
+ write={"clickhouse": "SELECT quantiles(0.5, 0.4)(a)"},
+ )
+ self.validate_all(
+ "SELECT quantiles(0.5)(a)",
+ read={"duckdb": "SELECT quantile(a, [0.5])"},
+ write={"clickhouse": "SELECT quantiles(0.5)(a)"},
+ )
+
+ self.validate_identity("SELECT isNaN(x)")
+ self.validate_all(
+ "SELECT IS_NAN(x), ISNAN(x)",
+ write={"clickhouse": "SELECT isNaN(x), isNaN(x)"},
+ )
+
+ self.validate_identity("SELECT startsWith('a', 'b')")
+ self.validate_all(
+ "SELECT STARTS_WITH('a', 'b'), STARTSWITH('a', 'b')",
+ write={"clickhouse": "SELECT startsWith('a', 'b'), startsWith('a', 'b')"},
+ )
def test_cte(self):
self.validate_identity("WITH 'x' AS foo SELECT foo")
@@ -305,6 +345,9 @@ class TestClickhouse(Validator):
def test_ddl(self):
self.validate_identity(
+ 'CREATE TABLE data5 ("x" UInt32, "y" UInt32) ENGINE=MergeTree ORDER BY (round(y / 1000000000), cityHash64(x)) SAMPLE BY cityHash64(x)'
+ )
+ self.validate_identity(
"CREATE TABLE foo (x UInt32) TTL time_column + INTERVAL '1' MONTH DELETE WHERE column = 'value'"
)