#
# 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