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

創(chuàng)新互聯(lián)公司長期為上千多家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊從業(yè)經(jīng)驗10年，關(guān)注不同地域、不同群體，并針對不同對象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺，與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為南芬企業(yè)提供專業(yè)的網(wǎng)站設(shè)計、網(wǎng)站制作，南芬網(wǎng)站改版等技術(shù)服務(wù)。擁有十載豐富建站經(jīng)驗和眾多成功案例,為您定制開發(fā)。

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

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

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

FOR UPDATE

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

如下示例中，Q1 查詢是對 t1 表中滿足 c1 = 1 的行進(jìn)行加鎖。這里 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 詳細(xì)列出了 FOR UPDATE 算子的輸出信息如下：

信息名稱	含義
output	該算子輸出的表達(dá)式。
filter	該算子上的過濾條件。 由于示例中 FOR UPDATE 算子沒有設(shè)置 filter，所以為 nil。
lock tables	需要加鎖的表。

MULTI FOR UPDATE

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

如下示例中，Q2 查詢是對 t1 和 t2 兩張表的數(shù)據(jù)進(jìn)行加鎖，加鎖對象是滿足 c1 = 1 AND c1 = d1 的行。由于需要對多個表的行進(jìn)行加鎖，因此 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 詳細(xì)列出了 MULTI FOR UPDATE 算子的信息如下：

信息名稱	含義
output	該算子輸出的列。
filter	該算子上的過濾條件。 由于示例中 MULTI FOR UPDATE 算子沒有設(shè)置 filter，所以為 nil。
lock tables	需要加鎖的表。

當(dāng)前標(biāo)題：創(chuàng)新互聯(lián)OceanBase教程：OceanBaseFORUPDATE
文章來源：http://uogjgqi.cn/article/dpdedpc.html