57 lines
1.8 KiB
Plaintext
57 lines
1.8 KiB
Plaintext
#
|
|
# bug 10948203 and bug 10947778
|
|
#
|
|
|
|
let $learner_base_port = query_get_value("select $MYPORT_1+50 as c1", c1, 1);
|
|
--source include/start_new_learner.inc
|
|
|
|
--connect (leader,127.0.0.1,root,,test,$MYPORT_1)
|
|
--connection leader
|
|
#add consensus_learner '$learner_cluster_info';
|
|
--replace_result $learner_cluster_info learner_cluster_info
|
|
eval call dbms_consensus.add_learner($learner_cluster_info);
|
|
select count(*) from information_schema.alisql_cluster_global where role='LEARNER';
|
|
create database aaa;
|
|
use aaa;
|
|
create table t (id int);
|
|
insert into t values(1);
|
|
|
|
let $wait_condition= select count(distinct match_index)=1 from information_schema.alisql_cluster_global;
|
|
--source include/wait_condition.inc
|
|
--sleep 1
|
|
|
|
--connect (learner,127.0.0.1,root,,mysql,$learner_port)
|
|
--connection learner
|
|
let $wait_condition= select LAST_LOG_INDEX=LAST_APPLY_INDEX from information_schema.alisql_cluster_local;
|
|
--source include/wait_condition.inc
|
|
show databases like '%aaa%';
|
|
|
|
--echo # kill learner
|
|
--shutdown_server 0
|
|
--disconnect learner
|
|
|
|
--connection leader
|
|
drop database aaa;
|
|
|
|
--echo # restart learner
|
|
--exec $MYSQLD $extra_args --datadir=$DDIR $init_args --port=$learner_port >> $MYSQLD_LOG 2>&1 &
|
|
|
|
# wait learner get log
|
|
--connection leader
|
|
let $wait_condition= select count(distinct match_index)=1 from information_schema.alisql_cluster_global;
|
|
--source include/wait_condition.inc
|
|
# wait the learner accept connection
|
|
--sleep 5
|
|
--connect (learner,127.0.0.1,root,,mysql,$learner_port)
|
|
--connection learner
|
|
let $wait_condition= select LAST_LOG_INDEX=LAST_APPLY_INDEX from information_schema.alisql_cluster_local;
|
|
--source include/wait_condition.inc
|
|
show databases like '%aaa%';
|
|
--connection leader
|
|
#drop consensus_learner '127.0.0.1:24400';
|
|
call dbms_consensus.drop_learner("127.0.0.1:24400");
|
|
|
|
# cleanup
|
|
--source include/stop_new_learner.inc
|
|
|