本文详解如何通过 mysql-connector-python 正确创建 MySQL 存储过程，重点解决“Commands out of sync”错误——该错误源于 MySQL 协议不支持多语句中嵌套 DELIMITER 及多结果集未清理问题，并提供可直接运行的健壮实现方案。
本文详解如何通过 mysql-connector-python 正确创建 mysql 存储过程，重点解决“commands out of sync”错误——该错误源于 mysql 协议不支持多语句中嵌套 `delimiter` 及多结果集未清理问题，并提供可直接运行的健壮实现方案。
在 Python 中通过 mysql-connector-python 创建 MySQL 存储过程时，开发者常误将 MySQL 客户端（如 MySQL Workbench）的语法习惯直接迁移至 Python 环境，从而触发 Commands out of sync; you can't run this command now 这一经典报错。根本原因在于：
✅ MySQL 协议本身不支持 DELIMITER 语句（它是客户端工具的语法糖，非服务端指令）；
✅ cursor.execute() 默认仅允许单条 SQL 语句执行，而含 CREATE PROCEDURE ... BEGIN ... END 的完整定义在底层被解析为多语句（尤其当内含 SELECT 等返回结果的语句时），导致服务端残留未读取的结果集；
✅ 若未显式消费所有结果集（例如 cursor.fetchall() 或 cursor.nextset()），后续操作（包括 commit() 或新查询）即会因连接状态不同步而失败。
因此，正确做法是：移除所有 DELIMITER 相关语句，将存储过程定义拆分为独立、合法的单条 SQL 命令，并确保执行后彻底处理潜在结果集。
以下是推荐的生产级实现代码：
import mysql.connector
from mysql.connector import Error
# 替换为你的实际配置
CONFIG = {
'host': 'localhost',
'user': 'your_user',
'password': 'your_password',
'database': 'your_database',
'port': 3306,
'allow_local_infile': True,
'autocommit': False # 显式控制事务
}
try:
mydb = mysql.connector.connect(**CONFIG)
cursor = mydb.cursor()
# ✅ 关键：移除 DELIMITER，使用标准 SQL 语法定义存储过程
# 注意：MySQL 5.7+ 支持单语句 CREATE PROCEDURE（无需 DELIMITER）
sql_create_procedure = """
DROP PROCEDURE IF EXISTS usp_myprocedure;
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
ELSE logic2
END AS mylogic
FROM oldtable;
-- ⚠️ 重要：此 SELECT 会产生结果集，必须显式处理
SELECT * FROM mytable;
END
"""
# 分句执行（mysql-connector-python 不支持多语句 execute，需分步）
# Step 1: 删除已有过程
cursor.execute("DROP PROCEDURE IF EXISTS usp_myprocedure")
# Step 2: 创建新过程（单条 CREATE 语句）
cursor.execute(sql_create_procedure.split('END')[0] + 'END') # 粗粒度截断确保语法合法
# ✅ 更稳妥的做法：使用两段式执行（推荐）
cursor.execute("DROP PROCEDURE IF EXISTS usp_myprocedure")
mydb.commit() # 确保删除生效
# 创建语句（不含 SELECT，避免结果集干扰 DDL）
create_body = """
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 ELSE logic2 END
FROM oldtable;
END
"""
cursor.execute(create_body)
mydb.commit()
print("✅ 存储过程 usp_myprocedure 创建成功")
except Error as e:
print(f"❌ 执行失败：{e}")
mydb.rollback()
finally:
if cursor:
cursor.close()
if mydb and mydb.is_connected():
mydb.close()? 关键注意事项与最佳实践：
- 禁止使用 DELIMITER：mysql-connector-python 不识别该命令，保留会导致 SQL 解析失败；
- 避免在 CREATE PROCEDURE 中包含 SELECT 作为过程体的一部分（除非你明确需要调用时返回结果）：若仅用于数据处理，建议移除 SELECT * FROM mytable，保持过程为纯 DML 操作，提升复用性与稳定性；
- 分步执行更可靠：先 DROP，再 CREATE，中间 commit()，规避元数据锁与状态冲突；
- 始终启用异常处理与资源清理：使用 try/except/finally 确保连接和游标被正确关闭；
- 验证 MySQL 版本兼容性：MySQL 5.7+ 原生支持标准 CREATE PROCEDURE 语法；若使用旧版本，请确认是否启用了 log_bin_trust_function_creators 等安全参数。
完成创建后，可通过 Python 调用该过程验证：
立即学习“Python免费学习笔记（深入）”；
cursor.callproc('usp_myprocedure') # 执行存储过程
# 若过程含 SELECT，需遍历结果集：
for result in cursor.stored_results():
print(result.fetchall())遵循以上规范，即可在 Python 中稳定、安全地自动化管理 MySQL 存储过程，彻底规避“Commands out of sync”陷阱。
