Skip to content

Commit

Permalink
fix(multi_down_addresses): fix the nameing error of the tables
Browse files Browse the repository at this point in the history
  • Loading branch information
@wlwilliamx
wlwilliamx committed Aug 28, 2024
1 parent aec17b3 commit 9708137
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 15 deletions.
4 changes: 2 additions & 2 deletions tests/integration_tests/multi_down_addresses/data/prepare.sql
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,5 +2,5 @@ DROP DATABASE IF EXISTS multi_down_addresses;
CREATE DATABASE multi_down_addresses;
USE multi_down_addresses;

CREATE TABLE create (round INT PRIMARY KEY, val INT);
CREATE TABLE update (round INT PRIMARY KEY, val INT);
CREATE TABLE changefeed_create (round INT PRIMARY KEY, val INT);
CREATE TABLE changefeed_update (round INT PRIMARY KEY, val INT);
26 changes: 13 additions & 13 deletions tests/integration_tests/multi_down_addresses/run.sh
View file
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ function prepare_create() {

# Prepare tables for test `cdc cli changefeed create` and `cdc cli changefeed update`
run_sql_file $CUR/data/prepare.sql ${UP_TIDB_HOST} ${UP_TIDB_PORT}
check_table_exists multi_down_addresses.create ${DOWN_TIDB_HOST} ${DOWN_TIDB_PORT_1} 60
check_table_exists multi_down_addresses.changefeed_create ${DOWN_TIDB_HOST} ${DOWN_TIDB_PORT_1} 60
}

function run_create() {
Expand All @@ -43,7 +43,7 @@ function run_create() {
# tidb 2 should works
kill $pid1
run_sql "BEGIN;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.create VALUES(1, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_create VALUES(1, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "COMMIT;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
check_sync_diff $WORK_DIR $CUR/conf/diff_config_2.toml

Expand All @@ -53,15 +53,15 @@ function run_create() {
run_sql "BEGIN;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
sleep 5
kill $pid2
run_sql "INSERT INTO multi_down_addresses.create VALUES(2, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_create VALUES(2, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "COMMIT;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
check_sync_diff $WORK_DIR $CUR/conf/diff_config_3.toml

# Round 3
# begin -> insert -> recover tidb 1 -> shutdown tidb 3 -> commit -> check_sync_diff
# tidb 1 should works
run_sql "BEGIN;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.create VALUES(3, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_create VALUES(3, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
sleep 5
start_downstream_tidb_instances --db 1 --out_dir $WORK_DIR --suffix 1
mapfile -t down_tidb_pids <"$WORK_DIR/downstream_tidb_instances_pids.log"
Expand All @@ -74,27 +74,27 @@ function run_create() {
# begin -> insert -> recover tidb 2 -> shutdown tidb 1 -> insert -> commit -> check_sync_diff
# tidb 2 should works
run_sql "BEGIN;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.create VALUES(4, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_create VALUES(4, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
sleep 5
start_downstream_tidb_instances --db 1 --out_dir $WORK_DIR --suffix 2
mapfile -t down_tidb_pids <"$WORK_DIR/downstream_tidb_instances_pids.log"
pid2=${down_tidb_pids[0]}
kill $pid1
run_sql "INSERT INTO multi_down_addresses.create VALUES(41, 2);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_create VALUES(41, 2);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "COMMIT;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
check_sync_diff $WORK_DIR $CUR/conf/diff_config_2.toml

# Round 5
# begin -> insert -> commit -> recover tidb 3 -> shutdown tidb 2 -> begin -> insert -> commit -> check_sync_diff
# tidb 3 should works
run_sql "BEGIN;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.create VALUES(5, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_create VALUES(5, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "COMMIT;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
sleep 5
start_downstream_tidb_instances --db 1 --out_dir $WORK_DIR --suffix 3
pid3=${down_tidb_pids[0]}
kill $pid2
run_sql "INSERT INTO multi_down_addresses.create VALUES(51, 2);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_create VALUES(51, 2);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "COMMIT;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
check_sync_diff $WORK_DIR $CUR/conf/diff_config_3.toml

Expand All @@ -114,7 +114,7 @@ function prepare_update() {
run_cdc_cli changefeed resume -c "multi-down-addresses"
sleep 5

check_table_exists multi_down_addresses.update ${DOWN_TIDB_HOST} ${DOWN_TIDB_PORT_1} 60
check_table_exists multi_down_addresses.changefeed_update ${DOWN_TIDB_HOST} ${DOWN_TIDB_PORT_1} 60
}

function run_update() {
Expand All @@ -126,15 +126,15 @@ function run_update() {
# tidb 2 should works
kill $pid1
run_sql "BEGIN;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.update VALUES(1, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_update VALUES(1, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "COMMIT;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
check_sync_diff $WORK_DIR $CUR/conf/diff_config_2.toml

# Round 2
# begin -> insert -> recover tidb 1 -> shutdown tidb 2 -> commit -> check_sync_diff
# tidb 1 should works
run_sql "BEGIN;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.update VALUES(2, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_update VALUES(2, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
sleep 5
start_downstream_tidb_instances --db 1 --out_dir $WORK_DIR --suffix 1
mapfile -t down_tidb_pids <"$WORK_DIR/downstream_tidb_instances_pids.log"
Expand All @@ -147,13 +147,13 @@ function run_update() {
# begin -> insert -> recover tidb 2 -> shutdown tidb 1 -> insert -> commit -> check_sync_diff
# tidb 2 should works
run_sql "BEGIN;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.update VALUES(3, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_update VALUES(3, 1);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
sleep 5
start_downstream_tidb_instances --db 1 --out_dir $WORK_DIR --suffix 2
mapfile -t down_tidb_pids <"$WORK_DIR/downstream_tidb_instances_pids.log"
pid2=${down_tidb_pids[0]}
kill $pid1
run_sql "INSERT INTO multi_down_addresses.create VALUES(31, 2);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "INSERT INTO multi_down_addresses.changefeed_create VALUES(31, 2);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql "COMMIT;" ${UP_TIDB_HOST} ${UP_TIDB_PORT}
check_sync_diff $WORK_DIR $CUR/conf/diff_config_2.toml
}
Expand Down

0 comments on commit 9708137

Please sign in to comment.