使用PyMySQL连接MySQL时程序无响应，该库是否稳定？

用户问题 #

这是我首次使用Python开发应用。我的程序在调用PyMySQL时出现无响应情况，请问这个库是否稳定？
我只是尝试连接MySQL数据库，但感觉每个Python数据库包都很难用？其他语言做这件事都非常简单，不会出现这类奇怪问题。

相关代码 #

migrateFresh.py #

import pymysql.cursors
import os
import glob
from bootstrap import *

reset_database()
migrate_and_seed()

bootstrap.py #

import pymysql.cursors
from dotenv import load_dotenv
import os
import glob

load_dotenv()

def get_connection (database = ''):
    return pymysql.connect(
        host = os.environ.get("DB_HOST"),
        user = os.environ.get("DB_USER"),
        password = os.environ.get("DB_PASS"),
        database = database,
        cursorclass=pymysql.cursors.DictCursor)

def reset_database():
    connection = get_connection()

    with connection:
        with connection.cursor() as cursor:
            cursor.execute(f'DROP DATABASE IF EXISTS {os.environ.get("DB_NAME")};')
            cursor.execute(f'CREATE DATABASE {os.environ.get("DB_NAME")};')

        connection.commit()

    print('Database has been reset')

def migrate_and_seed():
    connection = get_connection(os.environ.get("DB_NAME"))

    with connection:
        with connection.cursor() as cursor:
            for f in sorted(glob.glob("migrations/*.sql")):
                print(f)
                with open(f, "r") as infile:
                    query = infile.read()
                    cursor.execute(query)

        connection.commit()

        with connection.cursor() as cursor:
            for f in sorted(glob.glob("seeders/*.sql")):
                print(f)
                with open(f, "r") as infile:
                    query = infile.read()
                    cursor.execute(query)

        connection.commit()

问题解答 #

关于PyMySQL的稳定性 #

PyMySQL是Python生态中成熟的MySQL纯Python驱动，长期维护、社区活跃，稳定性有保障。你的程序无响应大概率是代码逻辑或环境配置问题，而非库本身的缺陷。

无响应问题的排查方向 #

• 检查连接参数：确认.env文件中的DB_HOST、DB_USER、DB_PASS、DB_NAME配置正确。如果DB_HOST设为localhost，部分环境下可能需要改为127.0.0.1，避免socket连接异常。
• 批量SQL执行限制：cursor.execute(query)仅支持执行单条SQL语句。如果你的迁移/种子SQL文件包含多条分号分隔的语句（比如多个CREATE TABLE），会导致执行卡住或报错。建议将SQL文件按分号拆分后逐条执行，示例如下：

  # 替代原cursor.execute(query)的代码
  for stmt in query.split(';'):
      stmt = stmt.strip()
      if stmt:
          cursor.execute(stmt)
  

• 添加连接超时：在get_connection的pymysql.connect参数中加入connect_timeout=10，避免因网络或数据库端无响应导致无限等待。
• 增加异常捕获：当前代码无任何错误处理，执行出错会静默卡住。建议在SQL执行环节添加异常捕获，打印错误信息：

  try:
      cursor.execute(query)
  except Exception as e:
      print(f"执行文件{f}时出错: {str(e)}")
      raise
  

关于Python数据库库的使用体验 #

Python的原生数据库驱动设计偏向底层，灵活性强但上手确实需要适应。如果觉得繁琐，可以使用ORM框架（如SQLAlchemy），它封装了连接、查询、事务等操作，用法更简洁，和其他语言的ORM体验接近，能大幅降低数据库操作的复杂度。

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