首页 > 数据库技术 > 详细

MySQL 存储过程返回多个值

时间:2019-02-25 15:46:01      阅读:370      评论:0      收藏:0      [点我收藏+]

MySQL  存储过程返回多个值

 

在本教程中,您将学习如何编写/开发返回多个值的存储过程。

MySQL存储函数只返回一个值。要开发返回多个值的存储过程,需要使用带有INOUTOUT参数的存储过程。

返回多个值的存储过程示例

我们看看 orderinfo 表

技术分享图片

表中数据

技术分享图片

 

以下存储过程接受点买家姓名,并返回各个状态的订单总数。

 

-- 手动创建存储过程 CheckOrderStatus
use test;
DROP PROCEDURE IF EXISTS CountOrderByStatus;
DELIMITER $$
use test$$
CREATE PROCEDURE CheckOrderStatus(
IN cust_name VARCHAR(20),
OUT 50Count INT,
OUT 60Count INT,
OUT 80Count INT,
out 90Count INT)
BEGIN
-- 50Count
SELECT count(*) INTO 50Count
FROM orderinfo
WHERE buyer_name = cust_name
AND order_status = 50;

-- 60Count
SELECT count(*) INTO 50Count
FROM orderinfo
WHERE buyer_name = cust_name
AND order_status = 60;

-- 80Count
SELECT count(*) INTO 50Count
FROM orderinfo
WHERE buyer_name = cust_name
AND order_status = 80;

-- 90Count
SELECT count(*) INTO 50Count
FROM orderinfo
WHERE buyer_name = cust_name
AND order_status = 90;

END$$
DELIMITER ;

IN参数之外,存储过程还需要4个额外的OUT参数:50Count, 50Count, 50Count 和 50Count。 在存储过程中,使用带有COUNT函数SELECT语句根据订单状态获取相应的订单总数,并将其分配给相应的参数。

要使用CountOrderByStatus存储过程,可以传递客户名称和四个用户定义的变量来获取输出值。

执行存储过程后,使用SELECT语句输出变量值。

call CheckOrderStatus(哪吒,@50Count,@60Count,@80Count,@90Count);
SELECT @50Count,@60Count,@80Count,@90Count;

 技术分享图片

从Python调用返回多个值的存储过程

以下代码片段显示如何从Python程序中调用返回多个值的存储过程。 

import pymysql

def callProcedure1(name):
    ‘‘‘调用存储过程,
    输入参数:姓名,输出:统计状态数;
使用输出参数方式‘‘‘
    count1 = ‘‘
    count2 = ‘‘
    count3 = ‘‘
    count4 = ‘‘
    db = pymysql.connect(127.0.0.1,adil,helloyyj,test,3306,charset=UTF8)
    cur = db.cursor()
    # 调用    CheckOrderStatus    存储过程,传入4个参数
    cur.callproc(CheckOrderStatus, args= (name, count1, count2, count3,count4))
    # 以 python 固定格式获取返回的值:@_存储过程名_0, 第一个返回值
    t = cur.execute(SELECT @_CheckOrderStatus_0,@_CheckOrderStatus_1,@_CheckOrderStatus_2,@_CheckOrderStatus_3;)
    print(t)
    data = cur.fetchall()
    print(data)
    if data :
        for rec in data:
            for i in range(len(rec)):
                print(rec[i])
    cur.close()
    db.close()


def callProcedure12(name):
    ‘‘‘调用存储过程,
    输入参数:编号,在线时间,输出:帐号,密码;
    使用select返回记录方式‘‘‘

    db = pymysql.connect(127.0.0.1, adil, helloyyj, test1, 3306, charset=UTF8)

    cur =db.cursor()
    # 调用 存储过程
    cur.execute(call CheckOrderStatus1("哪吒",@50Count,@60Count,@80Count,@90Count))
    # 执行 select  获取 参数返回值
    t1 = cur.execute(SELECT @50Count,@60Count,@80Count,@90Count;)
    print(t1)
    data=cur.fetchall()
    print(data)
    if data :
        for rec in data:
            for i in range(len(rec)):
                print(rec[i])
    cur.close()
    db.close()


if __name__==__main__:

    # callProcedure1(‘哪吒‘)
    callProcedure12(哪吒)

遇到的问题:

技术分享图片

有上可知,程序执行成功了,但是有一个Warning。

Warning: (3719, "‘utf8‘ is currently an alias for the character set UTF8MB3, but will be an alias for UTF8MB4 in a future release. Please consider using UTF8MB4 in order to be unambiguous.")
  result = self._query(query)
# 3719,“3719:‘utf8‘目前是该别名的别名 字符集UTF8MB3,将来会被UTF8MB4取代 发布。请考虑使用UTF8MB4以明确无误。

所以新建了一个数据库 test1,字符集为:utf8mb4,如下。

 技术分享图片

再次创建存储过程 CheckOrderStatus1,执行程序即可,不在产生警告。

 

MySQL 存储过程返回多个值

原文:https://www.cnblogs.com/BlueSkyyj/p/10419772.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!