• 创建SAVEPOINT
  • 回滚到SAVEPOINT
  1. ROLLBACK [WORK] to [SAVEPOINT] spname

假设一个事务执行了如下语句:

sql_no

语句

分区

1

update…

p1, p4

savepoint sp1

2

update…

p2, p4

3

p3, p5

savepoint sp2

4

update…

p1, p3, p6

5

update…

p1, p5

savepoint sp3

6

select…

7

update…

savepoint sp4

记录 Savepoint

用户在提交事务之前可以创建SAVEPOINT,需要根据SAVEPOINT创建的顺序,将事务的SAVEPOINT串成链表。以上事务包含了 7 条 SQL 和 4 个SAVEPOINT,记录SAVEPOINT的链表如下图所示,其中每个节点记录了<spname, sql_no>的映射关系:

事务参与者列表

事务为了支持回滚某条 SQL 之后的所有修改,需要将每条语句涉及的参与者以及对应的 sql_no 记录下来,以上事务执行了 7 条 SQL,涉及 p1~p6 共 6 个分区:

image.png

Savepoint 回滚过程

  1. 根据事务参与者列表查询sql_no对应的分区

    根据事务参与者列表查询到sql_no大于 3 的语句操作的分区涉及 p1、p3、p5、p6。

  2. 回滚分区数据

    根据第 2 步查询到的分区,调度程序向这些分区发起回滚请求,回滚当前事务在这些分区上 sp2 之后的所有修改。其中 p1、p3、p5 上关于本事务的部分修改被回滚掉,p6 上关于本事务的所有修改都被回滚掉。

  3. 更新事务参与者列表信息

    修改事务参与者列表,将sql_no大于 3 的操作信息从事务参与者列表中删除,由于 p6上的所有修改都被回滚掉,因此 p6 可以从参与者列表中删除。

  1. 删除无效的 Savepoint

    用户执行ROLLBACK to SAVEPOINT sp2成功后,系统会删除 sp3 和 sp4 的,不允许再回滚到 sp3 和 sp4。