【StoneDB】从库如何规避不支持的DML和DDL

（以下情况仅针对StoneDB 1.0版本不支持的部分DML和DDL操作，StoneDB 2.0及以上版本将无需此类操作）
主从复制中，主库的任何更新都会同步到从库，如果从库不想重做主库的某个更新动作，可以使用以下两种方法进行规避。当然，最终带来的影响是主从环境数据不一致的问题。
以下的测试环境中，主库是 InnoDB，从库是 StoneDB，在主库做从库不支持的 DML 或者 DDL。
从库执行 GTID 的空事务

1. ###主库
2. mysql> show create table ttt\G                             
3. *************************** 1. row ***************************
4.        Table: ttt
5. Create Table: CREATE TABLE `ttt` (
6.   `id` int(11) NOT NULL,
7.   `name` varchar(5) DEFAULT NULL,
8.   PRIMARY KEY (`id`)
9. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
10. 1 row in set (0.00 sec)
12. mysql> select * from ttt;     
13. +----+------+
14. | id | name |
15. +----+------+
16. |  1 | AAA  |
17. |  2 | BBB  |
18. |  3 | CCC  |
19. +----+------+
20. 3 rows in set (0.00 sec)
22. ###从库
23. mysql> show create table ttt\G
24. *************************** 1. row ***************************
25.        Table: ttt
26. Create Table: CREATE TABLE `ttt` (
27.   `id` int(11) NOT NULL,
28.   `name` varchar(5) DEFAULT NULL,
29.   PRIMARY KEY (`id`)
30. ) ENGINE=STONEDB DEFAULT CHARSET=utf8mb4
31. 1 row in set (0.02 sec)
33. mysql> select * from ttt;
34. +----+------+
35. | id | name |
36. +----+------+
37. |  1 | AAA  |
38. |  2 | BBB  |
39. |  3 | CCC  |
40. +----+------+
41. 3 rows in set (0.00 sec)
43. ###主库
44. mysql> delete from ttt where id=3;
45. Query OK, 1 row affected (0.00 sec)
47. mysql> select * from ttt;               
48. +----+------+
49. | id | name |
50. +----+------+
51. |  1 | AAA  |
52. |  2 | BBB  |
53. +----+------+
54. 2 rows in set (0.00 sec)
56. ###从库
57. mysql> show slave status\G
58. *************************** 1. row ***************************
59.                Slave_IO_State: Waiting for master to send event
60.                   Master_Host: 192.168.30.101
61.                   Master_User: u_repl
62.                   Master_Port: 33306
63.                 Connect_Retry: 60
64.               Master_Log_File: binlog.000002
65.           Read_Master_Log_Pos: 1053
66.                Relay_Log_File: ub01-relay-bin.000002
67.                 Relay_Log_Pos: 993
68.         Relay_Master_Log_File: binlog.000002
69.              Slave_IO_Running: Yes
70.             Slave_SQL_Running: No
71.               Replicate_Do_DB:
72.           Replicate_Ignore_DB:
73.            Replicate_Do_Table:
74.        Replicate_Ignore_Table:
75.       Replicate_Wild_Do_Table:
76.   Replicate_Wild_Ignore_Table:
77.                    Last_Errno: 1031
78.                    Last_Error: Error 'Table storage engine for 'ttt' doesn't have this option' on query. Default database: 'db'. Query: 'delete from ttt where id=3'
79.                  Skip_Counter: 0
80.           Exec_Master_Log_Pos: 786
81.               Relay_Log_Space: 1466
82.               Until_Condition: None
83.                Until_Log_File:
84.                 Until_Log_Pos: 0
85.            Master_SSL_Allowed: No
86.            Master_SSL_CA_File:
87.            Master_SSL_CA_Path:
88.               Master_SSL_Cert:
89.             Master_SSL_Cipher:
90.                Master_SSL_Key:
91.         Seconds_Behind_Master: NULL
92. Master_SSL_Verify_Server_Cert: No
93.                 Last_IO_Errno: 0
94.                 Last_IO_Error:
95.                Last_SQL_Errno: 1031
96.                Last_SQL_Error: Error 'Table storage engine for 'ttt' doesn't have this option' on query. Default database: 'db'. Query: 'delete from ttt where id=3'
97.   Replicate_Ignore_Server_Ids:
98.              Master_Server_Id: 101
99.                   Master_UUID: ae40cabd-efb2-11ec-ac20-44a84203989a
100.              Master_Info_File: /data/stonedb/install/data/master.info
101.                     SQL_Delay: 0
102.           SQL_Remaining_Delay: NULL
103.       Slave_SQL_Running_State:
104.            Master_Retry_Count: 86400
105.                   Master_Bind:
106.       Last_IO_Error_Timestamp:
107.      Last_SQL_Error_Timestamp: 220729 02:26:29
108.                Master_SSL_Crl:
109.            Master_SSL_Crlpath:
110.            Retrieved_Gtid_Set: ae40cabd-efb2-11ec-ac20-44a84203989a:1-4
111.             Executed_Gtid_Set: 4ddecc1a-ee49-11ec-96fe-f219e7257407:1,
112. ae40cabd-efb2-11ec-ac20-44a84203989a:1-3
113.                 Auto_Position: 1
114.          Replicate_Rewrite_DB:
115.                  Channel_Name:
116.            Master_TLS_Version:
117. 1 row in set (0.00 sec)
119. mysql> select * from ttt;
120. +----+------+
121. | id | name |
122. +----+------+
123. |  1 | AAA  |
124. |  2 | BBB  |
125. |  3 | CCC  |
126. +----+------+
127. 3 rows in set (0.00 sec)
129. 主库执行 delete后，由于 StoneDB 不支持 delete，从库会有报错，并且主从复制中断。
130. 下一步需要在主库找到执行 delete操作的gtid值。
132. ###主库
133. mysql> show binary logs;
134. +---------------+-----------+
135. | Log_name      | File_size |
136. +---------------+-----------+
137. | binlog.000001 |       177 |
138. | binlog.000002 |      1053 |
139. +---------------+-----------+
140. 2 rows in set (0.00 sec)
142. mysql> show binlog events in '/data/stonedb/install/binlog/binlog.000002';
143. +---------------+------+----------------+-----------+-------------+-------------------------------------------------------------------+
144. | Log_name      | Pos  | Event_type     | Server_id | End_log_pos | Info                                                              |
145. +---------------+------+----------------+-----------+-------------+-------------------------------------------------------------------+
146. | binlog.000002 |    4 | Format_desc    |       101 |         123 | Server ver: 5.7.36-StoneDB-log, Binlog ver: 4                     |
147. | binlog.000002 |  123 | Previous_gtids |       101 |         154 |                                                                   |
148. | binlog.000002 |  154 | Gtid           |       101 |         219 | SET @@SESSION.GTID_NEXT= 'ae40cabd-efb2-11ec-ac20-44a84203989a:1' |
149. | binlog.000002 |  219 | Query          |       101 |         307 | create database db                                                |
150. | binlog.000002 |  307 | Gtid           |       101 |         372 | SET @@SESSION.GTID_NEXT= 'ae40cabd-efb2-11ec-ac20-44a84203989a:2' |
151. | binlog.000002 |  372 | Query          |       101 |         494 | use `db`; create table ttt(id int primary key,name varchar(5))    |
152. | binlog.000002 |  494 | Gtid           |       101 |         559 | SET @@SESSION.GTID_NEXT= 'ae40cabd-efb2-11ec-ac20-44a84203989a:3' |
153. | binlog.000002 |  559 | Query          |       101 |         634 | BEGIN                                                             |
154. | binlog.000002 |  634 | Query          |       101 |         755 | use `db`; insert into ttt values(1,'AAA'),(2,'BBB'),(3,'CCC')     |
155. | binlog.000002 |  755 | Xid            |       101 |         786 | COMMIT /* xid=20 */                                               |
156. | binlog.000002 |  786 | Gtid           |       101 |         851 | SET @@SESSION.GTID_NEXT= 'ae40cabd-efb2-11ec-ac20-44a84203989a:4' |
157. | binlog.000002 |  851 | Query          |       101 |         926 | BEGIN                                                             |
158. | binlog.000002 |  926 | Query          |       101 |        1022 | use `db`; delete from ttt where id=3                              |
159. | binlog.000002 | 1022 | Xid            |       101 |        1053 | COMMIT /* xid=28 */                                               |
160. +---------------+------+----------------+-----------+-------------+-------------------------------------------------------------------+
161. 14 rows in set (0.00 sec)
163. 如果是在生产环境找主库 delete 操作的 gtid 值，需要知道哪个时间点，然后用 mysqlbinlog 解析binlog。
164. 这里由于是做测试，可以简单快递的找到 delete 操作的 gtid 值，ae40cabd-efb2-11ec-ac20-44a84203989a:4。
165. gtid 值由参数 server_uuid 和事务 id 组成，标识一个这个操作的唯一性。
167. ###从库
168. set gtid_next='ae40cabd-efb2-11ec-ac20-44a84203989a:4';
169. begin;
170. commit;
171. set gtid_next=automatic;
172. start slave;
174. mysql> show slave status\G
175. *************************** 1. row ***************************
176.                Slave_IO_State: Waiting for master to send event
177.                   Master_Host: 192.168.30.101
178.                   Master_User: u_repl
179.                   Master_Port: 33306
180.                 Connect_Retry: 60
181.               Master_Log_File: binlog.000002
182.           Read_Master_Log_Pos: 1053
183.                Relay_Log_File: ub01-relay-bin.000002
184.                 Relay_Log_Pos: 1260
185.         Relay_Master_Log_File: binlog.000002
186.              Slave_IO_Running: Yes
187.             Slave_SQL_Running: Yes
188.               Replicate_Do_DB:
189.           Replicate_Ignore_DB:
190.            Replicate_Do_Table:
191.        Replicate_Ignore_Table:
192.       Replicate_Wild_Do_Table:
193.   Replicate_Wild_Ignore_Table:
194.                    Last_Errno: 0
195.                    Last_Error:
196.                  Skip_Counter: 0
197.           Exec_Master_Log_Pos: 1053
198.               Relay_Log_Space: 1466
199.               Until_Condition: None
200.                Until_Log_File:
201.                 Until_Log_Pos: 0
202.            Master_SSL_Allowed: No
203.            Master_SSL_CA_File:
204.            Master_SSL_CA_Path:
205.               Master_SSL_Cert:
206.             Master_SSL_Cipher:
207.                Master_SSL_Key:
208.         Seconds_Behind_Master: 0
209. Master_SSL_Verify_Server_Cert: No
210.                 Last_IO_Errno: 0
211.                 Last_IO_Error:
212.                Last_SQL_Errno: 0
213.                Last_SQL_Error:
214.   Replicate_Ignore_Server_Ids:
215.              Master_Server_Id: 101
216.                   Master_UUID: ae40cabd-efb2-11ec-ac20-44a84203989a
217.              Master_Info_File: /data/stonedb/install/data/master.info
218.                     SQL_Delay: 0
219.           SQL_Remaining_Delay: NULL
220.       Slave_SQL_Running_State: Slave has read all relay log; waiting for more updates
221.            Master_Retry_Count: 86400
222.                   Master_Bind:
223.       Last_IO_Error_Timestamp:
224.      Last_SQL_Error_Timestamp:
225.                Master_SSL_Crl:
226.            Master_SSL_Crlpath:
227.            Retrieved_Gtid_Set: ae40cabd-efb2-11ec-ac20-44a84203989a:1-4
228.             Executed_Gtid_Set: 4ddecc1a-ee49-11ec-96fe-f219e7257407:1,
229. ae40cabd-efb2-11ec-ac20-44a84203989a:1-4
230.                 Auto_Position: 1
231.          Replicate_Rewrite_DB:
232.                  Channel_Name:
233.            Master_TLS_Version:
234. 1 row in set (0.00 sec)
236. mysql> select * from ttt;
237. +----+------+
238. | id | name |
239. +----+------+
240. |  1 | AAA  |
241. |  2 | BBB  |
242. |  3 | CCC  |
243. +----+------+
244. 3 rows in set (0.00 sec)
246. 利用 gtid 跳过一个空事务后，主从复制的线程已经正常启动，但由于 StoneDB 不支持 delete，现在主从环境数据是不一致的。
248. ###主库
249. mysql> insert into ttt values(4,'DDD');
250. Query OK, 1 row affected (0.00 sec)
252. mysql> select * from ttt;
253. +----+------+
254. | id | name |
255. +----+------+
256. |  1 | AAA  |
257. |  2 | BBB  |
258. |  4 | DDD  |
259. +----+------+
260. 3 rows in set (0.00 sec)
262. ###从库
263. mysql> select * from ttt;
264. +----+------+
265. | id | name |
266. +----+------+
267. |  1 | AAA  |
268. |  2 | BBB  |
269. |  3 | CCC  |
270. |  4 | DDD  |
271. +----+------+
272. 4 rows in set (0.00 sec)
274. 主从复制的线程启动后，主库的更新，从库同步正常。

复制代码

如果觉得在主库找 delete 的 gtid 值麻烦，在主库执行 delete 前，可以指定 delete 的 gtid 值。在从库还是根据这个 gtid 值执行空事务。

1. ###
2. mysql> show variables like 'server_uuid';
3. +---------------+--------------------------------------+
4. | Variable_name | Value                                |
5. +---------------+--------------------------------------+
6. | server_uuid   | ae40cabd-efb2-11ec-ac20-44a84203989a |
7. +---------------+--------------------------------------+
8. 1 row in set (0.01 sec)
10. mysql> set gtid_next='ae40cabd-efb2-11ec-ac20-44a84203989a:100';
11. Query OK, 0 rows affected (0.00 sec)
13. mysql> begin;
14. Query OK, 0 rows affected (0.00 sec)
16. mysql> delete from ttt where id=1;
17. Query OK, 1 row affected (0.00 sec)
19. mysql> commit;
20. Query OK, 0 rows affected (0.00 sec)
22. mysql> set gtid_next=automatic;
23. Query OK, 0 rows affected (0.00 sec)
25. ###从库
26. set gtid_next='ae40cabd-efb2-11ec-ac20-44a84203989a:100';
27. begin;
28. commit;
29. set gtid_next=automatic;
30. start slave;

复制代码

关闭当前线程的binlog

1. ###主库
2. mysql> show create table ttt\G                                             
3. *************************** 1. row ***************************
4.        Table: ttt
5. Create Table: CREATE TABLE `ttt` (
6.   `id` int(11) NOT NULL AUTO_INCREMENT,
7.   `name` varchar(5) DEFAULT NULL,
8.   PRIMARY KEY (`id`)
9. ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4
10. 1 row in set (0.00 sec)
12. mysql> select * from ttt;     
13. +----+------+
14. | id | name |
15. +----+------+
16. |  1 | AAA  |
17. |  2 | BBB  |
18. +----+------+
19. 2 rows in set (0.00 sec)
21. ###从库
22. mysql> show create table ttt\G
23. *************************** 1. row ***************************
24.        Table: ttt
25. Create Table: CREATE TABLE `ttt` (
26.   `id` int(11) NOT NULL AUTO_INCREMENT,
27.   `name` varchar(5) DEFAULT NULL,
28.   PRIMARY KEY (`id`)
29. ) ENGINE=STONEDB DEFAULT CHARSET=utf8mb4
30. 1 row in set (0.00 sec)
32. mysql> select * from ttt;
33. +----+------+
34. | id | name |
35. +----+------+
36. |  1 | AAA  |
37. |  2 | BBB  |
38. +----+------+
39. 2 rows in set (0.00 sec)
41. ###主库
42. mysql> set sql_log_bin=off;
43. Query OK, 0 rows affected (0.00 sec)
45. mysql> alter table ttt modify name varchar(10);
46. Query OK, 0 rows affected (0.00 sec)
47. Records: 0  Duplicates: 0  Warnings: 0
49. mysql> show create table ttt\G                 
50. *************************** 1. row ***************************
51.        Table: ttt
52. Create Table: CREATE TABLE `ttt` (
53.   `id` int(11) NOT NULL AUTO_INCREMENT,
54.   `name` varchar(10) DEFAULT NULL,
55.   PRIMARY KEY (`id`)
56. ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4
57. 1 row in set (0.00 sec)
59. ###从库
60. mysql> show slave status\G
61. *************************** 1. row ***************************
62.                Slave_IO_State: Waiting for master to send event
63.                   Master_Host: 192.168.30.101
64.                   Master_User: u_repl
65.                   Master_Port: 33306
66.                 Connect_Retry: 60
67.               Master_Log_File: binlog.000002
68.           Read_Master_Log_Pos: 2288
69.                Relay_Log_File: ub01-relay-bin.000002
70.                 Relay_Log_Pos: 2495
71.         Relay_Master_Log_File: binlog.000002
72.              Slave_IO_Running: Yes
73.             Slave_SQL_Running: Yes
74.               Replicate_Do_DB:
75.           Replicate_Ignore_DB:
76.            Replicate_Do_Table:
77.        Replicate_Ignore_Table:
78.       Replicate_Wild_Do_Table:
79.   Replicate_Wild_Ignore_Table:
80.                    Last_Errno: 0
81.                    Last_Error:
82.                  Skip_Counter: 0
83.           Exec_Master_Log_Pos: 2288
84.               Relay_Log_Space: 2701
85.               Until_Condition: None
86.                Until_Log_File:
87.                 Until_Log_Pos: 0
88.            Master_SSL_Allowed: No
89.            Master_SSL_CA_File:
90.            Master_SSL_CA_Path:
91.               Master_SSL_Cert:
92.             Master_SSL_Cipher:
93.                Master_SSL_Key:
94.         Seconds_Behind_Master: 0
95. Master_SSL_Verify_Server_Cert: No
96.                 Last_IO_Errno: 0
97.                 Last_IO_Error:
98.                Last_SQL_Errno: 0
99.                Last_SQL_Error:
100.   Replicate_Ignore_Server_Ids:
101.              Master_Server_Id: 101
102.                   Master_UUID: ae40cabd-efb2-11ec-ac20-44a84203989a
103.              Master_Info_File: /data/stonedb/install/data/master.info
104.                     SQL_Delay: 0
105.           SQL_Remaining_Delay: NULL
106.       Slave_SQL_Running_State: Slave has read all relay log; waiting for more updates
107.            Master_Retry_Count: 86400
108.                   Master_Bind:
109.       Last_IO_Error_Timestamp:
110.      Last_SQL_Error_Timestamp:
111.                Master_SSL_Crl:
112.            Master_SSL_Crlpath:
113.            Retrieved_Gtid_Set: ae40cabd-efb2-11ec-ac20-44a84203989a:1-8:100
114.             Executed_Gtid_Set: 4ddecc1a-ee49-11ec-96fe-f219e7257407:1-3,
115. ae40cabd-efb2-11ec-ac20-44a84203989a:1-8:100
116.                 Auto_Position: 1
117.          Replicate_Rewrite_DB:
118.                  Channel_Name:
119.            Master_TLS_Version:
120. 1 row in set (0.00 sec)
122. mysql> show create table ttt\G
123. *************************** 1. row ***************************
124.        Table: ttt
125. Create Table: CREATE TABLE `ttt` (
126.   `id` int(11) NOT NULL AUTO_INCREMENT,
127.   `name` varchar(5) DEFAULT NULL,
128.   PRIMARY KEY (`id`)
129. ) ENGINE=STONEDB DEFAULT CHARSET=utf8mb4
130. 1 row in set (0.00 sec)
132. 主库关闭当前线程的binlog，对表做DDL,将字段 name 的长度扩大。
133. 主从复制正常，从库表的字段 name 的长度不变。
135. ###主库
136. 开启新的线程，注意一点是开启新的线程！！！
137. mysql> insert into ttt(name) values('CCC');
138. Query OK, 1 row affected (0.00 sec)
140. mysql> select * from ttt;                  
141. +----+------+
142. | id | name |
143. +----+------+
144. |  1 | AAA  |
145. |  2 | BBB  |
146. |  3 | CCC  |
147. +----+------+
148. 3 rows in set (0.00 sec)
150. ###从库
151. mysql> select * from ttt;
152. +----+------+
153. | id | name |
154. +----+------+
155. |  1 | AAA  |
156. |  2 | BBB  |
157. |  3 | CCC  |
158. +----+------+
159. 3 rows in set (0.00 sec)
161. sql_log_bin=off，关闭的是当前线程的binlog，不影响其他线程的任何更新。

复制代码

以上两种方法都可以规避从库不想重做主库的某个更新动作，目的是让从库遇到不支持的操作时可以让主从复制的线程正常工作，但带来的问题是主从环境数据不一致。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！