新聞中心
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í)行查詢的一般流程如下:
- 首先執(zhí)行 ?
SELECT? 語句部分,獲得查詢結(jié)果集。 - 對查詢結(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 |
需要加鎖的表。 |
網(wǎng)站標(biāo)題:創(chuàng)新互聯(lián)OceanBase教程:OceanBaseFORUPDATE
網(wǎng)址分享:http://m.fisionsoft.com.cn/article/dpdedpc.html


咨詢
建站咨詢
