使用Flask-SQLAlchemy连接MySQL时遇查询中断连接问题求助

我之前也碰到过这个一模一样的头疼问题，哪怕配置了SQLALCHEMY_POOL_RECYCLE和pool_pre_ping还是踩坑，咱们一步步来排查和解决：

1. 确认MySQL端的超时配置是否匹配 #

首先得搞清楚你的MySQL服务器实际的超时时间，因为如果SQLALCHEMY_POOL_RECYCLE设置的值还是大于MySQL的wait_timeout或interactive_timeout，那还是会出问题。

登录MySQL执行以下命令查看当前值：

SHOW VARIABLES LIKE '%timeout';

重点看wait_timeout和interactive_timeout，确保你的SQLALCHEMY_POOL_RECYCLE设置的值比这两个小至少30秒（比如MySQL设了300秒，那你就设270秒），留个缓冲时间避免刚好卡在超时点上。

2. 确保SQLAlchemy的配置真正生效 #

有时候配置可能没被正确加载，尤其是如果你的Flask app是分模块初始化的，或者用了工厂模式，要确认配置是在创建SQLAlchemy实例之前设置的。

正确的配置顺序应该是这样的：

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
# 先设置所有数据库相关配置
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://user:pass@host/db'
app.config['SQLALCHEMY_POOL_RECYCLE'] = 270  # 小于MySQL的wait_timeout
app.config['SQLALCHEMY_POOL_PRE_PING'] = True
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False  # 可选，关闭不必要的追踪

db = SQLAlchemy(app)

如果用工厂函数，要确保在create_app()里先加载配置再初始化db。

3. 检查会话的手动管理情况 #

虽然Flask-SQLAlchemy默认会在请求结束时自动关闭会话，但如果你的代码里有手动创建会话、或者在非请求上下文（比如后台任务、定时脚本）里操作数据库，就可能出现会话没有被正确回收的情况。

比如在后台任务里，最好手动管理会话：

def background_task():
    try:
        # 手动创建会话
        session = db.session()
        # 执行查询操作
        result = session.query(Model).all()
        # 提交（如果有修改）
        session.commit()
    except Exception as e:
        session.rollback()
        raise e
    finally:
        # 确保会话关闭
        session.close()

另外，如果你在请求里手动调用了db.session.remove()，也要确保时机正确，不要提前关闭了会话导致后续查询出错。

4. 排查是否存在长查询或连接阻塞 #

有时候连接丢失不是因为超时，而是因为某个查询耗时太长，超过了MySQL的net_read_timeout或net_write_timeout。可以检查慢查询日志，看看有没有执行时间特别长的SQL：

开启MySQL慢查询日志后，执行命令查看：

SELECT * FROM mysql.slow_log;

如果有长查询，优化SQL语句（比如加索引、拆分大查询），或者调整MySQL的net_read_timeout和net_write_timeout值。

5. 测试连接池的有效性 #

可以写个简单的测试脚本，模拟长时间闲置后查询，看看是否还会报错：

import time
from your_app import app, db, Model

with app.app_context():
    # 第一次查询
    print(db.session.query(Model).first())
    # 等待超过MySQL的wait_timeout时间
    time.sleep(300)
    # 第二次查询
    print(db.session.query(Model).first())

如果第二次查询还是报错，说明pool_pre_ping可能没生效，这时候可以检查SQLAlchemy的版本，旧版本可能有pool_pre_ping的bug，建议升级到最新稳定版：

pip install --upgrade flask-sqlalchemy sqlalchemy

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