本文详解在 python 中通过 mysql-connector-python 创建 mysql 存储过程的正确方法，重点解决“commands out of sync”错误，说明为何不能使用 delimiter 语句、如何规避多结果集冲突，并提供可直接运行的安全示例。
本文详解在 python 中通过 mysql-connector-python 创建 mysql 存储过程的正确方法，重点解决“commands out of sync”错误，说明为何不能使用 delimiter 语句、如何规避多结果集冲突，并提供可直接运行的安全示例。
在使用 mysql-connector-python 从 Python 动态创建 MySQL 存储过程时，一个常见且令人困惑的错误是：
mysql.connector.errors.InternalError: Commands out of sync; you can't run this command now.
该错误并非源于 SQL 逻辑错误，而是由 MySQL 协议与 Python 驱动的交互机制导致：MySQL 客户端（包括 mysql-connector）不支持在单条 cursor.execute() 中执行含 DELIMITER 的复合语句，也不支持一次发送多条以分号分隔、且内部含多个结果集（如 SELECT）的语句块。而你在 Workbench 中能成功执行，是因为 GUI 工具自动处理了分隔符解析、多结果集消费及协议状态重置——Python 驱动则需显式管理。
✅ 正确做法：移除 DELIMITER，分步执行（推荐）
MySQL 5.7+ 原生支持在 CREATE PROCEDURE 语句中直接使用分号作为语句结束符（无需 DELIMITER // ... END //），前提是整个定义作为单条语句提交。此时，驱动仅需解析一条 DDL 命令，避免协议同步混乱。
以下是经过验证的生产级写法：
让 macOS 自动化像说话一样简单 —— 用代码控制你的 Mac，无需学习 AppleScript 系统要求 macOS 14+ (Sonoma) Python 3.9+ 需要开启：辅助功能 + 屏幕录制权限
立即学习“Python免费学习笔记（深入）”；
import mysql.connector
# 连接配置（请替换为实际值）
config = {
'host': 'localhost',
'user': 'your_user',
'password': 'your_password',
'database': 'your_db',
'port': 3306,
'allow_local_infile': True,
'autocommit': False # 显式控制事务更安全
}
mydb = mysql.connector.connect(**config)
cursor = mydb.cursor()
# ✅ 关键：移除 DELIMITER，用标准分号结束；DROP 和 CREATE 分开执行
drop_proc = "DROP PROCEDURE IF EXISTS usp_myprocedure;"
create_proc = """
CREATE PROCEDURE usp_myprocedure()
BEGIN
TRUNCATE TABLE mytable;
INSERT INTO mytable (col1, col2, col3, col4, mylogic)
SELECT
col1,
col2,
col3,
col4,
CASE
WHEN New_col = '%_%' THEN 'logic1_result' -- 示例逻辑，请替换为真实表达式
ELSE 'logic2_result'
END AS mylogic
FROM oldtable;
SELECT * FROM mytable; -- 注意：此 SELECT 在调用时返回结果集，但创建时不触发
END;
"""
try:
cursor.execute(drop_proc)
cursor.execute(create_proc) # 单条 CREATE 语句，无 DELIMITER，安全
mydb.commit()
print("✅ 存储过程 usp_myprocedure 创建成功")
except mysql.connector.Error as e:
mydb.rollback()
print(f"❌ 创建失败：{e}")
finally:
cursor.close()
mydb.close()⚠️ 重要注意事项
- DELIMITER 是客户端指令，非 SQL 标准语法：mysql-connector-python 等驱动不解析 DELIMITER，直接将其传给服务器会导致语法错误或协议错位。
- 避免在 CREATE PROCEDURE 中嵌入 SELECT 作为副作用：虽然语法允许，但该 SELECT 仅在后续调用 CALL usp_myprocedure() 时才执行并返回结果集，创建阶段不会触发。若需验证逻辑，应在 CALL 后用 cursor.fetchall() 获取。
- 批量语句必须逐条执行：即使逻辑上关联（如 DROP + CREATE），也必须拆分为独立 cursor.execute() 调用，不可拼接为一长串用分号连接的字符串。
- 始终显式关闭资源：使用 try/finally 或上下文管理器（with）确保 cursor 和 connection 及时释放，防止连接泄漏。
- 生产环境建议启用 autocommit=False：对 DDL 操作（如 CREATE PROCEDURE）MySQL 默认自动提交，但显式控制可提升可测试性与错误回滚能力。
? 验证与调用示例
创建成功后，可通过以下方式验证并调用：
# 重新连接（或复用已有连接）
cursor.execute("CALL usp_myprocedure();")
results = cursor.fetchall()
print("Procedure output:", results)? 提示：若存储过程中含多个 SELECT，需配合 cursor.nextset() 循环读取所有结果集，否则仍可能触发 “Commands out of sync”。
遵循以上规范，即可稳定、高效地在 Python 应用中动态管理 MySQL 存储过程，彻底规避协议同步类异常。
