• 一个Mysql 并发查询的问题
  • 发布于 2个月前
  • 348 热度
    5 评论
  • 远行de风
  • 0 粉丝 39 篇博客
  •   
在做审核业务流程中自定义了两张表,a 和 a_detail 。主要需求是子表所有记录都审核通过了,那么就去修改主表记录为审核通过。 但有可能会遇到最后两条记录同时审核成功,他们去查询当前子表审核记录的时候有可能对方还没提交,所以最终会修改主表失败。为了解决这个问题,就直接想到了添加索引后,利用 mysql 行锁加在主表的记录上,获取锁之后再去 count 。但是在操作过程中 在获取行锁之前添加了一句查询子表的 sql 导致结果不正确。请教下这是为什么?或者说请教下此业务有其他合适的解决方案吗?
CREATE TABLE `a` (
`uid` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '审核记录主表 guid',
`approval_status` int(11) NULL DEFAULT 1 COMMENT '审核状态(1:审核中,2:通过)',
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键 id',
PRIMARY KEY (`id`) USING BTREE,
INDEX `idx_guid`(`uid`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 22 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '审核记录主表' ROW_FORMAT = Dynamic;

-- ----------------------------
-- Records of a
-- ----------------------------
INSERT INTO `a` VALUES ('a1', 1, 1);
INSERT INTO `a` VALUES ('a2', 1, 2);



CREATE TABLE `a_detail` (
`approval_status` int(11) NULL DEFAULT 1 COMMENT '审核状态(1:审核中;2:通过)',
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键 id',
`auid` varchar(200) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE,
INDEX `idx_aid`(`auid`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 74 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '审核记录明细表' ROW_FORMAT = Dynamic;

-- ----------------------------
-- Records of a_detail
-- ----------------------------
INSERT INTO `a_detail` VALUES (1, 1, 'a1');
INSERT INTO `a_detail` VALUES (1, 2, 'a1');
INSERT INTO `a_detail` VALUES (1, 3, 'a2');
INSERT INTO `a_detail` VALUES (1, 4, 'a2');
会话一和 会话二 同时执行
SELECT @@GLOBAL.TX_ISOLATION;

begin;

-- 查询字表明细记录(这部如果去除整个流程正常)-
SELECT * FROM a_detail WHERE id = 1

-- 根据索引利用行锁 锁定主表的记录--
SELECT * FROM `a` where uid='a1' for update;

-- 跟新字表状态为 2 审核通过--
UPDATE a_detail set approval_status = 2 WHERE id = 1 and approval_status = 1;

-- 查看子表是不是都已经审核通过了--
select count(0) from a_detail WHERE auid = 'a1' and approval_status!=2;
-- 接下来如果 count(0) 数量是 0 代表所有子记录都通过,则去修改主表状态 update a set approval_status=2 where uid='a1' --
commit;
SELECT @@GLOBAL.TX_ISOLATION;

begin;

-- 查询字表明细记录(这部如果去除整个流程正常)-
SELECT * FROM a_detail WHERE id = 2
-- 根据索引利用行锁 锁定主表的记录--
SELECT * FROM `a` where uid='a1' for update;
-- 跟新字表状态为 2 审核通过--
UPDATE a_detail set approval_status = 2 WHERE id = 2 and approval_status = 1;
-- 查看子表是不是都已经审核通过了--
select count(0) from a_detail WHERE auid = 'a1' and approval_status!=2;
-- 接下来如果 count(0) 数量是 0 代表所有子记录都通过,则去修改主表状态 update a set approval_status=2 where uid='a1' --

commit;

用户评论
  • 流年开花
  • 难道不是每次子审核通过就 直接跑这 2 句就行? 都不用在一个事务里.
    UPDATE a_detail set approval_status = 2 WHERE id = 2 and approval_status = 1;
    UPDATE a set approval_status=(select count(0)==0 from a_detail WHERE auid = 'a1' and approval_status!=2) where uid='a1'
  • 2024/6/4 18:13:00 [ 0 ] [ 0 ] 回复
  • 一个像秋天
  • -- 查询字表明细记录(这部如果去除整个流程正常)-
    SELECT * FROM a_detail WHERE id = 1
    这个东西会影响后面的查询吧,我估计表现就是这样的
    -- 查看子表是不是都已经审核通过了--
    select count(0) from a_detail WHERE auid = 'a1' and approval_status!=2;
    ---------------------------------------------------------------------------------------
    还是考虑 3 的做法,但是有个问题是如果代码不够牛逼,很容易错乱也就是说导致 u_count 少了。
    你这个事务太大了,这个事务就是个灾难 !

  • 2024/6/4 18:10:00 [ 0 ] [ 0 ] 回复
  • 人走茶凉
  • 尽量不要用存储过程/触发器什么的,出现问题调试起来非常麻烦
    鉴于你这个问题,可以考虑在主表里面 加两字段 count ,u_count 。
    每次更新 u_count 的时候,使用 u_count=u_count+1
    然后再判断 u_count 是否=count ,来决定是否 审核通过
  • 2024/6/4 17:53:00 [ 0 ] [ 0 ] 回复
  • 勿笑疯狂
  • 浅薄看了点书,for update 用的是当前读,会刷新当前事务中读取到的数据版本。要不试试搞个分布式锁去确保同一时间只有一个可以操作到。
  • 2024/6/4 17:48:00 [ 0 ] [ 0 ] 回复