Python 连接 MySQL 数据库实战指南

4.1 创建游标

cursor = cnx.cursor()

4.2 查询数据 (SELECT)

使用 execute() 执行查询，并通过 fetchall() 获取所有结果集。

query = "SELECT id, name, address FROM customers WHERE age > 18"
cursor.execute(query)

results = cursor.fetchall()
for row in results:
    print(f"ID: {row[0]}, Name: {row[1]}, Address: {row[2]}")

4.3 插入数据 (INSERT)

为防止 SQL 注入攻击，务必使用参数化查询（占位符 %s），而非字符串拼接。

sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("John Doe", "123 Main St")
cursor.execute(sql, val)

4.4 更新与删除

更新操作需配合条件判断，删除操作需谨慎处理主键。

# 更新
update_sql = "UPDATE customers SET address = %s WHERE name = %s"
cursor.execute(update_sql, ("New Address", "John Doe"))

# 删除
delete_sql = "DELETE FROM customers WHERE id = %s"
cursor.execute(delete_sql, (1,))

5. 事务管理

MySQL 默认开启自动提交，但在涉及多步操作时，建议显式控制事务以保证数据一致性。

5.1 提交更改

执行写入操作（Insert/Update/Delete）后，必须调用 commit() 保存更改。

cnx.commit()

5.2 回滚操作

若发生错误，应调用 rollback() 撤销本次事务的所有更改。

try:
    # 模拟可能出错的操作
    cursor.execute("INSERT INTO ...")
    cnx.commit()
except Exception:
    cnx.rollback()
    raise

6. 异常处理与资源释放

良好的代码结构应包含异常捕获和连接关闭逻辑，防止资源泄露。

6.1 使用上下文管理器

推荐使用 with 语句自动管理游标和连接的关闭。

import mysql.connector
from mysql.connector import Error

try:
    with mysql.connector.connect(
        host="localhost",
        user="root",
        password="password",
        database="mydatabase"
    ) as cnx:
        with cnx.cursor() as cursor:
            cursor.execute("SELECT * FROM users LIMIT 5")
            for row in cursor.fetchall():
                print(row)
except Error as e:
    print(f"数据库错误：{e}")
finally:
    # 显式关闭逻辑通常由 with 处理，但可保留用于额外清理
    pass

6.2 常见错误排查

• Access Denied: 检查用户名密码权限。
• Unknown Database: 确认数据库名称拼写正确且已创建。
• Connection Timed Out: 检查防火墙设置或网络连通性。

7. 安全最佳实践

1. 禁止硬编码密码：使用环境变量或配置文件存储敏感信息。
2. 最小权限原则：为应用分配仅具备必要权限的数据库账号。
3. 参数化查询：始终使用 %s 占位符，杜绝字符串拼接。
4. SSL 加密：生产环境建议启用 SSL 连接保护传输数据。

8. 总结

通过本文的学习，您已掌握 Python 连接 MySQL 的核心技能，包括驱动安装、连接配置、CRUD 操作、事务控制及安全规范。在实际项目中，建议结合 ORM 框架（如 SQLAlchemy）进一步提升开发效率，同时保持对底层连接机制的理解以确保性能与安全。