Python连接MySQL怎么做_PyMySQL与SQLAlchemy配置连接池

小伙伴们有没有觉得学习文章很有意思？有意思就对了！今天就给大家带来《Python连接MySQL怎么做_PyMySQL与SQLAlchemy配置连接池》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

PyMySQL连接失败主因是认证插件不兼容、网络不通或驱动版本低；SQLAlchemy需配pool_pre_ping、pool_recycle防stale连接；连接池大小与事务管理不当易致连接泄露或超限。

PyMySQL直连MySQL，连不上先看这三件事

PyMySQL连接失败，八成卡在认证、网络或驱动版本上。它不依赖系统 MySQL 客户端，但对 mysql_native_password 插件和 TLS 配置很敏感。

• 确认 MySQL 服务已启动且允许远程连接：SELECT host, user FROM mysql.user; 看是否有 % 或对应 IP 的用户
• 检查用户认证插件：5.7+ 默认可能用 caching_sha2_password，PyMySQL 1.0+ 才原生支持；旧版建议执行 ALTER USER 'user'@'%' IDENTIFIED WITH mysql_native_password BY 'pwd';
• 防火墙和云厂商安全组必须放行 3306 端口，本地测试可先用 telnet host 3306 验证通路

SQLAlchemy + PyMySQL 配置连接池，别只写 engine = create_engine(...)

默认不启用连接池复用，短时高频请求会反复建连，超时或报 Too many connections。关键在参数组合，不是加个 pool_size 就完事。

• pool_pre_ping=True 必开：每次取连接前发 SELECT 1 检活，避免拿到被服务端断掉的 stale 连接
• pool_recycle=3600 推荐设：强制连接每小时重连一次，防止 MySQL 的 wait_timeout（默认 8 小时）导致中间断连
• 慎用 pool_timeout：设太小（如 5）会让等待连接的请求直接抛 TimeoutError；设太大（如 30）又拖慢故障感知；一般 10–20 足够
• 示例连接串：mysql+pymysql://user:pwd@host:3306/db?charset=utf8mb4，注意 charset 参数影响 emoji 存储

连接池满、查询卡住？查清是应用层阻塞还是数据库瓶颈

现象是请求 hang 住、日志停在 acquiring connection from pool，但不一定是池子太小——可能是连接没归还，或 DB 已扛不住。

• 先看 SQLAlchemy 日志：加 echo=True 和 logging.basicConfig(level=logging.INFO)，观察是否所有 connection.execute() 都有对应 connection.close() 或上下文退出
• 查 MySQL 当前连接：SHOW PROCESSLIST;，重点看 State 是 Sleep 还是 Locked 或 Sending data；大量 Sleep 说明连接没释放
• PyMySQL 默认不自动 commit，engine.execute() 执行 DML 后必须 conn.commit() 或用 session，否则连接一直被事务占用
• 连接池大小不是越大越好：pool_size=10 + max_overflow=20 是较稳配置；盲目调到 50 容易打爆 MySQL 的 max_connections

PyMySQL 和 SQLAlchemy 一起用，cursor 和 session 别混着关

PyMySQL 的 cursor 和 SQLAlchemy 的 Connection / Session 生命周期不同，手动关错对象会导致连接泄露或重复关闭异常。

• 用 engine.connect() 得到 Connection 对象，必须显式调 .close() 或用 with 语句；它不等同于 PyMySQL 的 cursor
• 不要对 SQLAlchemy 的 Connection 调 .cursor() 再手动关 cursor——这是底层封装，交由 SQLAlchemy 管理
• ORM 模式下用 session，务必配 session.close() 或 with Session() as s:；session.rollback() 不会自动 close，得再 call 一次 close
• 调试时可在 engine.dispose() 后立刻 SHOW STATUS LIKE 'Threads_connected'; 看连接数是否回落，验证释放逻辑

到这里，我们也就讲完了《Python连接MySQL怎么做_PyMySQL与SQLAlchemy配置连接池》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！