当前位置：首页 > Python > 正文

Python MySQL callproc方法教程 - 调用数据库存储过程指南

LinZheng
Python
2025-07-29
284

Python MySQL callproc方法教程

使用callproc调用数据库存储过程的完整指南

为什么使用存储过程？

存储过程是预编译的SQL语句集合，存储在数据库中，具有以下优势：

提高性能 - 减少网络传输量
增强安全性 - 避免SQL注入攻击
简化复杂操作 - 封装业务逻辑
便于维护 - 逻辑集中存储在数据库中

Python的MySQL连接器提供了callproc()方法来调用存储过程并处理结果。

准备工作

在开始之前，请确保：

已安装MySQL数据库
已创建数据库和表
已安装Python MySQL连接器：pip install mysql-connector-python

创建示例存储过程

首先我们在MySQL中创建一个简单的存储过程：

DELIMITER //
CREATE PROCEDURE GetEmployeeDetails(IN emp_id INT)
BEGIN
    SELECT * FROM employees WHERE id = emp_id;
END //
DELIMITER ;

这个存储过程接收一个员工ID参数，返回该员工的所有信息。

使用callproc调用存储过程

以下是使用Python调用存储过程的完整示例：

import mysql.connector
from mysql.connector import Error

def call_get_employee_details(employee_id):
    try:
        # 建立数据库连接
        conn = mysql.connector.connect(
            host='localhost',
            database='company_db',
            user='your_username',
            password='your_password'
        )
        
        if conn.is_connected():
            print("成功连接到MySQL数据库")
            
            # 创建游标对象
            cursor = conn.cursor()
            
            # 调用存储过程
            args = [employee_id]
            cursor.callproc('GetEmployeeDetails', args)
            
            # 获取结果
            for result in cursor.stored_results():
                employees = result.fetchall()
                for employee in employees:
                    print(f"ID: {employee[0]}")
                    print(f"姓名: {employee[1]}")
                    print(f"职位: {employee[2]}")
                    print(f"薪资: {employee[3]}")
                    print("-" * 30)
            
    except Error as e:
        print(f"数据库错误: {e}")
    finally:
        # 关闭连接
        if conn and conn.is_connected():
            cursor.close()
            conn.close()
            print("数据库连接已关闭")

# 调用函数查询ID为101的员工
call_get_employee_details(101)

处理输出参数

对于带有输出参数的存储过程，可以这样处理：

首先创建带输出参数的存储过程：

DELIMITER //
CREATE PROCEDURE GetEmployeeCountByDept(
    IN dept_name VARCHAR(50), 
    OUT employee_count INT
)
BEGIN
    SELECT COUNT(*) INTO employee_count 
    FROM employees 
    WHERE department = dept_name;
END //
DELIMITER ;

Python调用代码：

def call_get_employee_count(department):
    try:
        conn = mysql.connector.connect( ... )
        cursor = conn.cursor()
        
        # 调用带输出参数的存储过程
        args = [department, 0]  # 0是输出参数的占位值
        
        cursor.callproc('GetEmployeeCountByDept', args)
        
        # 获取输出参数值
        employee_count = cursor.fetchone()[0]
        print(f"{department}部门的员工总数: {employee_count}")
        
    except Error as e:
        print(f"数据库错误: {e}")
    finally:
        if conn.is_connected():
            cursor.close()
            conn.close()