从一个例子入门Mysql储存过程
2024-08-24 03:04:25
例子
-- 秒杀执行存储过程
DELIMITER $$ -- 将分隔符; 转换为 $$
-- 定义存储过程
-- 参数: in 输入参数; out 输出参数
-- row_count():返回上一条修改类型sql(delete,insert,update)的影响行数
-- row_count: 0:未修改数据; >0:表示修改的行数; <0:sql错误/未执行修改sql
CREATE PROCEDURE `seckill`.`execute_seckill`
(in v_seckill_id bigint,in v_phone bigint,
in v_kill_time timestamp,out r_result int)--创建储存过程
BEGIN-- 开始执行
DECLARE insert_count int DEFAULT 0;-- 定义变量
START TRANSACTION;--开启事物管理
insert ignore into success_killed
(seckill_id,user_phone,create_time)
values (v_seckill_id,v_phone,v_kill_time);--执行insert语句
select row_count() into insert_count;--返回影响行数
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_seckill_id
and end_time > v_kill_time
and start_time < v_kill_time
and number > 0;--执行update语句
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;--结束IF语句
END;--结束储存过程
$$--结束sql
-- 存储过程定义结束
DELIMITER ;--还原分隔符为;
--
set @r_result=-3;--定义用户变量
-- 执行存储过程
call execute_seckill(1003,13502178891,now(),@r_result);
-- 获取结果
select @r_result;
-- 存储过程
-- 1:存储过程优化:事务行级锁持有的时间
-- 2:不要过度依赖存储过程
-- 3:简单的逻辑可以应用存储过程
-- 4:QPS:一个秒杀单6000/qps
1.储存过程参数
- IN:参数的值必须在调用存储过程时指定,在存储过程中修改该参数的值不能被返回,为默认值
- OUT:该值可在存储过程内部被改变,并可返回
- INOUT:调用时指定,并且可被改变和返回
- [IN|OUT|INOUT] 参数名 数据类型
- 比如:
IN number INT
- 例子:
DELIMITER //
CREATE PROCEDURE myproc(OUT s int)
BEGIN
SELECT COUNT(*) INTO s FROM students;
END
//
DELIMITER ;
2.Mybatis调用储存过程
<!-- statementType 声明指向的是什么类型,其中CALLABLE是执行存储过程和函数的-->
<select id="killByProcedure" parameterType="map" statementType="CALLABLE">
call execute_seckill(
#{seckillId,jdbcType=BIGINT,mode=IN},
#{phone,jdbcType=BIGINT,mode=IN},
#{killTime,jdbcType=TIMESTAMP,mode=IN},
#{result,jdbcType=INTEGER,mode=OUT}
)
</select>
最新文章
- SQL:指定名称查不到数据的衍伸~空格 换行符 回车符的批量处理
- “.”(十六进制值 0x00)是无效的字符解决方案
- 关于Hibernate XXX is not mapped 错误
- 【BZOJ-4547】小奇的集合 矩阵乘法 + 递推
- iOS和Android的app界面设计规范(转)
- BZOJ3653: 谈笑风生
- Yeoman
- hdu 2050
- CCClippingNode bug
- Application.Count.ToString()和Application[";count";].ToString()的区别
- UVA 1599 Ideal Path (HDU 3760)
- linux下自动同步internet时间
- 2015 多校联赛 ——HDU5334(构造)
- 记一个SwipeMenuListView侧滑删除错乱的Bug
- 微信公众号支付提示mch_id参数格式错误
- C# ArcEngine二次开发之动态图层
- CentOS-07安装Redis学习笔记
- ASP.NET -- WebForm -- 缓存Cache的使用
- 嵌入Python | 调用Python模块中无参数的函数
- linux 编译 &#39;aclocal-1.14&#39; is missing on your system
热门文章
- git 入门教程之github 教程
- Caused by:org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type ";"; available: expected at least 1 bean which qualifies as autowire candidate
- PL/SQL重新编译包无反应案例2
- C#-hello world(二)
- mssql sqlserver 模拟for循环的写法
- gif软件(ShareX)
- 为爱好舞蹈的人们做的软件,细究数据结构,操作系统,磁盘原理,用java/c/c++写一个开源 MP3助手
- python + MySql 基本操作
- redis常用命令及结构
- JavaScript原型链和继承