mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-10 09:32:06 +00:00
42 lines
2.0 KiB
Python
42 lines
2.0 KiB
Python
import time
|
|
import pytest
|
|
|
|
from helpers.cluster import ClickHouseCluster
|
|
|
|
cluster = ClickHouseCluster(__file__)
|
|
node1 = cluster.add_instance("node1")
|
|
node2 = cluster.add_instance("node2", main_configs=["configs/config_with_standard_part_log.xml"])
|
|
node3 = cluster.add_instance("node3", main_configs=["configs/config_with_non_standard_part_log.xml"])
|
|
|
|
@pytest.fixture(scope="module")
|
|
def start_cluster():
|
|
try:
|
|
cluster.start()
|
|
yield cluster
|
|
finally:
|
|
cluster.shutdown()
|
|
|
|
def test_config_without_part_log(start_cluster):
|
|
assert "Table system.part_log doesn't exist" in node1.query_and_get_error("SELECT * FROM system.part_log")
|
|
node1.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() ORDER BY value")
|
|
assert "Table system.part_log doesn't exist" in node1.query_and_get_error("SELECT * FROM system.part_log")
|
|
node1.query("INSERT INTO test_table VALUES ('name', 1)")
|
|
node1.query("SYSTEM FLUSH LOGS")
|
|
assert "Table system.part_log doesn't exist" in node1.query_and_get_error("SELECT * FROM system.part_log")
|
|
|
|
def test_config_with_standard_part_log(start_cluster):
|
|
assert node2.query("SELECT * FROM system.part_log") == ''
|
|
node2.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() Order by value")
|
|
assert node2.query("SELECT * FROM system.part_log") == ''
|
|
node2.query("INSERT INTO test_table VALUES ('name', 1)")
|
|
node2.query("SYSTEM FLUSH LOGS")
|
|
assert int(node2.query("SELECT count() FROM system.part_log")) == 1
|
|
|
|
def test_config_with_non_standard_part_log(start_cluster):
|
|
assert node3.query("SELECT * FROM system.own_part_log") == ''
|
|
node3.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() Order by value")
|
|
assert node3.query("SELECT * FROM system.own_part_log") == ''
|
|
node3.query("INSERT INTO test_table VALUES ('name', 1)")
|
|
node3.query("SYSTEM FLUSH LOGS")
|
|
assert int(node3.query("SELECT count() FROM system.own_part_log")) == 1
|