51 lines
1.3 KiB
Plaintext
51 lines
1.3 KiB
Plaintext
#
|
|
# add a new learner and trigger force-single-mode to that learner
|
|
#
|
|
|
|
--disable_warnings
|
|
|
|
let $learner_base_port = query_get_value("select $MYPORT_1+50 as c1", c1, 1);
|
|
--source include/start_new_learner.inc
|
|
|
|
--connection default
|
|
#eval add consensus_learner $learner_cluster_info;
|
|
--replace_result $learner_cluster_info learner_cluster_info
|
|
eval call dbms_consensus.add_learner($learner_cluster_info);
|
|
create table t (id int);
|
|
insert into t values (1);
|
|
--source include/wait_apply_catchup.inc
|
|
|
|
--connect (learner,127.0.0.1,root,,test,$learner_port)
|
|
--connection learner
|
|
stop xpaxos_replication;
|
|
|
|
--connection default
|
|
insert into t values (2);
|
|
--sleep 1
|
|
|
|
--connection learner
|
|
#change consensus_node to consensus_force_single_mode;
|
|
call dbms_consensus.force_single_mode();
|
|
--sleep 1
|
|
select SERVER_ID, ROLE from information_schema.alisql_cluster_global;
|
|
select SERVER_ID, ROLE, SERVER_READY_FOR_RW from information_schema.alisql_cluster_local;
|
|
|
|
start xpaxos_replication;
|
|
--sleep 3
|
|
insert into t values (3);
|
|
--source include/wait_apply_catchup.inc
|
|
|
|
select * from t;
|
|
drop table t;
|
|
|
|
--connection default
|
|
#eval drop consensus_learner $learner_cluster_info;
|
|
--replace_result $learner_cluster_info learner_cluster_info
|
|
eval call dbms_consensus.drop_learner($learner_cluster_info);
|
|
drop table t;
|
|
|
|
--source include/stop_new_learner.inc
|
|
|
|
|
|
--enable_warnings
|