mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-22 23:52:03 +00:00
Created integration test for part_log table
This commit is contained in:
parent
f05fa092a2
commit
dd99468e7b
@ -0,0 +1,6 @@
|
||||
<yandex>
|
||||
<part_log>
|
||||
<database>database_name</database>
|
||||
<table>table_name</table>
|
||||
</part_log>
|
||||
</yandex>
|
@ -0,0 +1,4 @@
|
||||
<yandex>
|
||||
<part_log>
|
||||
</part_log>
|
||||
</yandex>
|
42
dbms/tests/integration/test_part_log_table/test.py
Normal file
42
dbms/tests/integration/test_part_log_table/test.py
Normal file
@ -0,0 +1,42 @@
|
||||
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)")
|
||||
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 "Table system.part_log doesn't exist" in node2.query_and_get_error("SELECT * FROM system.part_log")
|
||||
node2.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() Order by value")
|
||||
assert "Table system.part_log doesn't exist" in node2.query_and_get_error("SELECT * FROM system.part_log")
|
||||
node2.query("INSERT INTO test_table VALUES ('name', 1)")
|
||||
time.sleep(10)
|
||||
assert node2.query("SELECT * FROM system.part_log") != ""
|
||||
|
||||
def test_config_with_non_standard_part_log(start_cluster):
|
||||
node3.query("CREATE DATABASE database_name")
|
||||
assert "table_name" not in node3.query("SHOW TABLES FROM database_name")
|
||||
node3.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() ORDER BY value")
|
||||
assert "table_name" not in node3.query("SHOW TABLES FROM database_name")
|
||||
node3.query("INSERT INTO test_table VALUES ('name', 1)")
|
||||
time.sleep(10)
|
||||
assert "table_name" in node3.query("SHOW TABLES FROM database_name")
|
||||
|
Loading…
Reference in New Issue
Block a user