MySQL 存储过程

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

-- 判断是否有改存储过程，有就删除。
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

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

正在成长中