OceanBase 数据库支持的 FOR UPDATE 算子包括 FOR UPDATE 和 MULTI FOR UPDATE。

    FOR UPDATE 算子执行查询的一般流程如下:

    1. 首先执行 语句部分,获得查询结果集。

    2. 对查询结果集相关的记录进行加锁操作。

    FOR UPDATE 用于对单表(或者单个分区)进行加锁。

    如下示例中,Q1 查询是对 t1 表中满足 c1 = 1 的行进行加锁。这里 t1 表是一张单分区的表,所以 1 号算子生成了一个 FOR UPDATE 算子。

    上述示例中,Q1 查询的执行计划展示中的 outputs & filters 详细列出了 FOR UPDATE 算子的输出信息如下:

    MULTI FOR UPDATE

    MULTI FOR UPDATE 用于对多表(或者多个分区)进行加锁操作。

    1. obclient>CREATE TABLE t1 (c1 INT, c2 INT);
    2. Query OK, 0 rows affected (0.12 sec)
    3. obclient>CREATE TABLE t2 (d1 INT, d2 INT);
    4. Query OK, 0 rows affected (0.12 sec)
    5. obclient>EXPLAIN SELECT * FROM t1, t2 WHERE c1 = 1 AND c1 = d1
    6. *************************** 1. row ***************************
    7. Query Plan:
    8. =====================================================
    9. |ID|OPERATOR |NAME|EST. ROWS|COST|
    10. -----------------------------------------------------
    11. |0 |MATERIAL | |10 |931 |
    12. |1 | MULTI FOR UPDATE | |10 |895 |
    13. |2 | NESTED-LOOP JOIN CARTESIAN| |10 |895 |
    14. |3 | TABLE GET |T2 |1 |52 |
    15. Outputs & filters:
    16. -------------------------------------
    17. 0 - output([T1.C1], [T1.C2], [T2.D1], [T2.D2]), filter(nil)
    18. 1 - output([T1.C1], [T1.C2], [T2.D1], [T2.D2]), filter(nil), lock tables(T1, T2)
    19. 2 - output([T1.C1], [T1.C2], [T2.D1], [T2.D2], [T1.__pk_increment]), filter(nil),
    20. conds(nil), nl_params_(nil)
    21. 3 - output([T2.D1], [T2.D2]), filter(nil),
    22. access([T2.D1], [T2.D2]), partitions(p0)
    23. access([T1.C1], [T1.C2], [T1.__pk_increment]), partitions(p0)

    上述示例中,Q2 查询的执行计划展示中的 outputs & filters 详细列出了 MULTI FOR UPDATE 算子的信息如下:

    信息名称

    含义

    output

    该算子输出的列。

    filter

    该算子上的过滤条件。

    由于示例中 MULTI FOR UPDATE 算子没有设置 filter,所以为 nil。

    需要加锁的表。