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
|
################################################################################
# Verify server behaviour when a transaction is negatively certified.
#
# Test:
# 0. The test requires two servers: M1 and M2.
# 1. With both members ONLINE. Execute some transactions on M1.
# 2. Force negative certification outcome of the next transaction using DEBUG
# sync point.
# 3. First insert must be aborted. Validate the data on table and information
# in P_S tables on both M1 and M2.
# 4. Clean debug flag on MTR side.
# 5. Clean up. Validate gtid_executed on M1 and M2.
################################################################################
--source include/have_debug.inc
--let $group_replication_group_name= 8a94f357-aab4-11df-86ab-c80aa9429123
--source include/have_group_replication_plugin.inc
--source include/group_replication.inc
--echo ############################################################
--echo # 1. Execute some transactions on server1.
--connection server1
--let $group_replication_number_of_members= 2
--source include/gr_wait_for_number_of_members.inc
CREATE TABLE t1 (c1 INT NOT NULL PRIMARY KEY) ENGINE=InnoDB;
INSERT INTO t1 VALUES (1);
--let $sync_slave_connection= server2
--source include/sync_slave_sql_with_master.inc
--echo
--echo ############################################################
--echo # 2. Force negative certification outcome of the next
--echo # transaction.
--connection server1
SET @debug_save= @@GLOBAL.DEBUG;
SET @@GLOBAL.DEBUG= '+d,certifier_force_1_negative_certification';
--connection server2
SET @debug_save= @@GLOBAL.DEBUG;
SET @@GLOBAL.DEBUG= '+d,certifier_force_1_negative_certification';
--echo
--echo ############################################################
--echo # 3. First insert must be aborted.
--connection server1
--error ER_TRANSACTION_ROLLBACK_DURING_COMMIT
INSERT INTO t1 VALUES (2);
INSERT INTO t1 VALUES (3);
--let $sync_slave_connection= server2
--source include/sync_slave_sql_with_master.inc
--connection server1
--let $assert_text= 'There is no value 2 in table t1 on server 1'
--let $assert_cond= [SELECT COUNT(*) AS count FROM t1 WHERE t1.c1 = 2, count, 1] = 0
--source include/assert.inc
--let $assert_text= 'There is a value 3 in table t1 on server 1'
--let $assert_cond= [SELECT COUNT(*) AS count FROM t1 WHERE t1.c1 = 3, count, 1] = 1
--source include/assert.inc
--let $transaction_in_queue= query_get_value(SELECT Count_Transactions_in_queue FROM performance_schema.replication_group_member_stats where member_id in (SELECT @@server_uuid), Count_Transactions_in_queue, 1)
--let $assert_text= 'The value of Count_Transactions_in_queue should be 0 on server 1'
--let $assert_cond= $transaction_in_queue = 0
--source include/assert.inc
--let $certified_transactions= query_get_value(SELECT Count_transactions_checked FROM performance_schema.replication_group_member_stats where member_id in (SELECT @@server_uuid), Count_transactions_checked, 1)
--let $assert_text= 'The value of Count_transactions_checked should be 4 on server 1'
--let $assert_cond= $certified_transactions = 4
--source include/assert.inc
--let $negatively_certified= query_get_value(SELECT Count_conflicts_detected FROM performance_schema.replication_group_member_stats where member_id in (SELECT @@server_uuid), Count_conflicts_detected, 1)
--let $assert_text= 'The value of Count_conflicts_detected should be 1 on server 1'
--let $assert_cond= $negatively_certified = 1
--source include/assert.inc
--let $last_certified_transaction= query_get_value(SELECT Last_conflict_free_transaction from performance_schema.replication_group_member_stats where member_id in (SELECT @@server_uuid), Last_conflict_free_transaction, 1)
--let $assert_text= 'The value of Last_conflict_free_transaction should be 8a94f357-aab4-11df-86ab-c80aa9429123:5 on server 1'
--let $assert_cond= "$last_certified_transaction" = "$group_replication_group_name:5"
--source include/assert.inc
--connection server2
--let $assert_text= 'There is no value 2 in table t1 on server 2'
--let $assert_cond= [SELECT COUNT(*) AS count FROM t1 WHERE t1.c1 = 2, count, 1] = 0
--source include/assert.inc
--let $assert_text= 'There is a value 3 in table t1 on server 2'
--let $assert_cond= [SELECT COUNT(*) AS count FROM t1 WHERE t1.c1 = 3, count, 1] = 1
--source include/assert.inc
--let $transaction_in_queue= query_get_value(SELECT Count_Transactions_in_queue FROM performance_schema.replication_group_member_stats where member_id in (SELECT @@server_uuid), Count_Transactions_in_queue, 1)
--let $assert_text= 'The value of Count_Transactions_in_queue should be 0 on server 2'
--let $assert_cond= $transaction_in_queue = 0
--source include/assert.inc
--let $certified_transactions= query_get_value(SELECT Count_transactions_checked FROM performance_schema.replication_group_member_stats where member_id in (SELECT @@server_uuid), Count_transactions_checked, 1)
--let $assert_text= 'The value of Count_transactions_checked should be 4 on server 2'
--let $assert_cond= $certified_transactions = 4
--source include/assert.inc
--let $negatively_certified= query_get_value(SELECT Count_conflicts_detected FROM performance_schema.replication_group_member_stats where member_id in (SELECT @@server_uuid), Count_conflicts_detected, 1)
--let $assert_text= 'The value of Count_conflicts_detected should be 1 on server 2'
--let $assert_cond= $negatively_certified = 1
--source include/assert.inc
--let $last_certified_transaction= query_get_value(SELECT Last_conflict_free_transaction from performance_schema.replication_group_member_stats where member_id in (SELECT @@server_uuid), Last_conflict_free_transaction, 1)
--let $assert_text= 'The value of Last_conflict_free_transaction should be 8a94f357-aab4-11df-86ab-c80aa9429123:5 on server 2'
--let $assert_cond= "$last_certified_transaction" = "$group_replication_group_name:5"
--source include/assert.inc
--echo
--echo ############################################################
--echo # 4. Clean debug flag on MTR side.
--connection server1
SET @@GLOBAL.DEBUG= @debug_saved;
--connection server2
SET @@GLOBAL.DEBUG= @debug_saved;
--echo
--echo ############################################################
--echo # 5. Shutdown.
--connection server1
DROP TABLE t1;
--let $sync_slave_connection= server2
--source include/sync_slave_sql_with_master.inc
--connection server1
--let $assert_text= 'Aborted transaction should not have increased GNO to 7 on server 1'
--let $assert_cond= "[SELECT @@GLOBAL.GTID_EXECUTED]" = "$group_replication_group_name:1-6"
--source include/assert.inc
--connection server2
--let $assert_text= 'Aborted transaction should not have increased GNO to 7 on server 2'
--let $assert_cond= "[SELECT @@GLOBAL.GTID_EXECUTED]" = "$group_replication_group_name:1-6"
--source include/assert.inc
--source include/group_replication_end.inc
|
