mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-12 09:22:05 +00:00
133 lines
4.5 KiB
Python
133 lines
4.5 KiB
Python
import time
|
|
import pytest
|
|
|
|
from helpers.cluster import ClickHouseCluster
|
|
|
|
|
|
def _fill_nodes(nodes, shard):
|
|
for node in nodes:
|
|
node.query(
|
|
'''
|
|
CREATE DATABASE test;
|
|
|
|
CREATE TABLE test_table(date Date, id UInt32, dummy UInt32)
|
|
ENGINE = ReplicatedMergeTree('/clickhouse/tables/test{shard}/replicated', '{replica}', date, id, 8192);
|
|
'''.format(shard=shard, replica=node.name))
|
|
|
|
cluster = ClickHouseCluster(__file__)
|
|
node1 = cluster.add_instance('node1', main_configs=['configs/remote_servers.xml', 'configs/credentials1.xml'], with_zookeeper=True)
|
|
node2 = cluster.add_instance('node2', main_configs=['configs/remote_servers.xml', 'configs/credentials1.xml'], with_zookeeper=True)
|
|
|
|
|
|
@pytest.fixture(scope="module")
|
|
def same_credentials_cluster():
|
|
try:
|
|
cluster.start()
|
|
|
|
_fill_nodes([node1, node2], 1)
|
|
|
|
yield cluster
|
|
|
|
finally:
|
|
cluster.shutdown()
|
|
|
|
def test_same_credentials(same_credentials_cluster):
|
|
node1.query("insert into test_table values ('2017-06-16', 111, 0)")
|
|
time.sleep(1)
|
|
|
|
assert node1.query("SELECT id FROM test_table order by id") == '111\n'
|
|
assert node2.query("SELECT id FROM test_table order by id") == '111\n'
|
|
|
|
node2.query("insert into test_table values ('2017-06-17', 222, 1)")
|
|
time.sleep(1)
|
|
|
|
assert node1.query("SELECT id FROM test_table order by id") == '111\n222\n'
|
|
assert node2.query("SELECT id FROM test_table order by id") == '111\n222\n'
|
|
|
|
|
|
node3 = cluster.add_instance('node3', main_configs=['configs/remote_servers.xml', 'configs/no_credentials.xml'], with_zookeeper=True)
|
|
node4 = cluster.add_instance('node4', main_configs=['configs/remote_servers.xml', 'configs/no_credentials.xml'], with_zookeeper=True)
|
|
|
|
@pytest.fixture(scope="module")
|
|
def no_credentials_cluster():
|
|
try:
|
|
cluster.start()
|
|
|
|
_fill_nodes([node3, node4], 2)
|
|
|
|
yield cluster
|
|
|
|
finally:
|
|
cluster.shutdown()
|
|
|
|
|
|
def test_no_credentials(no_credentials_cluster):
|
|
node3.query("insert into test_table values ('2017-06-18', 111, 0)")
|
|
time.sleep(1)
|
|
|
|
assert node3.query("SELECT id FROM test_table order by id") == '111\n'
|
|
assert node4.query("SELECT id FROM test_table order by id") == '111\n'
|
|
|
|
node4.query("insert into test_table values ('2017-06-19', 222, 1)")
|
|
time.sleep(1)
|
|
|
|
assert node3.query("SELECT id FROM test_table order by id") == '111\n222\n'
|
|
assert node4.query("SELECT id FROM test_table order by id") == '111\n222\n'
|
|
|
|
node5 = cluster.add_instance('node5', main_configs=['configs/remote_servers.xml', 'configs/credentials1.xml'], with_zookeeper=True)
|
|
node6 = cluster.add_instance('node6', main_configs=['configs/remote_servers.xml', 'configs/credentials2.xml'], with_zookeeper=True)
|
|
|
|
@pytest.fixture(scope="module")
|
|
def different_credentials_cluster():
|
|
try:
|
|
cluster.start()
|
|
|
|
_fill_nodes([node5, node6], 3)
|
|
|
|
yield cluster
|
|
|
|
finally:
|
|
cluster.shutdown()
|
|
|
|
def test_different_credentials(different_credentials_cluster):
|
|
node5.query("insert into test_table values ('2017-06-20', 111, 0)")
|
|
time.sleep(1)
|
|
|
|
assert node5.query("SELECT id FROM test_table order by id") == '111\n'
|
|
assert node6.query("SELECT id FROM test_table order by id") == ''
|
|
|
|
node6.query("insert into test_table values ('2017-06-21', 222, 1)")
|
|
time.sleep(1)
|
|
|
|
assert node5.query("SELECT id FROM test_table order by id") == '111\n'
|
|
assert node6.query("SELECT id FROM test_table order by id") == '222\n'
|
|
|
|
node7 = cluster.add_instance('node7', main_configs=['configs/remote_servers.xml', 'configs/credentials1.xml'], with_zookeeper=True)
|
|
node8 = cluster.add_instance('node8', main_configs=['configs/remote_servers.xml', 'configs/no_credentials.xml'], with_zookeeper=True)
|
|
|
|
@pytest.fixture(scope="module")
|
|
def credentials_and_no_credentials_cluster():
|
|
try:
|
|
cluster.start()
|
|
|
|
_fill_nodes([node7, node8], 4)
|
|
|
|
yield cluster
|
|
|
|
finally:
|
|
cluster.shutdown()
|
|
|
|
def test_credentials_and_no_credentials(credentials_and_no_credentials_cluster):
|
|
node7.query("insert into test_table values ('2017-06-21', 111, 0)")
|
|
time.sleep(1)
|
|
|
|
assert node7.query("SELECT id FROM test_table order by id") == '111\n'
|
|
assert node8.query("SELECT id FROM test_table order by id") == ''
|
|
|
|
node8.query("insert into test_table values ('2017-06-22', 222, 1)")
|
|
time.sleep(1)
|
|
|
|
assert node7.query("SELECT id FROM test_table order by id") == '111\n'
|
|
assert node8.query("SELECT id FROM test_table order by id") == '222\n'
|
|
|