MySQL XA 事务
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
use learn_seata_account;
select * from account_tbl;
+----+-----------+---------+
| id | user_id | money |
+----+-----------+---------+
| 1 | yueyazhui | 1500000 |
+----+-----------+---------+
-- 一阶段
-- 开启 XA 事务
xa start "transfer_money";
-- 更新(业务逻辑)
update account_tbl set money = money - 300000 where user_id = 'yueyazhui';
-- 结束 XA 事务(处于 idle 状态)
xa end "transfer_money";
-- 提交
xa commit "transfer_money" one phase;
select * from account_tbl;
+----+-----------+---------+
| id | user_id | money |
+----+-----------+---------+
| 1 | yueyazhui | 1200000 |
+----+-----------+---------+
-- 准备(给协调者 binlog 报告状态,如果是一阶段提交这一步可省略)
xa prepare "transfer_money";
-- 二阶段
-- 提交
xa commit "transfer_money";
select * from account_tbl;
+----+-----------+---------+
| id | user_id | money |
+----+-----------+---------+
| 1 | yueyazhui | 1200000 |
+----+-----------+---------+
-- 回滚
-- 查看处于 prepare 状态
xa recover;
+----------+--------------+--------------+----------------+
| formatID | gtrid_length | bqual_length | data |
+----------+--------------+--------------+----------------+
| 1 | 14 | 0 | transfer_money |
+----------+--------------+--------------+----------------+
-- xa rollback data.substring(0, gtrid_length), data.substring(gtrid_length + 1), formatID;
xa rollback "transfer_money", "", 1;
select * from account_tbl;
+----+-----------+---------+
| id | user_id | money |
+----+-----------+---------+
| 1 | yueyazhui | 1500000 |
+----+-----------+---------+
本文由作者按照
CC BY 4.0
进行授权