mysql数据库中如何创建一个存储过程修改_Mysql事务

小小码 • 2022-12-27 09:30 • 代码基础 • 阅读 96

大家好，我是考100分的小小码，祝大家学习进步，加薪顺利呀。今天说一说mysql数据库中如何创建一个存储过程修改_Mysql事务,希望您对编程的造诣更进一步.

1、需求，手动给会员新增京币，并且添加分配日志，返回修改是否成功

CREATE DEFINER=`jszapi`@`%` PROCEDURE `p_allot_user_coin`(IN `_member_id` int,IN `_coin` int,OUT `_res` tinyint)
BEGIN
        /*
        用途：给会员手动分配京币
        作者：Mo
        创建时间：2019-12-16  
            
        参数：
        _member_id : 会员id
        _coin : 分配京币数量
        _res : 执行结果，1表示成功，0表示失败                  
        */ 
        DECLARE err INT DEFAULT 0; #是否有sql错误
        DECLARE timestampTmp int;#当前的时间戳  

        DECLARE memberSPIDCount INT DEFAULT 0;#会员id对应会员数(用于验证传入会员id是否有误)

        DECLARE memberTableUpdateCount INT DEFAULT 0;#更新t_members表影响的行数
        DECLARE allotTableInsertId INT DEFAULT 0; #插入t_coin_log表的自增id
        
        DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET err=1;#判断是否有SQL错误,全局
        
        #开启事务
        START TRANSACTION; 
        
        #赋值timestampTmp     
    　　 set timestampTmp=unix_timestamp();

        #判断传入会员id是否有误
        SELECT COUNT(1) INTO memberSPIDCount FROM t_members WHERE id = _member_id;
        
        IF memberSPIDCount = 0 THEN
    
            SET _res = 0;

        ELSE
            #更新
            UPDATE t_members    SET    jing_coin = jing_coin + _coin WHERE id = _member_id;

            #获取更新数
            SELECT    ROW_COUNT()    INTO    memberTableUpdateCount;
            IF    memberTableUpdateCount = 0 THEN
                SET err = 1;
            END    IF;

            #添加分配日志
            INSERT    INTO    t_coin_log(`member_id`,`coin`,`type`,`describe`,`create_time`)    VALUES(_member_id,_coin,3,"公司分配",timestampTmp);
            #获取插入的自增ID
            SELECT    @@IDENTITY    INTO    allotTableInsertId;
            IF    allotTableInsertId    = 0    THEN
                SET    err = 1;
            END    IF;

            #判断事务是否提交
            IF    err = 1    THEN
                SET    _res = 0;
                ROLLBACK;#回滚事务
            ELSE
                SET    _res = 1;
                COMMIT;#提交事务
            END    IF;

        END IF;
END

代码100分

2、查询，存储过程的调用：传入参数(IN)直接写需要传入的参数，传出参数(OUT)需要补全格式为 @变量名，如调用上述过程

代码100分#CALL 过程名(传入参数1,传入参数2,@传出变量）,res名称自己取
CALL p_allot_user_coin(3,100,@res);

3、结果，输出结果返回定义的修改状态_res值

mysql数据库中如何创建一个存储过程修改_Mysql事务

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至举报，一经查实，本站将立刻删除。
转载请注明出处: https://daima100.com/10472.html

mysql数据库中如何创建一个存储过程修改_Mysql事务

相关推荐

发表回复