业务背景:sql
某公司开展活动,4个实体店,天天限量发放10个优惠券,供人们抢购。数据库
技术分析:并发
一旦涉及抢购,必然会引发并发问题,并且还尽可能保证程序的并发性,这就要求或者在程序中作同步,或者在数据库层次作同步。通常来讲,在程序端作同步(synchronize),会致使阻塞得很厉害。使用数据库同步,能够选择有行级锁的数据库以及提升事务隔离等级,但提升事务等级会将事务串行化(Serializable),严重下降程序并发。综上权衡,我选择了PHP+MySQL。以个人认知,Oracle与MySQL均可以,MSSQL却没找到相似功能。app
主要解决方法:spa
1.须要把实体店对应的优惠券数量以记录的形式呈现,表1:Max_Table( ID, storeID,apply_count ,apply_code)。表2:apply_form(apply_code,store_id,phone_numbe)该表主要记录哪一个用户用什么 手机号码申请了优惠券,优惠券码是什么。.net
2.建立数据库时要使用InnoDB存储引擎code
3.在数据库中建立存储过程,在存储过程当中使用事务,在事务中要先查询是否发放完毕,为避免多进程同时访问某记录中的数量而引发的问题,我使用for update。使用该语句,若事务A访问访问该记录时,事务B会阻塞,直到事务A完毕后,从而达到了<并转串>的操做。orm
如下是解决该问题的核心存储过程,其中有2个入参,1个出参。blog
[sql] view plain copy进程
- CREATE DEFINER=`sa`@`localhost` PROCEDURE `p_apply_code`(IN `p_store_id` varchar(30), IN `p_phone_number` varchar(20),OUT return_val varchar(30))
- BEGIN
- #Routine body goes here...
- declare p_apply_count int(4) default 0;
- declare encode_apply_code varchar(16) default '';
-
- start transaction ;//开始事务
- SELECT apply_count into p_apply_count FROM max_table WHERE store_id=p_store_id for update;
- if (p_apply_count =0 ) THEN
- insert into max_table(store_id,apply_count) values(p_store_id,0);
- end if;
- IF( p_apply_count<=9) THEN
-
- set encode_apply_code='优惠券码的生成规则',
- insert into apply_form(apply_code,store_id,phone_number) values(encode_apply_code,p_store_id,p_phone_number);
- update max_table set apply_count=apply_count+1 where store_id=p_store_id;
- set result=encode_apply_code2;
- END IF;
-
- set return_val=result ;
- commit; //提交事务,同时释放for update锁
-
- END
-
- 4.PHP调用MySQL存储过程
-
- $sql = 'call p_apply_code('."'$store_id',"."'$phonenumber',"."@return_val".'); ';
- $db->query($sql);
- $apply_code=$db->getOne('select @return_val');
- <pre></pre>
- <pre></pre>
- <pre></pre>
- <pre></pre>
- <pre></pre>