1. 程式人生 > 資料庫 >基於postgresql行級鎖for update測試

基於postgresql行級鎖for update測試

建立表:

CREATE TABLE db_user
(
 id character varying(50) NOT NULL,age integer,name character varying(100),roleid character varying,CONSTRAINT db_user_pkey PRIMARY KEY (id)
)

隨便插入幾條資料即可。

一、不加鎖演示

1、開啟一個postgreSQL的SQL Shell或pgAdmin的SQL編輯器視窗,執行:

begin;

select * from db_user where name='lisi';

輸出結果:

基於postgresql行級鎖for update測試

2、再開啟一個postgreSQL的SQL Shell或pgAdmin的SQL編輯器視窗,執行:

begin;

select * from db_user where name='lisi';

輸出結果:

基於postgresql行級鎖for update測試

二、加鎖演示(for update)

1、開啟一個postgreSQL的SQL Shell或pgAdmin的SQL編輯器視窗,執行:

begin;

select * from db_user where name='lisi' for update;

輸出結果:

基於postgresql行級鎖for update測試

2、再開啟一個postgreSQL的SQL Shell或pgAdmin的SQL編輯器視窗,執行:

begin;

select * from db_user where name='lisi' for update;

輸出結果:

基於postgresql行級鎖for update測試

查詢一直處於執行中狀態。

3、第一個視窗執行:

commit;

第二個視窗立即執行查詢操作,結果如下:

基於postgresql行級鎖for update測試

第二個視窗記得提交commit;。

三、加鎖演示(for update nowait)

1、開啟一個postgreSQL的SQL Shell或pgAdmin的SQL編輯器視窗,執行:

begin;

select * from db_user where name='lisi' for update nowait;

輸出結果:

基於postgresql行級鎖for update測試

2、再開啟一個postgreSQL的SQL Shell或pgAdmin的SQL編輯器視窗,執行:

begin;

select * from db_user where name='lisi' for update nowait;

輸出結果:

基於postgresql行級鎖for update測試

不會進行資源等待,返回錯誤資訊。

3、第一個視窗執行:

commit;

提交成功,資源鎖釋放。

總結:

for update nowait和 for update 都會對所查詢到得結果集進行加鎖,所不同的是,如果另外一個執行緒正在修改結果集中的資料,for update nowait 不會進行資源等待,只要發現結果集中有些資料被加鎖,立刻返回 “55P03錯誤,內容是無法在記錄上獲得鎖.

命令說明:

begin;--開啟事務

begin transaction;--開啟事務

commit;--提交

rollback;--回滾

set lock_timeout=5000;--設定超時時間

注意:

連表查詢加鎖時,不支援單邊連線形式,例如:

select u.*,r.* from db_user u left join db_role r on u.roleid=r.id for update;

支援以下形式,並鎖住了兩個表中關聯的資料:

select u.*,r.* from db_user u,db_role r where u.roleid=r.id for update;

補充:PostgreSQL select for update指定列(相容oracle)

我們可以使用select for update語句來指定鎖住某一張表,在oracle中我們可以在for update語句後指定某一列,用來單獨鎖定指定列的資料。

oracle例子:

建表:

SQL> create table t1(id int,c2 varchar(20),c3 int,c4 float,c5 float); 
Table created.
SQL> create table t2(id int,c6 int); 
Table created.
SQL> insert into t1 values (1,'SA_REP',1,100,1); 
1 row created.
SQL> insert into t1 values (1,'SA_REP123',1); 
1 row created.
SQL> insert into t2 values (1,2500);
1 row created.

查詢:

我們使用下列查詢用來只鎖住c4列。

SQL> SELECT e.c3,e.c4,e.c5 
 2   FROM t1 e JOIN t2 d 
  USING (id) 
  WHERE c2 = 'SA_REP' 
  AND c6 = 2500 
 3  4  5  6   FOR UPDATE OF e.c4 
 7   ORDER BY e.c3; 
    C3     C4     C5
---------- ---------- ----------
     1    100     1

PostgreSQL相容方法:

建表:

create table t1(id int,c2 text,c5 float); 
create table t2(id int,c6 int); 
insert into t1 values (1,1); 
insert into t1 values (1,1); 
insert into t2 values (1,2500);

pg中使用方法和oracle類似,只是需要將order by語法放到前面,並且將列名換成表名。

bill=# SELECT e.c3,e.c5 
bill-#  FROM t1 e JOIN t2 d 
bill-#  USING (id) 
bill-#  WHERE c2 = 'SA_REP' 
bill-#  AND c6 = 2500 
bill-#  ORDER BY e.c3
bill-#  FOR UPDATE OF e ;
 c3 | c4 | c5 
----+-----+----
 1 | 100 | 1
(1 row)

驗證:

我們可以驗證下pg中是否只鎖定了指定的行。

1、安裝pgrowlocks外掛

bill=# create extension pgrowlocks;

CREATE EXTENSION

2、觀察

t1表被鎖:

bill=# select * from pgrowlocks('t1'); 
 locked_row | locker | multi | xids |   modes   | pids 
------------+--------+-------+--------+----------------+--------
 (0,1)   |  1037 | f   | {1037} | {"For Update"} | {2022}
(1 row)

t2表沒有被鎖:

bill=# select * from pgrowlocks('t2');  
 locked_row | locker | multi | xids | modes | pids 
------------+--------+-------+------+-------+------
(0 rows)

我們還可以再看看t1表中具體被鎖住的資料:

bill=# SELECT * FROM t1 AS a,pgrowlocks('t1') AS p 
bill-#  WHERE p.locked_row = a.ctid; 
 id |  c2  | c3 | c4 | c5 | locked_row | locker | multi | xids |   modes   | pids 
----+--------+----+-----+----+------------+--------+-------+--------+----------------+--------
 1 | SA_REP | 1 | 100 | 1 | (0,1)   |  1037 | f   | {1037} | {"For Update"} | {2022}
(1 row)

除此之外,pg中for update子句還有其它的選項:

UPDATE – 當前事務可以改所有欄位

NO KEY UPDATE – 當前事務可以改除referenced KEY以外的欄位

SHARE – 其他事務不能改所有欄位

KEY SHARE – 其他事務不能改referenced KEY欄位

以上為個人經驗,希望能給大家一個參考,也希望大家多多支援我們。如有錯誤或未考慮完全的地方,望不吝賜教。