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

創(chuàng)新互聯(lián)公司長(zhǎng)期為上千多家客戶(hù)提供的網(wǎng)站建設(shè)服務(wù),團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年,關(guān)注不同地域、不同群體,并針對(duì)不同對(duì)象提供差異化的產(chǎn)品和服務(wù);打造開(kāi)放共贏平臺(tái),與合作伙伴共同營(yíng)造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為南芬企業(yè)提供專(zhuān)業(yè)的網(wǎng)站設(shè)計(jì)、網(wǎng)站制作,南芬網(wǎng)站改版等技術(shù)服務(wù)。擁有十載豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開(kāi)發(fā)。
OceanBase 數(shù)據(jù)庫(kù)支持的 FOR UPDATE 算子包括 FOR UPDATE 和 MULTI FOR UPDATE。
FOR UPDATE 算子執(zhí)行查詢(xún)的一般流程如下:
- 首先執(zhí)行 ?
SELECT? 語(yǔ)句部分,獲得查詢(xún)結(jié)果集。 - 對(duì)查詢(xún)結(jié)果集相關(guān)的記錄進(jìn)行加鎖操作。
FOR UPDATE
FOR UPDATE 用于對(duì)單表(或者單個(gè)分區(qū))進(jìn)行加鎖。
如下示例中,Q1 查詢(xún)是對(duì) t1 表中滿(mǎn)足 c1 = 1 的行進(jìn)行加鎖。這里 t1 表是一張單分區(qū)的表,所以 1 號(hào)算子生成了一個(gè) 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 查詢(xún)的執(zhí)行計(jì)劃展示中的 outputs & filters 詳細(xì)列出了 FOR UPDATE 算子的輸出信息如下:
|
信息名稱(chēng) |
含義 |
|---|---|
|
output |
該算子輸出的表達(dá)式。 |
|
filter |
該算子上的過(guò)濾條件。 由于示例中 FOR UPDATE 算子沒(méi)有設(shè)置 filter,所以為 nil。 |
|
lock tables |
需要加鎖的表。 |
MULTI FOR UPDATE
MULTI FOR UPDATE 用于對(duì)多表(或者多個(gè)分區(qū))進(jìn)行加鎖操作。
如下示例中,Q2 查詢(xún)是對(duì) t1 和 t2 兩張表的數(shù)據(jù)進(jìn)行加鎖,加鎖對(duì)象是滿(mǎn)足 c1 = 1 AND c1 = d1 的行。由于需要對(duì)多個(gè)表的行進(jìn)行加鎖,因此 1 號(hào)算子是 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 查詢(xún)的執(zhí)行計(jì)劃展示中的 outputs & filters 詳細(xì)列出了 MULTI FOR UPDATE 算子的信息如下:
|
信息名稱(chēng) |
含義 |
|---|---|
|
output |
該算子輸出的列。 |
|
filter |
該算子上的過(guò)濾條件。 由于示例中 MULTI FOR UPDATE 算子沒(méi)有設(shè)置 filter,所以為 nil。 |
|
lock tables |
需要加鎖的表。 |
文章題目:創(chuàng)新互聯(lián)OceanBase教程:OceanBaseFORUPDATE
本文來(lái)源:http://www.dlmjj.cn/article/dpdedpc.html


咨詢(xún)
建站咨詢(xún)
