这是一个创建于 724 天前的主题，其中的信息可能已经有所发展或是发生改变。
问题 1.：悲观锁 运行机制
目前无法理解的是 假设 pk_money= 1 ， 我每次运行都会+ 1 但是我没提交啊
不知道为什么他会每次 + 1 ,
不知道是我 sql 语法问题 还是啥 ？
难道每次运行的时候 会把没有提及的 sql 自动提交？ 但是我已经关闭了自动提交 。
问题 2: 我想把 set pk_money=pk_money+1 这个 pk_money 等于上面的查询结果 然后在+ 1 这个应该怎么写啊？ 同时是悲观锁。 怎么把 下面的 select 和 update 合并。
问题 3: 我不提交的话，我重新开个窗口 单独去运行
update user_basic_info set pk_money=pk_money+1 where uid=123456803;
是会被阻塞到超时。 说明这个悲观锁是起作用了。 但是不知道怎么解释第一个问题
set autocommit=0;
start transaction;
select `pk_money` from user_basic_info where uid=123456803 for update ;
update user_basic_info set pk_money=pk_money+1 where uid=123456803;
-- COMMIT;
不会放图片。。。。
set autocommit=0
> OK
> Time: 0.074s
start transaction
> OK
> Time: 0.077s
select `pk_money` from user_basic_info where uid=123456803 for update
> Affected rows: 0
> Time: 0.071s
update user_basic_info set pk_money=pk_money+1 where uid=123456803
> Affected rows: 1
> Time: 0.074s
-- COMMIT;
> OK
> Time: 0.071s
 |
1
rqxiao 2022-11-28 15:02:44 +08:00
mysql update 语句不是自带行锁吗（如果 where 的条件有索引的话）
|
|
4
rqxiao 2022-11-28 15:05:50 +08:00
set autocommit=0;
start transaction; update user_basic_info set pk_money=pk_money+1 where uid=123456803; COMMIT; 这样和你加了一句 for update 是一样的把 |
 |
5
hhhhhh123 OP @rqxiao 结果是一样的， 但是把 commit 注释 ， 在窗口一直运行重复的代码， 结果会自动+=1 。 这个问题是为什么？
|
|
6
hhhhhh123 OP @rqxiao 顺便请教一下。 为啥网上几乎所有的教程都是要写一个 select 语法 + for update 。
|
|
8
hhhhhh123 OP 百度了一下 个人感觉很像是 脏读。
事务并发调度的问题 1. 脏读（ dirty read ）：A 事务读取 B 事务尚未提交的更改数据，并在这个数据基础上操作。如果 B 事务回滚，那么 A 事务读到的数据根本不是合法的，称为脏读。在 oracle 中，由于有 version 控制，不会出现脏读。 2. 不可重复读（ unrepeatable read ）：A 事务读取了 B 事务已经提交的更改（或删除）数据。比如 A 事务第一次读取数据，然后 B 事务更改该数据并提交，A 事务再次读取数据，两次读取的数据不一样。 3. 幻读（ phantom read ）：A 事务读取了 B 事务已经提交的新增数据。注意和不可重复读的区别，这里是新增，不可重复读是更改（或删除）。这两种情况对策是不一样的，对于不可重复读，只需要采取行级锁防止该记录数据被更改或删除，然而对于幻读必须加表级锁，防止在这个表中新增一条数据。 4.第一类丢失更新：A 事务撤销时，把已提交的 B 事务的数据覆盖掉。 5.第二类丢失更新：A 事务提交时，把已提交的 B 事务的数据覆盖掉。 |
 |
9
xhinliang 2022-11-28 15:19:39 +08:00
问题 1.：悲观锁 运行机制 目前无法理解的是 假设 pk_money= 1 ， 我每次运行都会+ 1 但是我没提交啊
不知道为什么他会每次 + 1 , ---- 你虽然没提交，但是在你的 transaction 内已经可见了，没提交只是别的 transaction 内不可见而已。 不知道这样能理解么？ |
|
13
xhinliang 2022-11-28 15:24:44 +08:00
为啥网上几乎所有的教程都是要写一个 select 语法 + for update 。
----- 这个不是必须的。在业务上先「写一个 select 语法 + for update 」一般是先锁定一下这些行的数据，同时可以读到这些数据当前值，你上来就 update 也没问题的。 |
|
14
xhinliang 2022-11-28 15:25:43 +08:00
那你看看当前的隔离级别呢？不会是 read uncommitted 吧？
|
|
16
xhinliang 2022-11-28 15:28:42 +08:00
还有个疑问， 就算是脏读 也不应该更新数据到数据库吧？ 更新到数据库那不就持久化了？
------------ 什么叫更新到数据库，所有的写入都是更新到数据库的呀，只是别的 session 能不能看到而已，这不就是隔离级别的基本概念么？ |
|
17
hhhhhh123 OP @xhinliang ``` show variables like '%tx_isolation%';``` 返回结果是空 啥也没有 ，这种是什么
|
|
19
rqxiao 2022-11-28 15:31:29 +08:00
你是 MyISAM 引擎吗，MyISAM 引擎不支持数事物，不过还没用过 MyISAM
|
|
20
hhhhhh123 OP |
|
21
hhhhhh123 OP 是 InnoDB
|
 |
22
zhanglintc 2022-11-28 15:57:11 +08:00
@hhhhhh123 #20 你这个现象倒是很神奇。我`Distrib 5.5.60-MariaDB`的版本，反正没能再现出来你的现象。如果是`REPEATABLE-READ`状态，没有 commit 之前，其他窗口是看不到这个变更的。
----- > 问题 2: 我想把 set pk_money=pk_money+1 这个 pk_money 等于上面的查询结果 然后在+ 1 这个应该怎么写啊？ 同时是悲观锁。 怎么把 下面的 select 和 update 合并。 这个问题没看懂。 感觉你这个需求直接用 update 命令就行了：`set pk_money=pk_money+1`。不需要用到`select`命令，没有合并一说。 |
|
23
hhhhhh123 OP @zhanglintc 因为网上的教程都是先 select 在 update 我以为这是必要流程
|
 |
24
la2la 2022-11-28 21:44:14 +08:00
1. MySQL 的存储引擎
|
|
25
la2la 2022-11-28 21:46:24 +08:00
2. 设置的隔离级别
ps: 不要根据现象去推测原理，这种现象或许仅仅是原理的一种表现而已。现象是用来验证原理的。网上有关于 Innodb 引擎的源码级别的教程，看看锁的具体实现呗 |
|
26
zhanglintc 2022-11-28 22:02:33 +08:00
@hhhhhh123 #10 就这一点来说，我表示怀疑。感觉没有可能新窗口中会看到未 commit 的提交。
|
|
27
zhanglintc 2022-11-28 22:03:30 +08:00
对 10 楼的回复“新会话就是 + 1”表示怀疑
|
|
28
hhhhhh123 OP @zhanglintc 主要是不会贴图片， 不然我就吧图片贴上来。 确确实实+1 。 不过代码就不会。 我也很好奇。 理论上确实不应该拿到未提交数据且更新到数据中了
|
 |
29
Dlin 2022-11-29 09:17:51 +08:00  1
如果真有这种问题，肯定就不是你的问题了。
|
|
30
zhanglintc 2022-11-29 11:17:32 +08:00
@hhhhhh123 #28 图片要传到某个图床，然后在这边贴链接才行。
|
 |
31
raysonlu 2022-11-29 15:55:21 +08:00
关于“新会话就是 + 1”也表示怀疑，建议再认真测试一次，在 InnoDB 引擎的表，执行“不会放图片。。。。”后面的代码块的“COMMIT”之前，再确保开了新的会话，直接执行 select （不要 for update ）,能把图贴上来，或者语句+结果文字贴上来就行。这种试验，已经给多位新入职同事科普过了。
|
|
32
hhhhhh123 OP @raysonlu
session1 : SELECT pk_money FROM user_basic_info WHERE uid = 123456803; # pk_money= 496 session2: ``` BEGIN; set autocommit=0; select `pk_money` from user_basic_info where uid=123456803 for update ; update user_basic_info set pk_money=pk_money+1 where uid=123456803; # 这里没有 commit ``` 结果 ``` BEGIN > OK > Time: 0.047s set autocommit=0 > OK > Time: 0.045s select `pk_money` from user_basic_info where uid=123456803 for update > Affected rows: 0 > Time: 0.042s update user_basic_info set pk_money=pk_money+1 where uid=123456803 > Affected rows: 1 > Time: 0.044s ``` 再次运行 session1 session1 : SELECT pk_money FROM user_basic_info WHERE uid = 123456803; # pk_money= 497 |
 |
33
bruce0 2022-11-29 18:38:55 +08:00
不知道能不能对你起到帮助 https://www.jianshu.com/p/fe708aad6113
|
|
34
zhanglintc 2022-11-29 21:49:59 +08:00
@hhhhhh123 #32 你这俩 session ，是同一个 GUI 工具里的两个不同的 tab 吗？
|
|
35
zhanglintc 2022-11-29 22:05:08 +08:00
这俩“session”里分别执行`select CONNECTION_ID()`感觉会是同一个值？
|
|
36
Dlin 2022-11-29 23:07:52 +08:00
建议用命令行测试
|
|
37
hhhhhh123 OP @zhanglintc 是啊，navicat 工具 不同的窗口
|
|
38
hhhhhh123 OP @zhanglintc 不一样 一个 2744 一个 2741
|
|
40
hhhhhh123 OP @Dlin
你看看 我这语法有问题吗？ 应该是这样写的吧？ mysql> begin; set autocommit=0; SELECT pk_money FROM user_basic_info WHERE uid = 123456803 for update ; UPDATE user_basic_info set pk_money=pk_money+1 where uid =123456803; Query OK, 0 rows affected (0.00 sec) Query OK, 0 rows affected (0.00 sec) +----------+ | pk_money | +----------+ | 498 | +----------+ 1 row in set (0.00 sec) Query OK, 1 row affected (0.00 sec) Rows matched: 1 Changed: 1 Warnings: 0 mysql> select pk_money from user_basic_info where uid= 123456803; +----------+ | pk_money | +----------+ | 499 | +----------+ 1 row in set (0.00 sec) mysql> |
|
41
hhhhhh123 OP @Dlin mysql> select pk_money from user_basic_info where uid= 123456803;
+----------+ | pk_money | +----------+ | 499 | +----------+ 1 row in set (0.00 sec) mysql> begin; set autocommit=0; SELECT pk_money FROM user_basic_info WHERE uid = 123456803 for update ; UPDATE user_basic_info set pk_money=pk_money+1 where uid =123456803; Query OK, 0 rows affected (0.00 sec) Query OK, 0 rows affected (0.00 sec) +----------+ | pk_money | +----------+ | 499 | +----------+ 1 row in set (0.00 sec) Query OK, 1 row affected (0.00 sec) Rows matched: 1 Changed: 1 Warnings: 0 mysql> select pk_money from user_basic_info where uid= 123456803; +----------+ | pk_money | +----------+ | 500 | +----------+ 1 row in set (0.00 sec) mysql> |
|
42
hhhhhh123 OP @raysonlu 这个是一样的
mysql> select pk_money from user_basic_info where uid= 123456803; +----------+ | pk_money | +----------+ | 500 | +----------+ 1 row in set (0.00 sec) mysql> set autocommit=0; begin; SELECT pk_money FROM user_basic_info WHERE uid = 123456803 for update ; UPDATE user_basic_info set pk_money=pk_money+1 where uid =123456803; Query OK, 0 rows affected (0.00 sec) Query OK, 0 rows affected (0.00 sec) +----------+ | pk_money | +----------+ | 500 | +----------+ 1 row in set (0.00 sec) Query OK, 1 row affected (0.00 sec) Rows matched: 1 Changed: 1 Warnings: 0 mysql> select pk_money from user_basic_info where uid= 123456803; +----------+ | pk_money | +----------+ | 501 | +----------+ 1 row in set (0.00 sec) mysql> |
|
43
hhhhhh123 OP |
Select Language