MySQLdb调用存储过程与长名称的兼容性问题及解决方案

import MySQLdb
import sys

# 数据库连接信息（请根据您的实际情况修改）
DB_CONFIG = {
    'host': 'localhost',
    'user': 'root',
    'passwd': 'your_password',
    'db': 'test_db',
    'charset': 'utf8mb4'
}

# 创建一个连接和游标
conn = None
cursor = None
try:
    conn = MySQLdb.connect(**DB_CONFIG)
    cursor = conn.cursor()

    # --- 1. 设置：创建一个足够长的存储过程名称来触发问题 ---
    # 存储过程名称长度为62，则生成的变量名 '_long_proc_name_0' 将是 1+62+2=65 个字符，超过64
    long_proc_name = "a_very_long_procedure_name_that_is_exactly_62_characters_long_1234567890"
    print(f"创建存储过程: '{long_proc_name}' (长度: {len(long_proc_name)} 字符)")

    # 清理旧的存储过程（如果存在）
    cursor.execute(f"DROP PROCEDURE IF EXISTS `{long_proc_name}`;")
    conn.commit()

    # 创建一个带有一个IN参数的简单存储过程
    create_proc_sql = f"""
        CREATE PROCEDURE `{long_proc_name}`(IN p_input_value INT)
        BEGIN
            SELECT CONCAT('Hello from ', '{long_proc_name}', ' with value: ', p_input_value);
        END;
    """
    cursor.execute(create_proc_sql)
    conn.commit()
    print(f"存储过程 '{long_proc_name}' 创建成功。")

    # --- 2. 演示问题：使用 cursor.callproc() 调用（预期失败） ---
    print("\n--- 尝试使用 cursor.callproc() 调用存储过程 (预期失败) ---")
    try:
        # 此时，MySQLdb会尝试生成一个名为 '_a_very_long_procedure_name_that_is_exactly_62_characters_long_1234567890_0'
        # 的用户变量，其长度为65，超出MySQL的64字符限制。
        cursor.callproc(long_proc_name, (100,))
        # 如果有结果集，需要迭代处理
        for result in cursor.stored_results():
            print(f"callproc 结果: {result.fetchall()}")
        print("警告: callproc 意外成功，可能测试环境的MySQL版本或配置不同。")
    except MySQLdb.Error as e:
        print(f"捕获到预期错误: {e}")
        if "User variable name" in str(e) and "is illegal" in str(e):
            print("这是预期的3061错误，由生成的长变量名引起。")
        else:
            print("捕获到非预期的MySQL错误。")
    except Exception as e:
        print(f"捕获到非预期的Python错误: {e}")

    # --- 3. 演示解决方案：使用 cursor.execute("CALL ...") 调用（预期成功） ---
    print("\n--- 尝试使用 cursor.execute('CALL ...') 调用存储过程 (预期成功) ---")
    try:
        # 直接执行 CALL 语句，避免了 callproc 的内部变量生成机制
        cursor.execute(f"CALL `{long_proc_name}`(%s);", (200,))
        # 同样，如果有结果集，需要迭代处理
        for result in cursor.stored_results():
            print(f"execute('CALL...') 结果: {result.fetchall()}")
        print("cursor.execute('CALL...') 成功调用存储过程。")
    except MySQLdb.Error as e:
        print(f"使用 cursor.execute('CALL...') 调用时发生错误: {e}")
    except Exception as e:
        print(f"捕获到非预期的Python错误: {e}")

except MySQLdb.Error as e:
    print(f"数据库连接或操作失败: {e}")
    sys.exit(1)
finally:
    # 清理：删除创建的存储过程
    if cursor:
        try:
            cursor.execute(f"DROP PROCEDURE IF EXISTS `{long_proc_name}`;")
            conn.commit()
            print(f"\n存储过程 '{long_proc_name}' 已删除。")
        except MySQLdb.Error as e:
            print(f"清理失败，删除存储过程时发生错误: {e}")
    if conn:
        conn.close()
        print("数据库连接已关闭。")