1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
###############################################################################
# Use this .inc to create the channels on MSR slave.
# This .inc assumes that the MSR setup is already done
# as 1->$rpl_number_of_servers, 2->$rpl_number_of_servers,...,
# $rpl_number_of_servers -1 -> $rpl_number_of_servers.
# It also assumes that server_$rpl_number_of_servers
# is the server where we have to create the channels.
# The number of channels are equal to $rpl_number_of_servers -1.
# They are default channel, channel_2, channel_3,...,channel_n.
# First master (server1) will be replicated using
# the default channel(empty channel name). Starting from the
# second master, the rest of the masters will be replicated using
# channel_<SERVER NUMBER> channel.
#
# Usage:
# --let $rpl_number_of_servers=4
# [--let $no_sample_data= 0 | 1]
# --source extra/rpl_tests/rpl_create_msr_channels.inc
#
# $rpl_number_of_servers
# Specify total number of servers in the MSR setup.
#
# $no_sample_data
# This .inc by default creates some sample data and sync
# it between master and slave after creating the channel between
# them. Set this variable to 1 if it is not required.
#
###############################################################################
if (!$rpl_number_of_servers)
{
--die "Please specify the total number of servers in the MSR setup."
}
--let $number_of_channels= `SELECT $rpl_number_of_servers -1`
--let $rpl_msr_server_number=$rpl_number_of_servers
--let $i=1
while ($i <= $number_of_channels)
{
--let $rpl_connection_name= server_$i
--source include/rpl_connection.inc
RESET MASTER;
--let $master_port=`SELECT @@PORT`
--let $rpl_connection_name=server_$rpl_msr_server_number
--source include/rpl_connection.inc
--let $rpl_channel_name='channel_$i'
# First channel name should be default channel with empty name.
if ($i == 1)
{
--let $rpl_channel_name=''
}
--replace_result $master_port port
--eval CHANGE REPLICATION SOURCE TO SOURCE_USER='root', SOURCE_PORT= $master_port, SOURCE_HOST='localhost' FOR CHANNEL $rpl_channel_name
--source include/start_slave.inc
if (!$no_sample_data)
{
--let $rpl_connection_name= server_$i
--source include/rpl_connection.inc
--eval CREATE DATABASE db$i
--eval CREATE TABLE db$i.t$i(i int)
--eval DROP TABLE db$i.t$i
--eval DROP DATABASE db$i
--let $sync_slave_connection=server_$rpl_msr_server_number
--source include/sync_slave_sql_with_master.inc
}
--inc $i
}
|
