开发者社区> 余二五> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

6Python全栈之路系列之MySQL存储过程

简介:
+关注继续查看

Python全栈之路系列之MySQL存储过程


存储过程是一个SQL语句集合,当主动去调用存储过程时,其中内部的SQL语句会按照逻辑执行。

存储过程过接收的参数

参数 描述
in 仅用于传入参数用
out 仅用于返回值用
inout 既可以传入又可以当作返回值

创建存储过程

创建一个简单的存储过程

1
2
3
4
5
6
7
8
9
10
11
12
13
-- 修改SQL语句的结束符为%
delimiter %
-- 创建这个存储过程先删除
DROP PROCEDURE IF EXISTS proc_p1 %
CREATE PROCEDURE proc_p1()
-- 开始
BEGIN
    -- SQL语句块
    select * from color;
-- 结束
END %
-- 把SQL语句的结束符改为;
delimiter ;

通过call调用存储过程

1
call proc_p1();

输出为

1
2
3
4
5
6
7
8
+-----+--------+
| nid | title  |
+-----+--------+
|   1 | red    |
|   2 | yellow |
+-----+--------+
rows in set (0.00 sec)
Query OK, 0 rows affected (0.01 sec)

删除存储过程

1
DROP PROCEDURE proc_p1;

实例

创建一个存储过程,接收一个参数,传入的参数就是显示数据的个数,

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
delimiter %
DROP PROCEDURE IF EXISTS proc_p1 %
create PROCEDURE proc_p1(
    -- i1就是传入的参数,传入的数据类型必须是int类型
    in i1 int
)
BEGIN
    -- 定义两个局部变量d1和d2,数据类型都为int,d1默认值为空,d2默认值为1
    DECLARE d1 int;
    DECLARE d2 int DEFAULT 1;
    -- d1的值等于传入过来的i1加上定义的局部变量d2的值
    SET d1 = i1 + d2;
    -- 查找person_info表中的nid大于d1的数据
    SELECT * FROM person_info WHERE nid > d1;
END %
delimiter ;

查询,括号内输入定义的参数

1
CALL proc_p1(4);

显示结果

1
2
3
4
5
6
7
8
9
10
+-----+------+------------------+-------------+----------+----------+---------+-----------+
| nid | name | email            | phone       | part_nid | position | caption | color_nid |
+-----+------+------------------+-------------+----------+----------+---------+-----------+
|   6 | w    | as@anshengme.com | 13800138000 |        5 | Python   | NULL    |      NULL |
|   9 | aa   | a@ansheng.me     | 13800138000 |        3 | DBA      | NULL    |         2 |
|  10 | b    | b.ansheng.me     | 13800138000 |        3 | DBA      | NULL    |         1 |
+-----+------+------------------+-------------+----------+----------+---------+-----------+
rows in set (0.00 sec)
 
Query OK, 0 rows affected (0.01 sec)

这次把nid大于5的数据全部输出出来了,传入的值是4,我们在内部让4+1了,所以就是大于5的数据.

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
delimiter %
DROP PROCEDURE IF EXISTS proc_p1 %
create PROCEDURE proc_p1(
    -- 接收了三个参数,类型都是int
    in i1 int,
    inout ii int,
    out i2 int
)
BEGIN
    -- 定义一个局部变量d2,默认值是3,数据类型为int
    DECLARE d2 int DEFAULT 3;
    -- ii = ii + 1
    set ii = ii + 1;
    -- 如果传入的i1等于1
    IF i1 = 1 THEN
        -- i2 = 100 + d2
        set i2 = 100 + d2;
    -- 如果传入的i1等于2
    ELSEIF i1 = 2 THEN
        -- i2 = 200 + d2
        set i2 = 200 + d2;
    -- 否则
    ELSE
        -- i2 = 1000 + d2
        set i2 = 1000 + d2;
    END IF;
END %
delimiter ;

查看数据

1
2
3
set @o = 5;
CALL proc_p1(1,@o,@u);
SELECT @o,@u;

显示的结果

1
2
3
4
5
6
+------+------+
| @o   | @u   |
+------+------+
|    6 |  103 |
+------+------+
1 row in set (0.00 sec)

使用pymysql模块操作存储过程

Python代码为:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
import pymysql
 
conn = pymysql.connect(host="127.0.0.1", port=3306, user='root', passwd='as', db="dbname")
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
 
# 执行存储过程
row = cursor.callproc("proc_p2",(1,2,3))
# 存储过程的查询结果
selc = cursor.fetchall()
print(selc)
# 获取存储过程返回
effect_row = cursor.execute('select @_proc_p2_0, @_proc_p2_1, @_proc_p2_2')
# 取存储过程返回值
result = cursor.fetchone()
print(result)
 
conn.commit()
cursor.close()
conn.close()

显示的结果

1
2
3
4
5
C:\Python\Python35\python.exe D:/PycharmProjects/pymysql_存储过程.py
[{'nid'1'name''man1'}, {'nid'2'name''man2'}, {'nid'3'name''man3'}]
{'@_proc_p2_1'3'@_proc_p2_0'1'@_proc_p2_2'103}
 
Process finished with exit code 0

存储过程使用into

into其实就是把一个select的执行结果当作另一个select的参数,例如下面的实例:

1
2
3
4
5
6
7
8
9
10
11
12
delimiter %
DROP PROCEDURE IF EXISTS proc_p2 %
CREATE PROCEDURE proc_p2()
BEGIN
    -- 定义一个局部变量n,类型为int
    DECLARE n int;
    -- 获取color_nid = 2的数据并赋值给n
    SELECT color_nid into n FROM person_info where color_nid = 2;
    -- 输出nid = n的数据
    SELECT * from color WHERE nid = n;
END %
delimiter ;

执行

call proc_p2();

结果

1
2
3
4
5
6
7
8
+-----+--------+
| nid | title  |
+-----+--------+
|   2 | yellow |
+-----+--------+
1 row in set (0.00 sec)
 
Query OK, 0 rows affected (0.01 sec)









本文转自 Edenwy  51CTO博客,原文链接:http://blog.51cto.com/edeny/1925908,如需转载请自行联系原作者

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Python编程:使用os.urandom生成Flask的SECRET_KEY
Python编程:使用os.urandom生成Flask的SECRET_KEY
12 0
Python编程:使用os.urandom生成Flask的SECRET_KEY
Python编程:使用os.urandom生成Flask的SECRET_KEY
12 0
python编程-15:图形库的应用方法graphics
python编程-15:图形库的应用方法graphics
10 0
Python编程:Flask或者Jinja2时间格式化
Jinja2 模板支持python函数,直接使用事件对象的方法 格式化即可
10 0
Python编程:Flask数据库扩展Flask-SQLAlchemy
Python编程:Flask数据库扩展Flask-SQLAlchemy
73 0
+关注
20376
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载