SAVEPOINT
描述
该语句用来创建事务中的保存点,实现事务的部分回滚。
语法
-
创建保存点:
SAVEPOINT savepoint_name; -
回滚到保存点:
ROLLBACK [WORK] TO [SAVEPOINT] savepoint_name; -
删除保存点:
RELEASE SAVEPOINT savepoint_name;
参数解释
| 参数 | 描述 |
|---|---|
| [WORK] | 可选关键字,不影响语义。 |
| savepoint_name | 指定保存点的名称。指定的保存点在事务范围内唯一,同名的保存点会覆盖前一个保存点。 创建保存点后,可以将事务回滚到指定保存点,也可以使用 ROLLBACK 语句回滚整个事务。 |
示例
假设一个事务执行了如下语句:
| sql_no | 语句 | 分区 |
|---|---|---|
| 1 | UPDATE ...; | p1, p4 |
| SAVEPOINT sp1; | ||
| 2 | UPDATE ...; | p2, p4 |
| 3 | UPDATE ...; | p3, p5 |
| SAVEPOINT sp2; | ||
| 4 | UPDATE ...; | p1, p3, p6 |
| 5 | UPDATE ...; | p1, p5 |
| SAVEPOINT sp3; | ||
| 6 | SELECT ...; | |
| 7 | UPDATE ...; | p5, p6 |
| SAVEPOINT sp4; |
记录 Savepoint
用户在提交事务之前可以创建保存点,需要根据保存点创建的顺序,将事务的保存点串成链表。以上事务包含了 7 条 SQL 和 4 个保存点,记录保存点的链表如下图所示,其中每个节点记录了 <savepoint_name, sql_no> 的映射关系:

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

Savepoint 回滚过程
-
根据保存点链表查询
savepoint_name对应的sql_no。假设用户执行
ROLLBACK to SAVEPOINT sp2,根据保存点链表查询到sp2对应的sql_no为3。 -
根据事务参与者列表查询
sql_no对应的 Partition。根据事务参与者列表查询到
sql_no大于3的语句操作的分区涉及p1、p3、p5、p6。 -
回滚分区数据根据 步骤 2 查询到的分区,调度程序向这些分区发起回滚请求,回滚当前事务在这些分区上
sp2之后的所有修改。其中
p1、p3、p5上关于本事务的部分修改被回滚掉,p6上关于本事务的所有修改都被回滚掉。 -
更新事务参与者列表信息。
修改事务参与者列表,将
sql_no大于3的操作信息从事务参与者列表中删除,由于p6上的所有修改都被回滚掉,因此p6可以从参与者列表中删除。
-
删除无效的保存点。
用户执行
ROLLBACK to SAVEPOINT sp2成功后,系统会删除sp3和sp4的保存点,不允许再回滚到sp3和sp4。