File: gr_concurrent_events_insert_with_select.result

package info (click to toggle)
mysql-8.0 8.0.43-3
  • links: PTS, VCS
  • area: main
  • in suites: sid
  • size: 1,273,924 kB
  • sloc: cpp: 4,684,605; ansic: 412,450; pascal: 108,398; java: 83,641; perl: 30,221; cs: 27,067; sql: 26,594; sh: 24,181; python: 21,816; yacc: 17,169; php: 11,522; xml: 7,388; javascript: 7,076; makefile: 2,194; lex: 1,075; awk: 670; asm: 520; objc: 183; ruby: 97; lisp: 86
file content (142 lines) | stat: -rw-r--r-- 3,778 bytes parent folder | download
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
include/group_replication.inc [rpl_server_count=3]
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 server1]
#
# Create the test table on server 1
#
[connection server1]
CREATE TABLE IF NOT EXISTS t1 (a INT PRIMARY KEY);
include/rpl_sync.inc
#
# Create the events in each member.
#
SET @old_event_scheduler= @@global.event_scheduler;
SET SESSION sql_log_bin= 0;
SET GLOBAL event_scheduler=on|
CREATE EVENT IF NOT EXISTS test.event1
ON SCHEDULE
EVERY 1 SECOND
STARTS CURRENT_TIMESTAMP + INTERVAL 1 SECOND
ENDS CURRENT_TIMESTAMP + INTERVAL 30 SECOND
ON COMPLETION PRESERVE
DISABLE
COMMENT 'Test with events'
 DO
BEGIN
DECLARE v INTEGER;
DECLARE CONTINUE HANDLER FOR SQLEXCEPTION BEGIN END;
SET v=0;
WHILE v < 1000
DO
SELECT max(a) + 1 INTO v FROM t1;
INSERT INTO t1 values (v);
SET v = v+1;
END WHILE;
END|
SET SESSION sql_log_bin= 1;
[connection server2]
SET @old_event_scheduler= @@global.event_scheduler;
SET SESSION sql_log_bin= 0;
SET GLOBAL event_scheduler=on|
CREATE EVENT IF NOT EXISTS test.event2
ON SCHEDULE
EVERY 1 SECOND
STARTS CURRENT_TIMESTAMP + INTERVAL 1 SECOND
ENDS CURRENT_TIMESTAMP + INTERVAL 30 SECOND
ON COMPLETION PRESERVE
DISABLE
COMMENT 'Test with events'
 DO
BEGIN
DECLARE v INTEGER;
DECLARE CONTINUE HANDLER FOR SQLEXCEPTION BEGIN END;
SET v=0;
WHILE v < 1000
DO
SELECT max(a) + 1 INTO v FROM t1;
INSERT INTO t1 values (v);
SET v = v+1;
END WHILE;
END|
SET SESSION sql_log_bin= 1;
[connection server3]
SET @old_event_scheduler= @@global.event_scheduler;
SET SESSION sql_log_bin= 0;
SET GLOBAL event_scheduler=on|
CREATE EVENT IF NOT EXISTS test.event3
ON SCHEDULE
EVERY 1 SECOND
STARTS CURRENT_TIMESTAMP + INTERVAL 1 SECOND
ENDS CURRENT_TIMESTAMP + INTERVAL 30 SECOND
ON COMPLETION PRESERVE
DISABLE
COMMENT 'Test with events'
 DO
BEGIN
DECLARE v INTEGER;
DECLARE CONTINUE HANDLER FOR SQLEXCEPTION BEGIN END;
SET v=0;
WHILE v < 1000
DO
SELECT max(a) + 1 INTO v FROM t1;
INSERT INTO t1 values (v);
SET v = v+1;
END WHILE;
END|
SET SESSION sql_log_bin= 1;
#
# Start the events in each member.
#
[connection server1]
SET GLOBAL event_scheduler=on;
SET SESSION sql_log_bin= 0;
ALTER EVENT event1 ENABLE;
SET SESSION sql_log_bin= 1;
[connection server2]
SET GLOBAL event_scheduler=on;
SET SESSION sql_log_bin= 0;
ALTER EVENT event2 ENABLE;
SET SESSION sql_log_bin= 1;
[connection server3]
SET GLOBAL event_scheduler=on;
SET SESSION sql_log_bin= 0;
ALTER EVENT event3 ENABLE;
SET SESSION sql_log_bin= 1;
#
# Wait for the events to be disabled
#
[connection server1]
[connection server2]
[connection server3]
#
# Check the members are still operational
#
[connection server1]
include/assert.inc ['The group replication applier channel is ON']
[connection server2]
include/assert.inc ['The group replication applier channel is ON']
[connection server3]
include/assert.inc ['The group replication applier channel is ON']
#
# Remove the events and the data
#
[connection server1]
SET SESSION sql_log_bin= 0;
DROP EVENT IF EXISTS test.event1;
SET SESSION sql_log_bin= 1;
SET GLOBAL event_scheduler= @old_event_scheduler;
[connection server2]
SET SESSION sql_log_bin= 0;
DROP EVENT IF EXISTS test.event2;
SET SESSION sql_log_bin= 1;
SET GLOBAL event_scheduler= @old_event_scheduler;
[connection server3]
SET SESSION sql_log_bin= 0;
DROP EVENT IF EXISTS test.event3;
SET SESSION sql_log_bin= 1;
SET GLOBAL event_scheduler= @old_event_scheduler;
[connection server1]
DROP TABLE t1;
include/group_replication_end.inc