Python如何连接数据库？Python连接MySQL数据库详细教程

通过Python连接数据库的核心在于使用第三方库（如pymysql或psycopg2）建立驱动，配置连接参数后执行SQL语句，实现数据的增删改查。

在数据驱动业务的今天,Python早已不仅是脚本语言，更是连接业务逻辑与底层数据的桥梁，无论是处理电商订单、分析用户行为，还是自动化报表生成，数据库交互都是必经之路，很多初学者常问，Python怎么连数据库？其实不需要复杂的底层协议开发，借助成熟的驱动库，几行代码就能打通数据通道。

Python连接数据库的常见方案对比

不同数据库有不同的“方言”，Python通过适配层来统一交互，业内专家指出，选择正确的驱动库是成功的一半，目前主流方案主要分为两类：通用型驱动和框架内置驱动。

通用驱动库的选择逻辑

对于关系型数据库,Python生态中有几个老牌且稳定的选择。

• MySQL连接：pymysql 是纯Python实现的驱动，无需安装C编译器，适合快速开发和跨平台部署。mysqlclient 性能更优，但依赖系统C库，安装稍麻烦。
• PostgreSQL连接：psycopg2 是事实上的标准，功能强大且稳定，几乎覆盖了PG的所有特性。
• SQLite连接：作为轻量级嵌入式数据库，Python标准库内置了 sqlite3，无需额外安装，开箱即用。

ORM框架的便利性

如果你不想写原生SQL,SQLAlchemy或Django ORM是更好的选择，它们将数据库表映射为Python类，通过对象操作代替SQL语句，虽然学习曲线稍陡，但在大型项目中，它能显著提升代码的可维护性，据统计，多数情况下，使用ORM能减少约30%的数据访问层代码量，但需注意其带来的性能开销。

实操：使用pymysql连接MySQL数据库

以最常见的MySQL为例,展示从安装到查询的完整流程，这是很多开发者入门Python数据库操作的首选场景。

环境准备与安装

确保你的环境中已安装MySQL服务,通过pip安装驱动库。

pip install pymysql

这一步非常关键,若遇到安装报错，通常是因为缺少编译环境或网络问题，建议检查Python版本兼容性。

建立连接与基础查询

连接数据库需要四个核心参数：主机地址、用户名、密码和数据库名，以下代码演示了如何建立连接并执行查询。

import pymysql
# 1. 建立连接
connection = pymysql.connect(
    host='localhost',
    user='your_username',
    password='your_password',
    database='your_database',
    charset='utf8mb4',
    cursorclass=pymysql.cursors.DictCursor
)
try:
    # 2. 创建游标
    with connection.cursor() as cursor:
        # 3. 执行SQL
        sql = "SELECT id, name, age FROM users WHERE age > %s"
        cursor.execute(sql, (18,))
        # 4. 获取结果
        results = cursor.fetchall()
        for row in results:
            print(row)
finally:
    # 5. 关闭连接
    connection.close()

在这个流程中,cursorclass=pymysql.cursors.DictCursor 是一个实用技巧，它让返回的结果以字典形式呈现，键为字段名，值为数据，极大提升了代码可读性。

参数化查询的重要性

注意代码中的 cursor.execute(sql, (18,))，这里使用了参数化查询，而非字符串拼接，这是防止SQL注入攻击的最有效手段，任何直接拼接用户输入的做法都是危险的，务必使用占位符 %s 并由驱动层处理转义。

处理连接池与资源管理

在高并发场景下,频繁创建和销毁数据库连接会消耗大量资源，使用连接池是生产环境的标配。

为什么需要连接池？

数据库连接是一种昂贵的资源,每次建立TCP握手、验证身份、分配内存，都需要时间，连接池预先创建一组连接，当应用需要时从池中借用，使用完毕后归还，这就像共享单车，不用每次都去制造一辆新车。

使用DBUtils实现连接池

DBUtils 是一个常用的Python数据库连接池工具，它可以与 pymysql 或 mysqlclient 配合使用。

from DBUtils.PooledDB import PooledDB
import pymysql
# 创建连接池
pool = PooledDB(
    creator=pymysql,
    maxconnections=10,  # 最大连接数
    mincached=2,        # 初始化时创建的空闲连接数
    host='localhost',
    user='your_username',
    password='your_password',
    database='your_database'
)
# 从池中获取连接
conn = pool.connection()
cursor = conn.cursor()
try:
    cursor.execute("SELECT  FROM users")
    print(cursor.fetchall())
finally:
    cursor.close()
    conn.close()  # 归还连接到池中，而非真正关闭

这种模式能有效控制数据库负载,避免连接数激增导致服务器崩溃，对于中小规模应用，设置 maxconnections=10 到 50 之间通常足够。

常见问题与避坑指南

在实际操作中,开发者常遇到一些棘手问题，以下是基于行业共识的解决方案。

中文乱码问题

这是最经典的问题,解决思路有三：

1. 数据库表字符集设为 utf8mb4。
2. 连接时指定 charset='utf8mb4'。
3. Python代码文件保存为UTF-8编码。
   三者缺一不可，若仍乱码，检查操作系统终端编码是否一致。

连接超时与断连

MySQL默认有 wait_timeout 设置，空闲连接会被服务端主动断开，客户端再次使用时会报错。

• 对策：在连接参数中设置 ping=True，让驱动在每次操作前自动检测连接状态并重连，或者在应用层实现心跳机制。

事务管理

对于涉及多步操作的业务（如转账），必须使用事务保证原子性。

try:
    cursor.execute("UPDATE accounts SET balance=balance-100 WHERE id=1")
    cursor.execute("UPDATE accounts SET balance=balance+100 WHERE id=2")
    connection.commit()  # 提交事务
except Exception as e:
    connection.rollback()  # 回滚事务
    print(f"操作失败: {e}")

commit() 是持久化数据的关键，rollback() 是数据安全的最后一道防线。

Python数据库连接Q&A

Python连接数据库时，pymysql和mysqlclient哪个更好？

pymysql是纯Python实现,安装简单，无外部依赖，适合快速原型开发或容器化环境，mysqlclient基于C扩展，性能更高，尤其在大量数据读写时优势明显，若追求极致性能且环境允许，选mysqlclient；若求便捷稳定，选pymysql。

如何防止SQL注入攻击？

永远不要使用字符串拼接构造SQL,始终使用参数化查询，即驱动提供的占位符机制（如%s），驱动层会自动对参数进行转义和类型检查，从根本上阻断注入风险，这是Python数据库操作的金科玉律。

SQLite适合用于生产环境的高并发场景吗？

不适合,SQLite是文件级数据库，并发写入能力弱，存在锁机制限制，它适合嵌入式应用、移动端本地存储或低并发服务，对于高并发Web后端，应选择MySQL、PostgreSQL等客户端-服务器架构的数据库。