【问题标题】:"FOR UPDATE" v/s "LOCK IN SHARE MODE" : Allow concurrent threads to read updated "state" value of locked row“FOR UPDATE” v/s “LOCK IN SHARE MODE”:允许并发线程读取锁定行的更新“状态”值
【发布时间】:2012-01-27 17:17:35
【问题描述】:

我有以下场景:

  • 用户 X 从位置 lc1 登录到应用程序:调用它 Ulc1
  • 用户 X(被黑,或者他的一些朋友知道他的登录凭据,或者他只是从他机器上的不同浏览器登录等等。你明白了)同时从位置 lc2 登录: 称之为 Ulc2

我正在使用一个主 servlet:
- 从数据库池中获取连接
- 将自动提交设置为 false
- 执行通过应用层的命令:如果全部成功,则在“finally”语句中将 autocommit 设置为 true,并关闭连接。否则,如果发生异常,则回滚()。

在我的数据库 (mysql/innoDb) 中,我有一个“历史”表,其中包含行列:
id(主键) |用户名 |日期 |话题 |锁定

“locked”列的默认值为“false”,它用作标记特定行是否被锁定的标志。
每一行都特定于一个用户(从用户名列可以看出)

回到场景:
-->Ulc1 发送命令以更新他从数据库中获取日期“D”和主题“T”的历史记录。

-->Ulc2 将 same 命令发送到 update 数据库中 same 日期“D”和 same 的历史记录 主题“T”正好在同一时间。

我想实现一个 mysql/innoDB 锁定系统,该系统将使到达的任何线程都可以进行以下检查:

该行的列“锁定”是否正确?

  • 如果为真,则向用户返回一条消息“他已经在从另一个位置更新相同的数据”
  • 如果不是 true(即未锁定):将其标记为已锁定并更新,然后在完成后将锁定重置为 false。

这两种 mysql 锁定技术中的哪一种实际上会允许第二个到达的线程读取锁定列的“更新”值来决定要采取的 wt 操作?

我应该使用 “FOR更新” 还是“锁定共享模式”

这个场景解释了我想要完成的事情:
- Ulc1线程先到达:“锁定”列为假,将其设置为真并继续更新过程
- Ulc2 线程在 Ulc1 的事务仍在处理中时到达,即使行通过 innoDb 功能锁定,它也不必等待,而是实际上读取锁定列的“新”值,即“真”,等等实际上不必等到 Ulc1 事务提交来读取“锁定”列的值(无论如何,到那时该列的值已经被重置为 false)。

我对这两种类型的锁定机制不是很有经验,到目前为止我的理解是 LOCK IN SHARE MODE 允许其他事务读取锁定的行,而 FOR UPDATE 甚至不允许读取。但是这个读数会得到更新的值吗?或者第二个到达的线程必须等待第一个线程提交然后读取值?

感谢任何关于在这种情况下使用哪种锁定机制的建议。
另外,如果有更好的方法来“检查”该行是否已被锁定(除了使用真/假列标志),请告诉我。
谢谢

解决方案
(基于 @Darhazer's 答案的 Jdbc 伪代码示例)

表 : [ id(主键) |用户名 |日期 |话题 |锁定]

connection.setautocommit(false);
//transaction-1
PreparedStatement ps1 = "Select locked from tableName for update where id="key" and   locked=false);
ps1.executeQuery();

//transaction 2
PreparedStatement ps2 = "Update tableName set locked=true where id="key";
ps2.executeUpdate();
connection.setautocommit(true);// here we allow other transactions threads to see the new value

connection.setautocommit(false);
//transaction 3
PreparedStatement ps3 = "Update tableName set aField="Sthg" where id="key" And date="D" and topic="T";
ps3.executeUpdate();

// reset locked to false
 PreparedStatement ps4 = "Update tableName set locked=false where id="key";
ps4.executeUpdate();

//commit
connection.setautocommit(true);

【问题讨论】:

    标签: mysql jdbc concurrency innodb deadlock


    【解决方案1】:

    LOCK IN SHARE MODE 将允许第二个线程读取值,但实际值将是查询(已提交读取)或事务(可重复读取)开始之前的值(因为 MySQL 使用多版本控制) ; 并且第二个事务必须看到的内容由隔离级别定义)。因此,如果在读取时未提交第一个事务,则将读取旧值。

    在您的场景中,最好有 1 个事务使用 select for update 锁定记录,另一个事务处理记录并在提交/回滚时解锁记录。

    select for update 的第二个线程事务将等待第一个线程完成,然后读取实际值并决定不继续执行其他事务,而是通知用户该记录已被锁定。

    为避免死锁,请确保您使用唯一索引执行 select for update

    示例代码:

    connection.setautocommit(false);
    //transaction-1
    PreparedStatement ps1 = "Select locked from tableName for update where id="key" and   locked=false);
    ps1.executeQuery();
    
    //transaction 2
    PreparedStatement ps2 = "Update tableName set locked=true where id="key";
    ps2.executeUpdate();
    connection.setautocommit(true); // here we allow other transactions / threads to see the new value
    
    connection.setautocommit(false);
    //transaction 3
    PreparedStatement ps3 = "Update tableName set aField="Sthg" where id="key" And date="D" and topic="T";
    ps3.executeUpdate();
    
    // probably more queries
    
    // reset locked to false
     PreparedStatement ps4 = "Update tableName set locked=false where id="key";
    ps4.executeUpdate();
    
    //commit
    connection.setautocommit(true);
    

    【讨论】:

    • 感谢您的帮助。但我没有得到你提到第二个线程的部分:你的意思是第二个线程将能够读取列“锁定”的更新值,即使在记录被线程 1 解锁之前?
    • @shadesco 的想法是在您已经将其标记为真时不锁定锁定值,例如记录被锁定。将数据库中的锁定时间保持在最短并在应用程序中实施(如果您在整个事务期间锁定记录,则根本没有“锁定”值)。您也可以锁定记录,但在将更改提交到锁定列之后,其他事务将看到新值。
    • 我想我明白了你的意思,但我写了一个小的更新部分,问你一个问题,你能检查一下吗?
    • 在事务中使用.setAutoCommit而不是.commit是一种好方法吗?
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2015-10-31
    • 2015-12-25
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2020-12-17
    相关资源
    最近更新 更多