add i test

pingcap · Apr 27, 2022 · 67c744c · 67c744c
1 parent b15ab92
commit 67c744c
Show file tree

Hide file tree

Showing 4 changed files with 23 additions and 2 deletions.
diff --git a/dm/tests/tracker_ignored_ddl/conf/dm-task.yaml b/dm/tests/tracker_ignored_ddl/conf/dm-task.yaml
@@ -46,3 +46,4 @@ syncers:
     worker-count: 16
     batch: 100
     enable-ansi-quotes: false  # compatible with deprecated config
+    checkpoint-flush-interval: 1
diff --git a/...sts/tracker_ignored_ddl/conf/source1.yaml → ...racker_ignored_ddl/conf/source1_gtid.yaml b/...sts/tracker_ignored_ddl/conf/source1.yaml → ...racker_ignored_ddl/conf/source1_gtid.yaml
diff --git a/dm/tests/tracker_ignored_ddl/conf/source1_pos.yaml b/dm/tests/tracker_ignored_ddl/conf/source1_pos.yaml
@@ -0,0 +1,11 @@
+source-id: mysql-replica-01
+flavor: ''
+enable-gtid: false
+enable-relay: true
+relay-binlog-name: ''
+relay-binlog-gtid: ''
+from:
+  host: 127.0.0.1
+  user: root
+  password: /Q7B9DizNLLTTfiZHv9WoEAKamfpIUs=
+  port: 3306
diff --git a/dm/tests/tracker_ignored_ddl/run.sh b/dm/tests/tracker_ignored_ddl/run.sh
@@ -7,14 +7,15 @@ source $cur/../_utils/test_prepare
 WORK_DIR=$TEST_DIR/$TEST_NAME
 
 function run() {
+	source_cfg=$1
 	run_sql_file $cur/data/db.prepare.sql $MYSQL_HOST1 $MYSQL_PORT1 $MYSQL_PASSWORD1
 
 	run_dm_master $WORK_DIR/master $MASTER_PORT $cur/conf/dm-master.toml
 	check_rpc_alive $cur/../bin/check_master_online 127.0.0.1:$MASTER_PORT
 	run_dm_worker $WORK_DIR/worker1 $WORKER1_PORT $cur/conf/dm-worker.toml
 	check_rpc_alive $cur/../bin/check_worker_online 127.0.0.1:$WORKER1_PORT
 	# operate mysql config to worker
-	cp $cur/conf/source1.yaml $WORK_DIR/source1.yaml
+	cp $cur/conf/$source_cfg $WORK_DIR/source1.yaml
 	dmctl_operate_source create $WORK_DIR/source1.yaml $SOURCE_ID1
 
 	# start DM task only
@@ -30,6 +31,8 @@ function run() {
 	# a not ignored DDL to trigger a checkpoint flush
 	run_sql_source1 "create table tracker_ignored_ddl.test (c int primary key);"
 
+	# sleep 2 second, so the next insert will trigger check point flush since checkpoint-flush-interval=1
+	sleep 2
 	run_sql_file $cur/data/db.increment2.sql $MYSQL_HOST1 $MYSQL_PORT1 $MYSQL_PASSWORD1
 	run_dm_ctl_with_retry $WORK_DIR "127.0.0.1:$MASTER_PORT" \
 		"query-status test" \
@@ -62,12 +65,18 @@ function run() {
 	run_dm_ctl_with_retry $WORK_DIR "127.0.0.1:$MASTER_PORT" \
 		"query-status test" \
 		"\"stage\": \"Running\"" 1
+
+	run_dm_ctl $WORK_DIR "127.0.0.1:$MASTER_PORT" \
+		"stop-task test" \
+		"\"result\": true" 2
+	dmctl_operate_source stop $WORK_DIR/source1.yaml $SOURCE_ID1
 }
 
 cleanup_data $TEST_NAME
 # also cleanup dm processes in case of last run failed
 cleanup_process
-run
+run source1_gtid.yaml
+run source1_pos.yaml
 cleanup_process
 
 echo "[$(date)] <<<<<< test case $TEST_NAME success! >>>>>>"