云服务器MySQL存储过程API调用完整使用教程

一、存储过程与API调用概述

存储过程是一组为了完成特定功能的SQL语句集，经编译后存储在数据库中。在云服务器MySQL里使用存储过程，能减少重复SQL代码的编写，提升数据库执行效率。API调用则是通过应用程序与数据库的接口，触发存储过程执行，实现数据查询、插入等操作。简单来说，存储过程是“预先写好的任务脚本”，API调用是“触发这个脚本运行的按钮”。

二、创建存储过程

在云服务器MySQL中创建存储过程，核心工具是CREATE PROCEDURE语句。具体操作分三步：

1. 调整语句结束符
默认情况下，MySQL用分号（;）作为语句结束符，但存储过程内部可能包含多个分号，容易导致解析错误。这时需要用DELIMITER命令临时修改结束符，比如改为双斜杠（//）。

2. 编写存储过程主体
以查询指定用户信息的存储过程为例：

DELIMITER //
CREATE PROCEDURE GetUserInfo(IN user_id INT)
BEGIN
    SELECT * FROM users WHERE id = user_id;
END //
DELIMITER ;

这里IN表示user_id是输入参数，存储过程会根据传入的用户ID查询对应记录。

3. 执行创建
将上述代码复制到云服务器MySQL的客户端工具（如MySQL Workbench）中运行，就能在数据库里生成名为GetUserInfo的存储过程。

三、调用存储过程的API

不同编程语言可通过数据库连接库调用存储过程，以Python为例，使用mysql-connector-python库的步骤如下：

1. 连接数据库
需要填写云服务器MySQL的连接信息，包括主机地址、用户名、密码和数据库名：

import mysql.connector

mydb = mysql.connector.connect(
    host="your_cloud_server_host",
    user="your_username",
    password="your_password",
    database="your_database"
)

2. 调用存储过程
通过游标（cursor）的callproc方法触发存储过程，传入存储过程名和参数列表：

mycursor = mydb.cursor()
user_id = 1
mycursor.callproc('GetUserInfo', [user_id])

3. 获取并处理结果
存储过程执行后，通过stored_results()获取返回数据：

for result in mycursor.stored_results():
    print(result.fetchall())

最后记得关闭游标和数据库连接，释放资源。

四、存储过程的参数传递

存储过程的参数分三种类型：输入（IN）、输出（OUT）、输入输出（INOUT）。以统计用户数量的存储过程为例：

1. 存储过程定义

DELIMITER //
CREATE PROCEDURE GetUserCount(OUT user_count INT)
BEGIN
    SELECT COUNT(*) INTO user_count FROM users;
END //
DELIMITER ;

这里OUT表示user_count是输出参数，用于返回统计结果。

2. Python调用示例
调用时需预先定义输出参数的初始值，通过callproc方法获取返回值：

import mysql.connector

mydb = mysql.connector.connect(
    host="your_cloud_server_host",
    user="your_username",
    password="your_password",
    database="your_database"
)

mycursor = mydb.cursor()
output_params = [0]  # 初始化输出参数
result_args = mycursor.callproc('GetUserCount', output_params)
print("用户总数：", result_args[0])  # 输出参数值

mycursor.close()
mydb.close()

五、错误处理

实际调用中可能遇到数据库连接失败、存储过程不存在等问题，需要用异常捕获提升程序健壮性。Python示例如下：

import mysql.connector

try:
    mydb = mysql.connector.connect(
        host="your_cloud_server_host",
        user="your_username",
        password="your_password",
        database="your_database"
    )
    mycursor = mydb.cursor()
    user_id = 1
    mycursor.callproc('GetUserInfo', [user_id])
    for result in mycursor.stored_results():
        print(result.fetchall())
except mysql.connector.Error as err:
    print(f"操作失败，错误信息：{err}")
finally:
    if 'mycursor' in locals(): mycursor.close()
    if 'mydb' in locals(): mydb.close()

通过try-except捕获数据库异常，finally块确保连接及时关闭，避免资源泄露。