公告:欢迎访问,查看更多资源请点我^.^!            点我关闭广告
秒杀 存储过程编写 使用存储过程来优化 事务行级锁持有的时间
2017-07-13 22:46:38
616人阅读
评论(0)
分类:数据库
DELIMITER $$ -- 将默认换行分割符;换成$$

-- 定义存储过程
-- 参数:in 输入参数    out 输出参数
-- row_count():返回上一条修改类型sql(insert、update、delete)的影响行数
--      返回结果:0 未修改数据   >0 影响行数  <0 sql错误/未执行修改sqlCREATE PROCEDURE `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);
        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;
            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;        END IF;    END;
$$
-- 存储过程定义结束


-- 调用 存储过程DELIMITER ;set @r_result = -3;
-- mysql 中 执行存储过程
call execute_seckill(1003, 18701321850, now(), @r_result); 


java后台使用存储过程
service:(SeckillExecution是秒杀状态对象)
    public SeckillExecution executeSeckillProcedure(long seckillId, long     userPhone) {        
        Date killTime = new Date();        
        Map<String, Object> map = new HashMap<>();
        map.put("seckillId", seckillId);
        map.put("phone", userPhone); 
        map.put("killTime", killTime);
        map.put("result", null);
        secKillDao.killByProceduce(map);
        //获取result
        int result = MapUtils.getInteger(map, "result", -2);        
            if (result == 1) {
                //秒杀抢购成功           
                return 成功状态;
            } esle {            
                return 失败状态;
        }
    }
    
dao:    void killByProceduce(Map<String, Object> paramMap);

mybatis调用存储过程:
    <select id="killByProcedure" statementType="CALLABLE">
        call execute_seckill (            
            #{seckillId, jdbcType=BIGINT,mode=IN},
            #{phone, jdbcType=BIGINT,mode=IN},
            #{killTime, jdbcType=TIMESTAMP,mode=IN},
            #{result, jdbcType=BIGINT,mode=OUT}
        )
    </select>MapUtils的依赖:
    <dependency>
      <groupId>commons-collections</groupId>
      <artifactId>commons-collections</artifactId>
      <version>3.2.1</version>
    </dependency>


分享一下:
赞一下(1)
博主资料
博主头像
zc521106
文章:34
浏览:19899
文章分类
Java(12)
NoSql(112)
数据库(12)
前端(12)
阅读排行
Java基础知识
(12)
NoSql应用
(112)
数据库Oracle语法
(12)
前端常用工具类
(12)
java web项目
(12)
linux安装mysql
(12)
评论区
这篇文章怎么样?写点评论吧!
姓名:
邮箱:
有回复时通知我:
发表
回复【10.20.30.32】:
暂无评论,快抢沙发!
* 以上用户言论只代表其个人观点,不代表iBlog网站的观点或立场,如有任何疑问请随时联系管理员...