OceanBase FOR UPDATE

2021-06-29 17:42 更新

FOR UPDATE 算子用于對表中的數(shù)據(jù)進行加鎖操作。

OceanBase 數(shù)據(jù)庫支持的 FOR UPDATE 算子包括 FOR UPDATE 和 MULTI FOR UPDATE。

FOR UPDATE 算子執(zhí)行查詢的一般流程如下：

  1. 首先執(zhí)行 ?SELECT? 語句部分，獲得查詢結果集。
  2. 對查詢結果集相關的記錄進行加鎖操作。

FOR UPDATE

FOR UPDATE 用于對單表（或者單個分區(qū)）進行加鎖。

如下示例中，Q1 查詢是對 t1 表中滿足 c1 = 1 的行進行加鎖。這里 t1 表是一張單分區(qū)的表，所以 1 號算子生成了一個 FOR UPDATE 算子。

obclient>CREATE TABLE t1(c1 INT, c2 INT);
Query OK, 0 rows affected (0.12 sec)

obclient>CREATE TABLE t2(c1 INT, c2 INT);
Query OK, 0 rows affected (0.12 sec)

obclient>INSERT INTO t1 VALUES(1, 1);
Query OK, 0 rows affected (0.12 sec)

obclient>INSERT INTO t1 VALUES(2, 2);
Query OK, 1 rows affected (0.12 sec)

obclient>INSERT INTO t1 VALUES(3, 3);
Query OK, 1 rows affected (0.12 sec)

obclient>INSERT INTO t2 VALUES(1, 1);
Query OK, 1 rows affected (0.12 sec)

obclient>INSERT INTO t2 VALUES(2, 2);
Query OK, 1 rows affected (0.12 sec)

obclient>INSERT INTO t2 VALUES(3, 3);
Query OK, 1 rows affected (0.12 sec)

Q1: 
obclient> EXPLAIN SELECT * FROM t1 WHERE c1 = 1 FOR UPDATE\G;
*************************** 1. row ***************************
Query Plan:
=====================================
|ID|OPERATOR    |NAME|EST. ROWS|COST|
-------------------------------------
|0 |MATERIAL    |    |10       |856 |
|1 | FOR UPDATE |    |10       |836 |
|2 |  TABLE SCAN|T1  |10       |836 |
=====================================
Outputs & filters:
-------------------------------------
  0 - output([T1.C1], [T1.C2]), filter(nil)
  1 - output([T1.C1], [T1.C2]), filter(nil), lock tables(T1)
  2 - output([T1.C1], [T1.C2], [T1.__pk_increment]), filter([T1.C1 = 1]),
      access([T1.C1], [T1.C2], [T1.__pk_increment]), partitions(p0)

上述示例中，Q1 查詢的執(zhí)行計劃展示中的 outputs & filters 詳細列出了 FOR UPDATE 算子的輸出信息如下：

信息名稱

含義

output

該算子輸出的表達式。

filter

該算子上的過濾條件。

由于示例中 FOR UPDATE 算子沒有設置 filter，所以為 nil。

lock tables

需要加鎖的表。

MULTI FOR UPDATE

MULTI FOR UPDATE 用于對多表（或者多個分區(qū)）進行加鎖操作。

如下示例中，Q2 查詢是對 t1 和 t2 兩張表的數(shù)據(jù)進行加鎖，加鎖對象是滿足 c1 = 1 AND c1 = d1 的行。由于需要對多個表的行進行加鎖，因此 1 號算子是 MULTI FOR UPDATE。

obclient>CREATE TABLE t1 (c1 INT, c2 INT);
Query OK, 0 rows affected (0.12 sec)

obclient>CREATE TABLE t2 (d1 INT, d2 INT);
Query OK, 0 rows affected (0.12 sec)

obclient>EXPLAIN SELECT * FROM t1, t2 WHERE c1 = 1 AND c1 = d1 
                FOR UPDATE\G;
*************************** 1. row ***************************
Query Plan:
=====================================================
|ID|OPERATOR                    |NAME|EST. ROWS|COST|
-----------------------------------------------------
|0 |MATERIAL                    |    |10       |931 |
|1 | MULTI FOR UPDATE           |    |10       |895 |
|2 |  NESTED-LOOP JOIN CARTESIAN|    |10       |895 |
|3 |   TABLE GET                |T2  |1        |52  |
|4 |   TABLE SCAN               |T1  |10       |836 |
=====================================================
Outputs & filters:
-------------------------------------
  0 - output([T1.C1], [T1.C2], [T2.D1], [T2.D2]), filter(nil)
  1 - output([T1.C1], [T1.C2], [T2.D1], [T2.D2]), filter(nil), lock tables(T1, T2)
  2 - output([T1.C1], [T1.C2], [T2.D1], [T2.D2], [T1.__pk_increment]), filter(nil),
      conds(nil), nl_params_(nil)
  3 - output([T2.D1], [T2.D2]), filter(nil),
      access([T2.D1], [T2.D2]), partitions(p0)
  4 - output([T1.C1], [T1.C2], [T1.__pk_increment]), filter([T1.C1 = 1]),
      access([T1.C1], [T1.C2], [T1.__pk_increment]), partitions(p0)

上述示例中，Q2 查詢的執(zhí)行計劃展示中的 outputs & filters 詳細列出了 MULTI FOR UPDATE 算子的信息如下：

信息名稱

含義

output

該算子輸出的列。

filter

該算子上的過濾條件。

由于示例中 MULTI FOR UPDATE 算子沒有設置 filter，所以為 nil。

lock tables

需要加鎖的表。
以上內(nèi)容是否對您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號