基于postgresql行级锁for update测试-6ren

基于postgresql行级锁for update测试

转载作者：qq735679552 更新时间：2022-09-27 22:32:09

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章基于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、不加锁演示

。

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测试

2、加锁演示（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;.

3、加锁演示（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字段。

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

原文链接：https://blog.csdn.net/shuoyu816/article/details/80086810 。

最后此篇关于基于postgresql行级锁for update测试的文章就讲到这里了,如果你想了解更多关于基于postgresql行级锁for update测试的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

文章推荐： Python实现的用户登录系统功能示例

文章推荐： python中numpy的矩阵、多维数组的用法

文章推荐： mysql实现从导出数据的sql文件中只导入指定的一个表

文章推荐： MySQL之导出整个及单个表数据的操作

java:找不到主类:测试/测试。程序将会退出
我获得了一些源代码示例，我想测试一些功能。不幸的是，我在执行程序时遇到问题: 11:41:31 [linqus@ottsrvafq1 example]$ javac -g test/test.jav
r - 为什么两个ggplot对象通过all.equal()测试，但未通过same()测试？
我想测试ggplot生成的两个图是否相同。一种选择是在绘图对象上使用all.equal，但我宁愿进行更艰巨的测试以确保它们相同，这似乎是identical()为我提供的东西。但是，当我测试使用相同d
java - 以编程方式失败的 Maven 测试 JUnit5 测试
我确实使用 JUnit5 执行我的 Maven 测试，其中所有测试类都有 @ExtendWith({ProcessExtension.class}) 注释。如果是这种情况，此扩展必须根据特殊逻辑使测试
Node.js 编程工作流程 - 测试、代码、测试
在开始使用 Node.js 开发有用的东西之前，您的流程是什么？您是否在 VowJS、Expresso 上创建测试？你使用 Selenium 测试吗？什么时候？我有兴趣获得一个很好的工作流程来开发我
java - Mockito 测试 - 测试 write() 方法导致 NullPointerException
这个问题已经有答案了: What is a NullPointerException, and how do I fix it? (12 个回答) 已关闭 3 年前。基于示例here ，我尝试为我的
laravel - 测试 Vue.js 组件 - Laravel 测试
我正在考虑测试一些 Vue.js 组件，作为 Laravel 应用程序的一部分。所以，我有一个在 Blade 模板中使用并生成 GET 的组件。在 mounted 期间请求生命周期钩子(Hook)。假
c++ - 测试 t=测试(); C++98 中会发生什么？
考虑以下程序: #include struct Test { int a; }; int main() { Test t=Test(); std::cout<
c# - 为什么我应该同时进行单元测试和 Web 测试(而不仅仅是 Web 测试)？
我目前的立场是:如果我使用 web 测试(在我的例子中可能是通过 VS.NET'08 测试工具和 WatiN)以及代码覆盖率和广泛的数据来彻底测试我的 ASP.NET 应用程序，我应该不需要编写单独的
c# - 在测试 1、测试 10、测试 2 中对包含数字的字符串进行排序的好方法
我正在使用 C#、.NET 4.7 我有 3 个字符串，即。 [test.1, test.10, test.2] 我需要对它们进行排序以获得: test.1 test.2 test.10 我可能会得到
Android espresso 测试 - 测试 recyclerview 项目内的 View 是否可见
我有一个 ID 为“rv_list”的 RecyclerView。单击任何 RecyclerView 项目时，每个项目内都有一个可见的 id 为“star”的 View 。我想用 expresso
node.js - 使用 Jest 测试 firebase 函数时的 Flakey 测试
我正在使用 Jest 和模拟器测试 Firebase 函数，尽管这些测试可能来自竞争条件。所谓 flakey，我的意思是有时它们会通过，有时不会，即使在同一台机器上也是如此。测试和函数是用 Type
javascript - AngularJS 测试 - 使用 $http 和 then() 测试 AngularUI 的提前输入
我在测试我与 typeahead.js ( https://github.com/angular-ui/bootstrap/blob/master/src/typeahead/typeahead.js
ios - 测试 iOS 应用程序时，Teamcity Step 测试(命令行)失败
我正在尝试使用 Teamcity 自动运行测试，但似乎当代理编译项目时，它没有正确完成，因为当我运行运行测试之类的命令时，我收到以下错误: fatal error: 'Pushwoosh/PushNo
api - 测试 rest 或 graphql API 时如何运行 cucumber 测试
这是我第一次玩 cucumber ，还创建了一个测试和 API 的套件。我的问题是在测试 API 时是否需要运行它？例如我脑子里有这个，启动 express 服务器作为后台任务然后当它启动时(我
android - 将所有 android 测试(单元/集成/UI 测试)放入单个测试项目中是最佳做法吗？
我有我的主要应用程序项目，然后是我的测试的第二个项目。将所有类型的测试存储在该测试项目中是一种好的做法，还是应该将一些测试驻留在主应用程序项目中？我应该在我的主项目中保留 POJO JUnit(测试
ruby-on-rails - 用户 has_many 测试，测试 has_many 成绩。如何计算成绩？
我正在努力弄清楚如何实现这个计数。模型是用户、测试、等级用户 has_many 测试，测试 has_many 成绩。每个等级都有一个计算分数(strong_pass、pass、fail、stron
android - 使用 MockWebServer 测试 OkHttp 并使用 Buffer body 测试 MockResponse
我正在尝试测试一些涉及 OkHttp3 的下载代码，但不幸失败了。目标:测试下载图像文件并验证其是否有效。平台:安卓。此代码可在生产环境中运行，但测试代码没有任何意义。产品代码 class Fil
xamarin.ios - UI 测试，无法运行 iOS ui 测试 - 无法确定 X 的模拟器版本
当我想为 iOS 运行 UI 测试时，我收到以下消息: SetUp : System.Exception : Unable to determine simulator version for X 堆
ios - 在 iOS 中使用 Firebase Remote Config 测试/验证 A/B 测试
我正在使用 Firebase Remote Config 在 iOS 上设置 A/B 测试。一切都已设置完毕，我正在 iOS 应用程序中读取服务器端默认值。但是在多个模拟器上尝试，它们都读取了默认
javascript - 如何用 Jest 测试 asnyc 代码(或用 jsdom 测试 "image.onload")
[已编辑]:我已经用 promise 方式更改了我的代码。我正在写 React with this starter 由 facebook 创建，我是测试方面的新手。现在我有一个关于图像的组件，它有

qq735679552

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城