MySQL中使用if not exists需要注意什么

78次阅读
没有评论

共计 1499 个字符,预计需要花费 4 分钟才能阅读完成。

丸趣 TV 小编给大家分享一下 MySQL 中使用 if not exists 需要注意什么,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!

环境 MySQL 5.6.14
事务隔离级别 读提交
事务的开启和结束由 JAVA 程序控制.

上次报死锁的过程, 抽象如下

delimitr $$

CREATE PROCEDURE `test_proc`(

 pid int

)

begin

 if not exists (select * from t where id=pid) then

 insert into t(id) values(pid);

 end if;

 

 update t set total=total+1 where id=pid;

end $$

delimiter ; 

死锁原因已经明白了,就是并发情况下,Insert 遇到排它锁, 则尝试加共享锁。
在最后 Update 的时候, 两个持有共享锁的连接, 都尝试申请排它锁, 则导致了死锁.

但是问题是 … 怎么会走到了最后一行的 Update 语句?
另外两个连接, 不是应该在 Insert 语句时报  Duplicate entry xx for key PRIMARY 错误吗?

问题应该出在这种结构里
if not exists (select * from t where id=pid) then
    xxx
end if;

使用 if not exists 模式, 真心要注意啊. 在这种结构里出现的异常, 不会报错, 而是直接跳出 IF 判断, 继续执行!!

实验准备

CREATE TABLE `t` (

 `id` int(11) NOT NULL,

 `total` int(11) NOT NULL DEFAULT 0 ,

 PRIMARY KEY (`id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

truncate table t;

drop procedure if exists test_proc;

delimiter $$

CREATE PROCEDURE `test_proc`(

 pid int,

 ptotal int

)

begin

 if not exists (select * from t where id=pid) then

 insert into t(id,total) value(pid,ptotal);

 update t set total=ptotal+1 where id=pid;

 end if;

 select ptotal+1; 

end $$

delimiter ;

打开三个客户端,分别执行过程

第一个客户端执行,并没有提交.
第二,第三客户端处于阻塞状态.
等第一个客户端提交,

第二个客户端返回 201
第三个客户端返回 301
且没有任何的报错信息.

三个客户端都提交之后,查看 T 表信息
只有一个记录,id 为 1,total 为 101

也就是说, 第二个, 第三个客户端, 在得到主键冲突的异常后, 没有报错, 没有继续执行 IF 块内剩下的语句, 而是直接跳出了 IF 块, 继续执行 IF 块外的语句!!

该报错的地方不报错, 在大段的存储过程中, 导致死锁还是小问题, 就怕引起数据的错乱, 而不自知.

针对这种情况, 如果有主键或者唯一约束, 我觉得干脆改为如下的方式.
delimiter $$
CREATE PROCEDURE `test_proc`(
 pid int,
 ptotal int
)
begin
 insert into t(id,total) value(pid,ptotal);
 update t set total=ptotal+1 where id=pid;
 select ptotal+1;
end $$
delimiter ;

看完了这篇文章,相信你对“MySQL 中使用 if not exists 需要注意什么”有了一定的了解,如果想了解更多相关知识,欢迎关注丸趣 TV 行业资讯频道,感谢各位的阅读!

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-07-26发表,共计1499字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)