问题背景:
假设MySQL数据库有一张会员表vip_member(InnoDB表),结构如下:
当一个会员想续买会员(只能续买1个月、3个月或6个月)时,必须满足以下业务要求:
•如果end_at早于当前时间,则设置start_at为当前时间,end_at为当前时间加上续买的月数
•如果end_at等于或晚于当前时间,则设置end_at=end_at+续买的月数
•续买后active_status必须为1(即被激活)
问题分析:
对于上面这种情况,我们一般会先SELECT查出这条记录,然后根据查出记录的end_at再UPDATE start_at和end_at,伪代码如下(为uid是1001的会员续1个月):
vipMember = SELECT * FROM vip_member WHERE uid=1001 LIMIT 1 # 查uid为1001的会员
if vipMember.end_at < NOW():
UPDATE vip_member SET start_at=NOW(), end_at=DATE_ADD(NOW(), INTERVAL 1 MONTH), active_status=1, updated_at=NOW() WHERE uid=1001
else:
UPDATE vip_member SET end_at=DATE_ADD(end_at, INTERVAL 1 MONTH), active_status=1, updated_at=NOW() WHERE uid=1001
假如同时有两个线程执行上面的代码,很显然存在“数据覆盖”问题(即一个是续1个月,一个续2个月,但最终可能只续了2个月,而不是加起来的3个月)。
解决方案:
A、我想到的第一种方案是把SELECT和UPDATE合成一条SQL,如下:
UPDATE vip_member
SET
start_at = CASE
WHEN end_at < NOW()
THEN NOW()
ELSE start_at
END,
end_at = CASE
WHEN end_at < NOW()
THEN DATE_ADD(NOW(), INTERVAL #duration:INTEGER# MONTH)
ELSE DATE_ADD(end_at, INTERVAL #duration:INTEGER# MONTH)
END,
active_status=1,
updated_at=NOW()
WHERE uid=#uid:BIGINT#
LIMIT 1;
So easy!
B、第二种方案:事务,即用一个事务来包裹上面的SELECT+UPDATE操作。
那么是否包上事务就万事大吉了呢?