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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
|
include/master-slave.inc
Warnings:
Note #### Sending passwords in plain text without SSL/TLS is extremely insecure.
Note #### Storing MySQL user name or password information in the connection metadata repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START REPLICA; see the 'START REPLICA Syntax' in the MySQL Manual for more information.
[connection master]
#
# 1. Check that the parameter count is greater than 3 and less then 5,
# i.e. channel_name, hostname and port must be provided.
#
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1');
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_add_source'; Wrong arguments: You need to specify all mandatory arguments.
include/assert.inc ['The performance_schema.replication_asynchronous_connection_failover table is empty']
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', 3100, 'net', 30, 11);
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_add_source'; Wrong arguments: You must specify max 5 arguments.
include/assert.inc ['The performance_schema.replication_asynchronous_connection_failover table is empty']
#
# 2. Check that the channel name is provided.
#
SELECT asynchronous_connection_failover_add_source(9, '127.0.0.1', 3100);
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_add_source'; Wrong arguments: You need to specify channel name.
include/assert.inc ['The performance_schema.replication_asynchronous_connection_failover table is empty']
#
# 3. Check host parameters values is provided and not empty.
#
SELECT asynchronous_connection_failover_add_source('', '', 3100);
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_add_source'; Wrong arguments: You need to specify hostname.
include/assert.inc ['The performance_schema.replication_asynchronous_connection_failover table is empty']
#
# 4. Check port parameters values is provided.
#
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', '3100');
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_add_source'; Wrong arguments: You need to specify value for port.
include/assert.inc ['The performance_schema.replication_asynchronous_connection_failover table is empty']
#
# 5. Check the weight parameter value is integer value between 1-100.
#
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', 3100, '', 0);
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_add_source'; Wrong arguments: The weight argument value should be integer value between 1-100.
include/assert.inc ['The performance_schema.replication_asynchronous_connection_failover table is empty']
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', 3100, '', 200);
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_add_source'; Wrong arguments: The weight argument value should be integer value between 1-100.
include/assert.inc ['The performance_schema.replication_asynchronous_connection_failover table is empty']
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', 3100, '', '100');
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_add_source'; Wrong arguments: The weight argument value should be integer value between 1-100.
include/assert.inc ['The performance_schema.replication_asynchronous_connection_failover table is empty']
#
# 6. Check the default value of weight parameter is 50.
#
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', 3100);
asynchronous_connection_failover_add_source('', '127.0.0.1', 3100)
The UDF asynchronous_connection_failover_add_source() executed successfully.
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
SELECT asynchronous_connection_failover_delete_source('', '127.0.0.1', 3100);
asynchronous_connection_failover_delete_source('', '127.0.0.1', 3100)
The UDF asynchronous_connection_failover_delete_source() executed successfully.
#
# 7. Check asynchronous_connection_failover_add_source returns warning
# on network_namespace value. Also if network_namespace is set through
# CHANGE REPLICATION SOURCE TO command that network_namespace is
# returned on querying
# performance_schema.replication_asynchronous_connection_failover
# table for the channel.
#
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', 3100, 100);
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_add_source'; Wrong arguments: You need to specify a string value for network_namespace.
include/assert.inc ['There is no row in performance_schema.replication_asynchronous_connection_failover']
include/assert.inc ['There is no row in performance_schema.replication_asynchronous_connection_failover']
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', 3100, 'blue');
asynchronous_connection_failover_add_source('', '127.0.0.1', 3100, 'blue')
The UDF asynchronous_connection_failover_add_source() executed successfully.
Warnings:
Warning 4030 The parameter network_namespace is reserved for future use. Please use the CHANGE REPLICATION SOURCE command to set channel network_namespace parameter.
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
CHANGE REPLICATION SOURCE TO SOURCE_HOST="127.0.0.1", SOURCE_USER="root", SOURCE_PASSWORD="", SOURCE_PORT=SERVER_1_PORT, NETWORK_NAMESPACE='red' FOR CHANNEL "";
Warnings:
Note 1759 Sending passwords in plain text without SSL/TLS is extremely insecure.
Note 1760 Storing MySQL user name or password information in the connection metadata repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START REPLICA; see the 'START REPLICA Syntax' in the MySQL Manual for more information.
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover with NETWORK_NAMESPACE="red"']
#
# 8. Check that the parameter count is greater than 3 and less then 4,
# i.e. channel_name, hostname and port must be provided.
#
SELECT asynchronous_connection_failover_delete_source('', '127.0.0.1');
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_delete_source'; Wrong arguments: You need to specify all mandatory arguments.
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
SELECT asynchronous_connection_failover_delete_source('', '127.0.0.1', 3100, 'net', 30);
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_delete_source'; Wrong arguments: You must specify max 4 arguments.
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
#
# 9. Check that the channel name is provided.
#
SELECT asynchronous_connection_failover_delete_source(9, '127.0.0.1', 3100);
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_delete_source'; Wrong arguments: You need to specify channel name.
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
#
# 10. Check host parameters values is provided and not empty.
#
SELECT asynchronous_connection_failover_delete_source('', '', 3100);
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_delete_source'; Wrong arguments: You need to specify hostname.
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
#
# 11. Check port parameters values is provided.
#
SELECT asynchronous_connection_failover_delete_source('', '127.0.0.1', '3100');
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_delete_source'; Wrong arguments: You need to specify value for port.
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
#
# 12. Check correct string value is provided for network_namespace.
#
SELECT asynchronous_connection_failover_delete_source('', '127.0.0.1', 3100, 100);
ERROR HY000: Can't initialize function 'asynchronous_connection_failover_delete_source'; Wrong arguments: You need to specify a string value for network_namespace.
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
#
# 13. Add existing credentials. Delete non existing credentials.
#
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', 3100, '');
ERROR HY000: asynchronous_connection_failover_add_source UDF failed; Error inserting row to the table.
include/assert.inc ['There is one row in performance_schema.replication_asynchronous_connection_failover']
SELECT asynchronous_connection_failover_delete_source('', '127.0.0.1', 3100, '');
asynchronous_connection_failover_delete_source('', '127.0.0.1', 3100, '')
The UDF asynchronous_connection_failover_delete_source() executed successfully.
include/assert.inc ['The performance_schema.replication_asynchronous_connection_failover table is empty']
SELECT asynchronous_connection_failover_delete_source('ch2', '127.0.0.1', 77100);
ERROR HY000: asynchronous_connection_failover_delete_source UDF failed; Error no matching row was found to be deleted.
include/assert.inc ['The performance_schema.replication_asynchronous_connection_failover table is empty']
#
# 14. Verify user without SUPER or REPLICATION_SLAVE_ADMIN fails with
# ER_SPECIFIC_ACCESS_DENIED_ERROR error when execute
# asynchronous_connection_failover_add_source and
# asynchronous_connection_failover_delete_source UDF.
#
CREATE USER 'async_user' IDENTIFIED BY 'pass';
[connection connect_async]
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', 3100);
ERROR 42000: Access denied; you need (at least one of) the SUPER or REPLICATION_SLAVE_ADMIN privilege(s) for this operation
SELECT asynchronous_connection_failover_delete_source('', '127.0.0.1', 3100);
ERROR 42000: Access denied; you need (at least one of) the SUPER or REPLICATION_SLAVE_ADMIN privilege(s) for this operation
SELECT * FROM mysql.replication_asynchronous_connection_failover;
ERROR 42000: SELECT command denied to user 'async_user'@'localhost' for table 'replication_asynchronous_connection_failover'
SELECT asynchronous_connection_failover_reset();
ERROR 42000: Access denied; you need (at least one of) the SUPER or REPLICATION_SLAVE_ADMIN privilege(s) for this operation
#
# 15. Verify user with REPLICATION_SLAVE_ADMIN privilege can execute
# asynchronous_connection_failover_add_source and
# asynchronous_connection_failover_delete_source UDF.
#
[connection master]
GRANT REPLICATION_SLAVE_ADMIN ON *.* TO 'async_user';
[connection connect_async]
SELECT asynchronous_connection_failover_add_source('', '127.0.0.1', 3100);
asynchronous_connection_failover_add_source('', '127.0.0.1', 3100)
The UDF asynchronous_connection_failover_add_source() executed successfully.
SELECT asynchronous_connection_failover_delete_source('', '127.0.0.1', 3100);
asynchronous_connection_failover_delete_source('', '127.0.0.1', 3100)
The UDF asynchronous_connection_failover_delete_source() executed successfully.
SELECT asynchronous_connection_failover_reset();
asynchronous_connection_failover_reset()
The UDF asynchronous_connection_failover_reset() executed successfully.
[connection master]
DROP USER 'async_user';
include/assert.inc ['There are 0 rows in performance_schema.replication_asynchronous_connection_failover']
RESET REPLICA ALL;
include/rpl_end.inc
|
