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
|
# Test clone with insert
--source include/have_debug.inc
--source include/have_debug_sync.inc
--source include/count_sessions.inc
connect (con1,localhost,root,,);
connect (con2,localhost,root,,);
connect (con3,localhost,root,,);
--let $CLONE_DATADIR = $MYSQL_TMP_DIR/data_new
--let $MYSQLD_DATADIR = `SELECT @@datadir`
--replace_result $CLONE_PLUGIN CLONE_PLUGIN
--eval INSTALL PLUGIN clone SONAME '$CLONE_PLUGIN'
DELIMITER |;
CREATE PROCEDURE prepare_data(IN val INT)
BEGIN
DECLARE i INT DEFAULT 1;
WHILE i <= val DO
INSERT INTO t1 (b,c) VALUES (REPEAT(a,600), REPEAT(b,600));
INSERT INTO t2 (b,c) VALUES (REPEAT(a,600), REPEAT(b,600));
SET i = i + 1;
END WHILE;
END|
DELIMITER ;|
--echo # Case 1 - Normal page archiving process using clone client.
CREATE TABLE t1 (a INT AUTO_INCREMENT, b LONGBLOB, c LONGBLOB, key k1(a));
CREATE TABLE t2 (a INT PRIMARY KEY AUTO_INCREMENT, b LONGBLOB, c LONGBLOB);
--connection con1
SET DEBUG_SYNC = 'clone_file_copy SIGNAL page_signal WAIT_FOR go_page';
SET DEBUG_SYNC = 'clone_page_copy SIGNAL redo_signal WAIT_FOR go_redo';
if (!$remote_clone) {
SET DEBUG_SYNC = 'clone_donor_after_saving_dynamic_metadata SIGNAL meta_signal WAIT_FOR go_meta';
}
--source ../include/clone_command_send.inc
--connection con2
SET DEBUG_SYNC = 'now WAIT_FOR page_signal';
CALL prepare_data(50);
SET DEBUG_SYNC = 'now SIGNAL go_page';
SET DEBUG_SYNC = 'now WAIT_FOR redo_signal';
CALL prepare_data(10);
SET DEBUG_SYNC = 'now SIGNAL go_redo';
if (!$remote_clone) {
SET DEBUG_SYNC = 'now WAIT_FOR meta_signal';
SET GLOBAL debug="+d,periodical_checkpoint_disabled";
CALL prepare_data(10);
UPDATE t1 SET a = 100 where a = 1;
UPDATE t2 SET a = 200 where a = 1;
SET DEBUG_SYNC = 'now SIGNAL go_meta';
}
--connection con1
--reap
select count(*) from t1;
select count(*) from t2;
# Restart server on cloned data directory
--replace_result $CLONE_DATADIR CLONE_DATADIR
--let restart_parameters="restart: --datadir=$CLONE_DATADIR"
--source include/restart_mysqld.inc
INSERT INTO t1 (b,c) VALUES (REPEAT(a,600), REPEAT(b,600));
INSERT INTO t2 (b,c) VALUES (REPEAT(a,600), REPEAT(b,600));
select count(*), max(a) from t1;
select count(*), max(a) from t2;
#Cleanup
--let restart_parameters="restart:"
--source include/restart_mysqld.inc
--connection con1
DROP TABLE t1;
DROP TABLE t2;
SET DEBUG_SYNC = 'RESET';
--force-rmdir $CLONE_DATADIR
DROP PROCEDURE prepare_data;
UNINSTALL PLUGIN clone;
--disconnect con1
--disconnect con2
--disconnect con3
|
