mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 16:50:48 +00:00
update test_materialize_mysql_database test
This commit is contained in:
parent
c90c06ceaf
commit
73e9f4d421
@ -7,3 +7,4 @@ services:
|
|||||||
MYSQL_ROOT_PASSWORD: clickhouse
|
MYSQL_ROOT_PASSWORD: clickhouse
|
||||||
ports:
|
ports:
|
||||||
- 3308:3306
|
- 3308:3306
|
||||||
|
command: --server_id=100 --log-bin='mysql-bin-1.log' --default-time-zone='+3:00'
|
||||||
|
@ -1,10 +0,0 @@
|
|||||||
version: '2.3'
|
|
||||||
services:
|
|
||||||
mysql5_7:
|
|
||||||
image: mysql:5.7
|
|
||||||
restart: always
|
|
||||||
environment:
|
|
||||||
MYSQL_ROOT_PASSWORD: clickhouse
|
|
||||||
ports:
|
|
||||||
- 33307:3306
|
|
||||||
command: --server_id=100 --log-bin='mysql-bin-1.log' --default-time-zone='+3:00'
|
|
@ -177,7 +177,7 @@ def alter_add_column_with_materialize_mysql_database(clickhouse_node, mysql_node
|
|||||||
mysql_node.query("ALTER TABLE test_database.test_table_1 ADD COLUMN add_column_1 INT NOT NULL")
|
mysql_node.query("ALTER TABLE test_database.test_table_1 ADD COLUMN add_column_1 INT NOT NULL")
|
||||||
mysql_node.query("ALTER TABLE test_database.test_table_1 ADD COLUMN add_column_2 INT NOT NULL FIRST")
|
mysql_node.query("ALTER TABLE test_database.test_table_1 ADD COLUMN add_column_2 INT NOT NULL FIRST")
|
||||||
mysql_node.query("ALTER TABLE test_database.test_table_1 ADD COLUMN add_column_3 INT NOT NULL AFTER add_column_1")
|
mysql_node.query("ALTER TABLE test_database.test_table_1 ADD COLUMN add_column_3 INT NOT NULL AFTER add_column_1")
|
||||||
mysql_node.query("ALTER TABLE test_database.test_table_1 ADD COLUMN add_column_4 INT NOT NULL DEFAULT " + ("0" if service_name == "mysql5_7" else "(id)"))
|
mysql_node.query("ALTER TABLE test_database.test_table_1 ADD COLUMN add_column_4 INT NOT NULL DEFAULT " + ("0" if service_name == "mysql1" else "(id)"))
|
||||||
|
|
||||||
# create mapping
|
# create mapping
|
||||||
clickhouse_node.query(
|
clickhouse_node.query(
|
||||||
@ -193,9 +193,9 @@ def alter_add_column_with_materialize_mysql_database(clickhouse_node, mysql_node
|
|||||||
mysql_node.query("ALTER TABLE test_database.test_table_2 ADD COLUMN add_column_1 INT NOT NULL, ADD COLUMN add_column_2 INT NOT NULL FIRST")
|
mysql_node.query("ALTER TABLE test_database.test_table_2 ADD COLUMN add_column_1 INT NOT NULL, ADD COLUMN add_column_2 INT NOT NULL FIRST")
|
||||||
mysql_node.query(
|
mysql_node.query(
|
||||||
"ALTER TABLE test_database.test_table_2 ADD COLUMN add_column_3 INT NOT NULL AFTER add_column_1, ADD COLUMN add_column_4 INT NOT NULL DEFAULT " + (
|
"ALTER TABLE test_database.test_table_2 ADD COLUMN add_column_3 INT NOT NULL AFTER add_column_1, ADD COLUMN add_column_4 INT NOT NULL DEFAULT " + (
|
||||||
"0" if service_name == "mysql5_7" else "(id)"))
|
"0" if service_name == "mysql1" else "(id)"))
|
||||||
|
|
||||||
default_expression = "DEFAULT\t0" if service_name == "mysql5_7" else "DEFAULT\tid"
|
default_expression = "DEFAULT\t0" if service_name == "mysql1" else "DEFAULT\tid"
|
||||||
check_query(clickhouse_node, "DESC test_database.test_table_2 FORMAT TSV",
|
check_query(clickhouse_node, "DESC test_database.test_table_2 FORMAT TSV",
|
||||||
"add_column_2\tInt32\t\t\t\t\t\nid\tInt32\t\t\t\t\t\nadd_column_1\tInt32\t\t\t\t\t\nadd_column_3\tInt32\t\t\t\t\t\nadd_column_4\tInt32\t" + default_expression + "\t\t\t\n_sign\tInt8\tMATERIALIZED\t1\t\t\t\n_version\tUInt64\tMATERIALIZED\t1\t\t\t\n")
|
"add_column_2\tInt32\t\t\t\t\t\nid\tInt32\t\t\t\t\t\nadd_column_1\tInt32\t\t\t\t\t\nadd_column_3\tInt32\t\t\t\t\t\nadd_column_4\tInt32\t" + default_expression + "\t\t\t\n_sign\tInt8\tMATERIALIZED\t1\t\t\t\n_version\tUInt64\tMATERIALIZED\t1\t\t\t\n")
|
||||||
|
|
||||||
|
@ -6,12 +6,12 @@ import pymysql.cursors
|
|||||||
import pytest
|
import pytest
|
||||||
|
|
||||||
import materialize_with_ddl
|
import materialize_with_ddl
|
||||||
from helpers.cluster import ClickHouseCluster
|
from helpers.cluster import ClickHouseCluster, get_docker_compose_path
|
||||||
|
|
||||||
SCRIPT_DIR = os.path.dirname(os.path.realpath(__file__))
|
DOCKER_COMPOSE_PATH = get_docker_compose_path()
|
||||||
|
|
||||||
cluster = ClickHouseCluster(__file__)
|
cluster = ClickHouseCluster(__file__)
|
||||||
clickhouse_node = cluster.add_instance('node1', config_dir="configs", with_mysql=False)
|
clickhouse_node = cluster.add_instance('node1', user_configs=["configs/users.xml"], with_mysql=False)
|
||||||
|
|
||||||
|
|
||||||
@pytest.fixture(scope="module")
|
@pytest.fixture(scope="module")
|
||||||
@ -61,8 +61,8 @@ class MySQLNodeInstance:
|
|||||||
|
|
||||||
@pytest.fixture(scope="module")
|
@pytest.fixture(scope="module")
|
||||||
def started_mysql_5_7():
|
def started_mysql_5_7():
|
||||||
mysql_node = MySQLNodeInstance('root', 'clickhouse', '127.0.0.1', 33307)
|
mysql_node = MySQLNodeInstance('root', 'clickhouse', '127.0.0.1', 3308)
|
||||||
docker_compose = os.path.join(SCRIPT_DIR, 'composes', 'mysql_5_7_compose.yml')
|
docker_compose = os.path.join(DOCKER_COMPOSE_PATH, 'docker_compose_mysql.yml')
|
||||||
|
|
||||||
try:
|
try:
|
||||||
subprocess.check_call(['docker-compose', '-p', cluster.project_name, '-f', docker_compose, 'up', '--no-recreate', '-d'])
|
subprocess.check_call(['docker-compose', '-p', cluster.project_name, '-f', docker_compose, 'up', '--no-recreate', '-d'])
|
||||||
@ -76,7 +76,7 @@ def started_mysql_5_7():
|
|||||||
@pytest.fixture(scope="module")
|
@pytest.fixture(scope="module")
|
||||||
def started_mysql_8_0():
|
def started_mysql_8_0():
|
||||||
mysql_node = MySQLNodeInstance('root', 'clickhouse', '127.0.0.1', 33308)
|
mysql_node = MySQLNodeInstance('root', 'clickhouse', '127.0.0.1', 33308)
|
||||||
docker_compose = os.path.join(SCRIPT_DIR, 'composes', 'mysql_8_0_compose.yml')
|
docker_compose = os.path.join(DOCKER_COMPOSE_PATH, 'docker_compose_mysql_8_0.yml')
|
||||||
|
|
||||||
try:
|
try:
|
||||||
subprocess.check_call(['docker-compose', '-p', cluster.project_name, '-f', docker_compose, 'up', '--no-recreate', '-d'])
|
subprocess.check_call(['docker-compose', '-p', cluster.project_name, '-f', docker_compose, 'up', '--no-recreate', '-d'])
|
||||||
@ -88,7 +88,7 @@ def started_mysql_8_0():
|
|||||||
|
|
||||||
|
|
||||||
def test_materialize_database_dml_with_mysql_5_7(started_cluster, started_mysql_5_7):
|
def test_materialize_database_dml_with_mysql_5_7(started_cluster, started_mysql_5_7):
|
||||||
materialize_with_ddl.dml_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql5_7")
|
materialize_with_ddl.dml_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql1")
|
||||||
|
|
||||||
|
|
||||||
def test_materialize_database_dml_with_mysql_8_0(started_cluster, started_mysql_8_0):
|
def test_materialize_database_dml_with_mysql_8_0(started_cluster, started_mysql_8_0):
|
||||||
@ -96,15 +96,15 @@ def test_materialize_database_dml_with_mysql_8_0(started_cluster, started_mysql_
|
|||||||
|
|
||||||
|
|
||||||
def test_materialize_database_ddl_with_mysql_5_7(started_cluster, started_mysql_5_7):
|
def test_materialize_database_ddl_with_mysql_5_7(started_cluster, started_mysql_5_7):
|
||||||
materialize_with_ddl.drop_table_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql5_7")
|
materialize_with_ddl.drop_table_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql1")
|
||||||
materialize_with_ddl.create_table_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql5_7")
|
materialize_with_ddl.create_table_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql1")
|
||||||
materialize_with_ddl.rename_table_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql5_7")
|
materialize_with_ddl.rename_table_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql1")
|
||||||
materialize_with_ddl.alter_add_column_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql5_7")
|
materialize_with_ddl.alter_add_column_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql1")
|
||||||
materialize_with_ddl.alter_drop_column_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql5_7")
|
materialize_with_ddl.alter_drop_column_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql1")
|
||||||
# mysql 5.7 cannot support alter rename column
|
# mysql 5.7 cannot support alter rename column
|
||||||
# materialize_with_ddl.alter_rename_column_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql5_7")
|
# materialize_with_ddl.alter_rename_column_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql1")
|
||||||
materialize_with_ddl.alter_rename_table_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql5_7")
|
materialize_with_ddl.alter_rename_table_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql1")
|
||||||
materialize_with_ddl.alter_modify_column_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql5_7")
|
materialize_with_ddl.alter_modify_column_with_materialize_mysql_database(clickhouse_node, started_mysql_5_7, "mysql1")
|
||||||
|
|
||||||
|
|
||||||
def test_materialize_database_ddl_with_mysql_8_0(started_cluster, started_mysql_8_0):
|
def test_materialize_database_ddl_with_mysql_8_0(started_cluster, started_mysql_8_0):
|
||||||
|
Loading…
Reference in New Issue
Block a user