thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

../../tests

Browse Source
This commit is contained in:
divanik 2024-05-31 13:17:28 +00:00
parent 439ac99897
commit 4b99a16b88
4 changed files with 101 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/integration/test_disk_types/test.py
View File

@ -6,7 +6,7 @@ disk_types = {
"default": "Local",
"disk_s3": "S3",
"disk_encrypted": "S3",
"local": "Local"
"local": "Local",
}
# do not test HDFS on ARM
@ -20,9 +20,9 @@ def cluster():
cluster = ClickHouseCluster(__file__)
cluster.add_instance(
"node",
main_configs=["configs/storage_arm.xml"]
if is_arm()
else ["configs/storage_amd.xml"],
main_configs=(
["configs/storage_arm.xml"] if is_arm() else ["configs/storage_amd.xml"]
),
with_minio=True,
with_hdfs=not is_arm(),
)
@ -96,7 +96,9 @@ def test_select_by_type(cluster):
if disk_type == "Local":
assert (
node.query(
"SELECT name FROM system.disks WHERE type='" + disk_type + "' ORDER BY name"
"SELECT name FROM system.disks WHERE type='"
+ disk_type
+ "' ORDER BY name"
)
== "default\nlocal\n"
)

101
tests/integration/test_disks_app_func/test.py
View File

@ -50,7 +50,13 @@ def test_disks_app_func_ld(started_cluster):
["/usr/bin/clickhouse", "disks", "--save-logs", "--query", "list-disks"]
)
disks = list(sorted(map(lambda x : x.split(':')[0], filter(lambda x : len(x) > 1, out.split("\n")))))
disks = list(
sorted(
map(
lambda x: x.split(":")[0], filter(lambda x: len(x) > 1, out.split("\n"))
)
)
)
assert disks[:4] == ["default", "local", "test1", "test2"]
@ -61,7 +67,15 @@ def test_disks_app_func_ls(started_cluster):
init_data(source)
out = source.exec_in_container(
["/usr/bin/clickhouse", "disks", "--save-logs", "--disk", "test1", "--query", "list ."]
[
"/usr/bin/clickhouse",
"disks",
"--save-logs",
"--disk",
"test1",
"--query",
"list .",
]
)
files = out.split("\n")
@ -118,7 +132,15 @@ def test_disks_app_func_cp(started_cluster):
)
out = source.exec_in_container(
["/usr/bin/clickhouse", "disks", "--save-logs", "--disk", "test2", "--query", "list ."]
[
"/usr/bin/clickhouse",
"disks",
"--save-logs",
"--disk",
"test2",
"--query",
"list .",
]
)
assert "path1" in out
@ -150,13 +172,29 @@ def test_disks_app_func_cp(started_cluster):
# alesapin: Why we need list one more time?
# kssenii: it is an assertion that the file is indeed deleted
out = source.exec_in_container(
["/usr/bin/clickhouse", "disks", "--save-logs", "--disk", "test2", "--query", "list ."]
[
"/usr/bin/clickhouse",
"disks",
"--save-logs",
"--disk",
"test2",
"--query",
"list .",
]
)
assert "path1" not in out
out = source.exec_in_container(
["/usr/bin/clickhouse", "disks", "--save-logs", "--disk", "test1", "--query", "list ."]
[
"/usr/bin/clickhouse",
"disks",
"--save-logs",
"--disk",
"test1",
"--query",
"list .",
]
)
assert "path1" not in out
@ -210,7 +248,15 @@ def test_disks_app_func_rm(started_cluster):
)
out = source.exec_in_container(
["/usr/bin/clickhouse", "disks", "--save-logs", "--disk", "test2", "--query", "list ."]
[
"/usr/bin/clickhouse",
"disks",
"--save-logs",
"--disk",
"test2",
"--query",
"list .",
]
)
assert "path3" in out
@ -228,7 +274,15 @@ def test_disks_app_func_rm(started_cluster):
)
out = source.exec_in_container(
["/usr/bin/clickhouse", "disks", "--save-logs", "--disk", "test2", "--query", "list ."]
[
"/usr/bin/clickhouse",
"disks",
"--save-logs",
"--disk",
"test2",
"--query",
"list .",
]
)
assert "path3" not in out
@ -240,8 +294,15 @@ def test_disks_app_func_mv(started_cluster):
init_data(source)
out = source.exec_in_container(
["/usr/bin/clickhouse", "disks", "--save-logs", "--disk", "test1",
"--query", "list ."]
[
"/usr/bin/clickhouse",
"disks",
"--save-logs",
"--disk",
"test1",
"--query",
"list .",
]
)
files = out.split("\n")
@ -260,7 +321,15 @@ def test_disks_app_func_mv(started_cluster):
)
out = source.exec_in_container(
["/usr/bin/clickhouse", "disks", "--save-logs", "--disk", "test1", "--query", "list ."]
[
"/usr/bin/clickhouse",
"disks",
"--save-logs",
"--disk",
"test1",
"--query",
"list .",
]
)
files = out.split("\n")
@ -312,7 +381,15 @@ def test_remote_disk_list(started_cluster):
init_data_s3(source)
out = source.exec_in_container(
["/usr/bin/clickhouse", "disks", "--save-logs", "--disk", "test3", "--query", "list ."]
[
"/usr/bin/clickhouse",
"disks",
"--save-logs",
"--disk",
"test3",
"--query",
"list .",
]
)
files = out.split("\n")
@ -327,7 +404,7 @@ def test_remote_disk_list(started_cluster):
"--disk",
"test3",
"--query",
"list . --recursive"
"list . --recursive",
]
)

6
tests/integration/test_endpoint_macro_substitution/test.py
View File

@ -8,7 +8,7 @@ disk_types = {
"disk_s3": "S3",
"disk_hdfs": "HDFS",
"disk_encrypted": "S3",
"local": "Local"
"local": "Local",
}
if is_arm():
@ -75,7 +75,9 @@ def test_select_by_type(cluster):
if disk_type == "Local":
assert (
node.query(
"SELECT name FROM system.disks WHERE type='" + disk_type + "' ORDER BY name"
"SELECT name FROM system.disks WHERE type='"
+ disk_type
+ "' ORDER BY name"
)
== "default\nlocal\n"
)

4
tests/integration/test_multiple_disks/test.py
View File

@ -83,9 +83,7 @@ def test_system_tables(start_cluster):
"path": "/external/",
"keep_free_space": "0",
},
{
"name": "local", "path": "/", "keep_free_space": "0"
}
{"name": "local", "path": "/", "keep_free_space": "0"},
]
click_disk_data = json.loads(