mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 16:50:48 +00:00
73 lines
2.6 KiB
Python
73 lines
2.6 KiB
Python
import pytest
|
|
|
|
from helpers.cluster import ClickHouseCluster
|
|
|
|
cluster = ClickHouseCluster(__file__)
|
|
node = cluster.add_instance(
|
|
"node", main_configs=["configs/config.xml"], with_zookeeper=True
|
|
)
|
|
|
|
|
|
@pytest.fixture(scope="module")
|
|
def started_cluster():
|
|
try:
|
|
cluster.start()
|
|
yield cluster
|
|
finally:
|
|
cluster.shutdown()
|
|
|
|
|
|
def create_force_drop_flag(node):
|
|
force_drop_flag_path = "/var/lib/clickhouse/flags/force_drop_table"
|
|
node.exec_in_container(
|
|
[
|
|
"bash",
|
|
"-c",
|
|
"touch {} && chmod a=rw {}".format(
|
|
force_drop_flag_path, force_drop_flag_path
|
|
),
|
|
],
|
|
user="root",
|
|
)
|
|
|
|
|
|
@pytest.mark.parametrize("engine", ["Ordinary", "Atomic"])
|
|
def test_drop_materialized_view(started_cluster, engine):
|
|
node.query(
|
|
"CREATE DATABASE d ENGINE={}".format(engine),
|
|
settings={"allow_deprecated_database_ordinary": 1},
|
|
)
|
|
node.query(
|
|
"CREATE TABLE d.rmt (n UInt64) ENGINE=ReplicatedMergeTree('/test/rmt', 'r1') ORDER BY n PARTITION BY n % 2"
|
|
)
|
|
node.query(
|
|
"CREATE MATERIALIZED VIEW d.mv (n UInt64, s String) ENGINE=MergeTree ORDER BY n PARTITION BY n % 2 AS SELECT n, toString(n) AS s FROM d.rmt"
|
|
)
|
|
node.query("INSERT INTO d.rmt VALUES (1), (2)")
|
|
assert "is greater than max" in node.query_and_get_error("DROP TABLE d.rmt")
|
|
assert "is greater than max" in node.query_and_get_error("DROP TABLE d.mv")
|
|
assert "is greater than max" in node.query_and_get_error("TRUNCATE TABLE d.rmt")
|
|
assert "is greater than max" in node.query_and_get_error("TRUNCATE TABLE d.mv")
|
|
assert "is greater than max" in node.query_and_get_error(
|
|
"ALTER TABLE d.rmt DROP PARTITION '0'"
|
|
)
|
|
assert node.query("SELECT * FROM d.rmt ORDER BY n") == "1\n2\n"
|
|
assert node.query("SELECT * FROM d.mv ORDER BY n") == "1\t1\n2\t2\n"
|
|
|
|
create_force_drop_flag(node)
|
|
node.query("ALTER TABLE d.rmt DROP PARTITION '0'")
|
|
assert node.query("SELECT * FROM d.rmt ORDER BY n") == "1\n"
|
|
assert "is greater than max" in node.query_and_get_error(
|
|
"ALTER TABLE d.mv DROP PARTITION '0'"
|
|
)
|
|
create_force_drop_flag(node)
|
|
node.query("ALTER TABLE d.mv DROP PARTITION '0'")
|
|
assert node.query("SELECT * FROM d.mv ORDER BY n") == "1\t1\n"
|
|
assert "is greater than max" in node.query_and_get_error("DROP TABLE d.rmt SYNC")
|
|
create_force_drop_flag(node)
|
|
node.query("DROP TABLE d.rmt SYNC")
|
|
assert "is greater than max" in node.query_and_get_error("DROP TABLE d.mv SYNC")
|
|
create_force_drop_flag(node)
|
|
node.query("DROP TABLE d.mv SYNC")
|
|
node.query("DROP DATABASE d")
|