OceanBase SAVEPOINT

描述

SAVEPOINT 語句用來實(shí)現(xiàn)事務(wù)的部分回滾。

格式

1. 創(chuàng)建 savepoint：

SAVEPOINT spname

2. 回滾到 savepoint：

ROLLBACK [WORK] to [SAVEPOINT] spname

3. 刪除 savepoint：

RELEASE SAVEPOINT spname

參數(shù)說明

• spname：指定 savepoint 的名稱。savepoint 是事務(wù)范圍內(nèi)唯一的，一個 savepoint 會覆蓋前一個同名的 savepoint。創(chuàng)建 savepoint 后可以將事務(wù)回滾到指定 savepoint，也可以使用 ?ROLLBACK? 語句回滾整個事務(wù)。

舉例

假設(shè)一個事務(wù)執(zhí)行了如下語句：

記錄 savepoint

用戶在提交事務(wù)之前可以創(chuàng)建 savepoint，需要根據(jù) savepoint 創(chuàng)建的順序，將事務(wù)的 savepoint 串成鏈表。以上事務(wù)包含了 7 條 sql 和 4 個 savepoint，記錄 savepoint 的鏈表如下圖所示，其中每個節(jié)點(diǎn)記錄了<spname, sql_no>的映射關(guān)系：

事務(wù)參與者列表

事務(wù)為了支持回滾某條 sql 之后的所有修改，需要將每條語句涉及的參與者以及對應(yīng)的 sql_no 記錄下來，以上事務(wù)執(zhí)行了 7 條 sql，涉及 p1~p6 共 6 個 partition：

savepoint 回滾過程

1. 根據(jù) savepoint 鏈表查詢 spname 對應(yīng)的 sql_no

假設(shè)用戶執(zhí)行 ROLLBACK to SAVEPOINT sp2，根據(jù) savepoint 鏈表查詢到 sp2 對應(yīng)的 sql_no 為 3。

2. 根據(jù)事務(wù)參與者列表查詢 sql_no 對應(yīng)的 partition

根據(jù)事務(wù)參與者列表查詢到 sql_no 大于 3 的語句操作的分區(qū)涉及 p1、p3、p5、p6。

3. 回滾分區(qū)數(shù)據(jù)

根據(jù)第2步查詢到的分區(qū)，調(diào)度程序向這些分區(qū)發(fā)起回滾請求，回滾當(dāng)前事務(wù)在這些分區(qū)上 sp2 之后的所有修改。其中 p1、p3、p5 上關(guān)于本事務(wù)的部分修改被回滾掉，p6 上關(guān)于本事務(wù)的所有修改都被回滾掉。

4. 更新事務(wù)參與者列表信息

修改事務(wù)參與者列表，將 sql_no 大于 3 的操作信息從事務(wù)參與者列表中刪除，由于 p6 上的所有修改都被回滾掉，因此 p6 可以從參與者列表中刪除。



5. 刪除無效的 savepoint

用戶執(zhí)行 ROLLBACK to SAVEPOINT sp2 成功后，系統(tǒng)會刪除 sp3 和 sp4 的 savepoint，不允許再回滾到 sp3 和 sp4。