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

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

正在成长中

原文地址:https://www.cnblogs.com/qypx520/p/5856636.html