python mysql错误如何处理

Python连接MySQL需区分三类错误并针对性处理:连接错误(检查网络、配置)、权限错误(核对用户权限)、SQL错误(验证语句与参数),必须用try-except捕获异常,避免硬编码敏感信息,合理使用连接池与显式ping。

Python 连接 MySQL 出错时,核心是区分错误类型、捕获异常、针对性修复,而不是靠重试或忽略。

常见错误类型及对应处理

MySQLdb、PyMySQL、mysql-connector-python 等驱动报错机制略有差异,但主要错误可归为三类:

  • 连接错误(如 pymysql.err.OperationalError 2003/2006):数据库没启动、地址/端口错、网络不通、防火墙拦截。检查 host、port、user、password 是否写对,用 telnet 或 mysql 命令行手动连一次确认服务可达。
  • 权限错误(如 1045 Access denied):用户名密码错误,或用户没被授权访问目标数据库/表。进 MySQL 执行 SELECT User,Host FROM mysql.user;SHOW GRANTS FOR 'xxx'@'yyy'; 核对权限。
  • SQL 执行错误(如 1054 Unknown column、1064 Syntax error):SQL 拼写错误、字段名不存在、参数未转义导致语法破坏。用 print 或 logging 输出最终执行的 SQL 字符串(注意别打日志敏感数据),粘贴到 MySQL 客户端里直接运行验证。

必须用 try-except 包裹关键操作

不要让未捕获异常导致程序崩溃,尤其在 Web 或定时任务中。示例(以 PyMySQL 为例):

import pymysql
from pymysql.err import OperationalError, ProgrammingError

try: conn = pymysql.connect( host='127.0.0.1', port=3306, user='root', password='123456', database='test', charset='utf8mb4' ) with conn.cursor() as cur: cur.execute("SELECT * FROM users WHERE id = %s", (user_id,)) result = cur.fetchone() except OperationalError as e: print(f"连接失败:{e}")

可记录日志、发告警、或返回默认值

except ProgrammingError as e: print(f"SQL 错误:{e}")

检查 SQL 语句和参数类型

finally: if 'conn' in locals() and conn.open: conn.close()

避免硬编码和敏感信息泄露

密码、地址等不要写死在代码里。改用配置文件(如 .env + python-decouple)或环境变量:

  • 新建 .env 文件:DB_HOST=192.168.1.100DB_USER=adminDB_PASSWORD=secret
  • 代码中读取:from decouple import config,然后 config('DB_HOST')
  • 确保 .env 不提交到 Git(加进 .gitignore)

连接池与自动重连要谨慎启用

短生命周期脚本不用池;高并发服务建议用 PyMySQL 的 ConnectionPool 或更成熟的 SQLAlchemy + pool_pre_ping=True。自动重连(如 PyMySQL 的 autocommit=Trueping(True))能缓解临时断连,但掩盖了根本问题——比如 MySQL 主从切换未通知应用、或连接空闲超时被服务端 kill。建议在每次执行前显式 ping:

if not conn.open:
    conn.ping(reconnect=True)