自己的一个小小的新的，写给大家。

-- 判断是否有改存储过程，有就删除。

DROP PROCEDURE IF EXISTS seckill.execute_seckill;

-- 执行秒杀的存储过程

DELIMITER $$ -- ；结尾改为$$

-- 定义存储过程

-- 参数：in输入参数，out输出参数

-- insert_count返回上一条修改类型sql的影响行数（delete,insert,update）

-- ROW_COUNT() : 0；标示未修改数据，>0：标示修改的行数，<0 标示sql错误/执行修改

CREATE PROCEDURE seckill.execute_seckill

(IN v_kill_id BIGINT,IN v_phone BIGINT,IN v_kill_time TIMESTAMP,OUT r_result INT)

BEGIN -- 开始存储过程

DECLARE insert_count INT DEFAULT 0; -- 新建一个变量，并赋值

START TRANSACTION; -- 启动一个事务

SELECT * FROM seckill;

SELECT FOUND_ROWS() INTO insert_count; -- 返回查询到的行数，并赋值给 变量。

INSERT IGNORE INTO success_killed (seckill_id,user_phone,create_time) VALUES (v_kill_id,v_phone,v_kill_time);

SELECT ROW_COUNT() INTO insert_count; -- 返回insert影响的行数，并赋值给 变量。

IF (insert_count = 0) THEN

ROLLBACK; -- 回滚

SET r_result = -1; -- 赋值

ELSEIF(insert_count < 0) THEN

ROLLBACK;

SET r_result = -2;

ELSE

UPDATE seckill SET number = number - 1 WHERE seckill_id = v_kill_id AND end_time > v_kill_time AND start_time < v_kill_time AND number>0;

SELECT ROW_COUNT() INTO insert_count;

IF(insert_count = 0) THEN

ROLLBACK;

SET r_result = 0;

ELSEIF (insert_count < 0) THEN

ROLLBACK;

SET r_result = -2;

ELSE

COMMIT; -- 提交

SET r_result = 1;

END IF; -- 结束if条件

END IF;

END; -- 存储过程结束

$$

-- 存储过程结束

DELIMITER ;

SET @r_result = -3; -- 新建一个变量

CALL execute_seckill (1000,15412375874,NOW(),@r_result); -- 调用存储过程

SELECT @r_result; -- 获取结果

-- 存储过程

-- 1：存储过程优化：事务行级锁持有的时间

-- 2：不要过度使用存储过程

-- 3：简单的逻辑可以应用存储过程

-- 4：OPS：一个秒杀6000/qps

 

 

----------------------------------------------

正在成长中