pymysql调用存储过程

视频版教程 Python操作Mysql数据库之pymysql模块技术

我们首先创建一个简单的存储过程

DELIMITER //

CREATE PROCEDURE test_add(m INT,n INT, OUT result INT)
BEGIN
SET result=m+n;

END; //
1
2
3
4
5
6
7

测试：

SET @s=0;
CALL test_add(1,2,@s);
SELECT @s
1
2
3

Pymysql调用存储过程实现：

from pymysql import Connection

con = None

try:
    # 创建数据库连接
    con = Connection(
        host="localhost",  # 主机名
        port=3306,  # 端口
        user="root",  # 账户
        password="123456",  # 密码
        database="db_python",  # 指定操作的数据库
        autocommit=True  # 设置自动提交
    )
    # 获取游标对象
    cursor = con.cursor()
    # 使用游标对象，调用存储过程
    cursor.execute("CALL test_add(1,2,@s);")
    cursor.execute("select @s;")
    result = cursor.fetchone()
    print(result[0])
    # 确认提交
    # con.commit()
except Exception as e:
    print("异常：", e)
finally:
    if con:
        # 关闭连接
        con.close()
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
29