Python中pymysql正常但SQLAlchemy连接MySQL报TypeError问题

问题概况 #

使用pymysql可直接正常连接并操作MySQL，但通过SSHTunnelForwarder建立SSH隧道后，用SQLAlchemy连接执行查询时抛出错误：

TypeError: '>=' not supported between instances of 'NoneType' and 'tuple'

报错堆栈指向SQLAlchemy内部判断MySQL版本的代码：self.server_version_info >= (5, 7, 20)，说明server_version_info为None，即SQLAlchemy未能正确获取到MySQL服务器版本信息。

可能原因及解决方案 #

1. 确保SSH隧道完全初始化后再创建SQLAlchemy引擎 #

SSHTunnelForwarder进入with块后可能存在端口绑定延迟，导致SQLAlchemy创建引擎时隧道还未完全就绪。可以添加延迟或检查隧道状态：

import time
with SSHTunnelForwarder(
        (ssh_host, ssh_port),
        ssh_username=ssh_user,
        ssh_password=ssh_password,
        remote_bind_address=(mysql_host, mysql_port)
) as tunnel:
    # 等待隧道完全建立
    time.sleep(1)
    # 或循环检查隧道激活状态
    while not tunnel.is_active:
        time.sleep(0.1)
    
    db_url = f"mysql+pymysql://{mysql_user}:{mysql_password}@{tunnel.local_bind_host}:{tunnel.local_bind_port}"
    engine = create_engine(db_url)
    # 使用text()包裹查询（规范写法）
    from sqlalchemy import text
    result = engine.execute(text("SELECT * FROM <table_name>;")).fetchall()

2. 显式指定MySQL服务器版本 #

手动指定版本信息，避免SQLAlchemy自动探测失败：

db_url = f"mysql+pymysql://{mysql_user}:{mysql_password}@{tunnel.local_bind_host}:{tunnel.local_bind_port}"
# 替换为你的MySQL实际版本，例如5.7.30
engine = create_engine(db_url, connect_args={"server_version": "5.7.30"})

或者开启连接池预检查，确保连接有效性：

engine = create_engine(db_url, pool_pre_ping=True)

3. 检查SQLAlchemy与pymysql版本兼容性 #

部分版本组合可能存在适配问题：

• 若使用SQLAlchemy 1.4.x，建议搭配pymysql >= 1.0.0
• 若使用旧版SQLAlchemy（如1.3.x），可尝试降低pymysql版本至0.10.x

执行以下命令调整依赖版本：

# 升级依赖
pip install --upgrade sqlalchemy pymysql
# 或指定固定版本
pip install sqlalchemy==1.4.49 pymysql==1.1.0

4. 修正数据库URL的host配置 #

确认tunnel.local_bind_host的值，默认是127.0.0.1，部分环境可能绑定到0.0.0.0，可以显式写死127.0.0.1代替tunnel.local_bind_host：

db_url = f"mysql+pymysql://{mysql_user}:{mysql_password}@127.0.0.1:{tunnel.local_bind_port}"

5. 启用echo模式调试 #

开启SQLAlchemy的echo模式查看详细执行日志，排查连接过程中的隐藏问题：

engine = create_engine(db_url, echo=True)

内容的提问来源于stack exchange，提问作者Raghu