OceanBase SAVEPOINT

描述

SAVEPOINT 语句用来实现事务的部分回滚。

格式

1. 创建 savepoint：

SAVEPOINT spname

2. 回滚到 savepoint：

ROLLBACK [WORK] to [SAVEPOINT] spname

3. 删除 savepoint：

RELEASE SAVEPOINT spname

参数说明

• spname：指定 savepoint 的名称。savepoint 是事务范围内唯一的，一个 savepoint 会覆盖前一个同名的 savepoint。创建 savepoint 后可以将事务回滚到指定 savepoint，也可以使用 ​ROLLBACK​ 语句回滚整个事务。

举例

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

记录 savepoint

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

事务参与者列表

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

savepoint 回滚过程

1. 根据 savepoint 链表查询 spname 对应的 sql_no

假设用户执行 ROLLBACK to SAVEPOINT sp2，根据 savepoint 链表查询到 sp2 对应的 sql_no 为 3。

2. 根据事务参与者列表查询 sql_no 对应的 partition

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

3. 回滚分区数据

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

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

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



5. 删除无效的 savepoint

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