数据库

基于postgresql行级锁for update测试
数据库 2024/11/5 佚名
3 2

创建表：

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, 100, 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, c3 int, c4 float, c5 float); 
create table t2(id int, c6 int); 
insert into t1 values (1, 'SA_REP', 1, 100, 1); 
insert into t1 values (1, 'SA_REP123', 1, 100, 1); 
insert into t2 values (1, 2500);

pg中使用方法和oracle类似，只是需要将order by语法放到前面，并且将列名换成表名。

bill=# SELECT e.c3, e.c4, 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字段

以上为个人经验，希望能给大家一个参考，也希望大家多多支持。如有错误或未考虑完全的地方，望不吝赐教。

标签：
postgresql,行级锁,for,update
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
白云城资源网 Copyright www.dyhadc.com

评论“基于postgresql行级锁for update测试”

暂无“基于postgresql行级锁for update测试”评论...
www.dyhadc.com 白云城资源网
129,905影音资源
244,626技术资源
111,817软件资源
578,645站长资源
一句话新闻
一口气升级7个大模型SaaS应用，百度智能云：突出一个“开箱即用” - 2024/11/5

这一波大模型产业落地浪潮里，不少企业其实处在 “干瞪眼“的状态。

一种情况是，很多大模型产品看得见却摸不着，在台上一个个遥遥领先——今天Sora技精四座，明天英伟达的机器人又赢得满堂彩，可是到了台下一问：啥时候能用上啊？答曰：遥遥无期。

另一种情况是，企业想用上大模型，却又难免瞻前顾后——既要考虑场景融合，又得兼顾安全性，还要考虑打通现有系统，再加上各种部署成本和繁琐的采购流程……最后只能拂袖：罢了，再等等吧。

稳了！魔兽国服回归的3条重磅消息！官宣时间再确认！

昨天有一位朋友在大神群里分享，自己亚服账号被封号之后居然弹出了国服的封号信息对话框。

这里面让他访问的是一个国服的战网网址，com.cn和后面的zh都非常明白地表明这就是国服战网。

而他在复制这个网址并且进行登录之后，确实是网易的网址，也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情，因为以前都没有出现这样的情况，现在突然提示跳转到国服战网的网址，是不是说明了简体中文客户端已经开始进行更新了呢？

更新日志

友情链接

杰晶网络 DDR爱好者之家 南强小屋 黑松山资源网 白云城资源网 更多链接
白云城资源网 Copyright www.dyhadc.com