Python与MySQLldb

admin 2026年03月27日 05:37 105 0

Python与MySQLdb是经典的数据库连接组合，MySQLdb作为Python早期访问MySQL的接口库，基于C语言开发，提供高效的数据库操作能力，它支持建立与MySQL服务器的连接、执行SQL查询（增删改查）、处理结果集及事务管理等功能，依赖MySQL开发环境，性能优异，但需注意，MySQLdb对Python 3支持有限，且依赖外部库，现代开发中多推荐使用PyMySQL或mysql-connector-python等纯Python实现，兼顾兼容性与易用性。

Python与MySQLdb：高效连接MySQL数据库的实战指南

在当今数据驱动的时代,Python凭借其简洁优雅的语法和强大的生态系统，已成为数据处理与应用开发的首选编程语言，MySQL作为全球最受欢迎的开源关系型数据库之一，广泛应用于各类Web应用和企业系统中，要将Python与MySQL完美结合，高效可靠的数据库连接工具MySQLdb（或其Python 3兼容版mysqlclient）扮演着至关重要的角色，本文将全面介绍MySQLdb的安装配置、核心功能及实战应用，助您快速掌握Python操作MySQL数据库的技能。

认识MySQLdb

MySQLdb是Python生态中连接MySQL数据库的经典接口库,它基于MySQL C API开发，为Python开发者提供了对MySQL数据库的高效访问能力，该库诞生于Python 2.x时代，凭借其稳定性和性能优势，成为早期Python开发者的首选工具，MySQLdb支持执行各类SQL语句、管理数据库事务、处理结果集等核心功能，是Python与MySQL交互的桥梁。

重要提示：官方MySQLdb库对Python 3.x的支持较为有限，若需在Python 3环境中使用，推荐安装其兼容分支mysqlclient——这是MySQLdb的Python 3重构版本，保持了API的兼容性，本文将以mysqlclient为例（下文统一称为MySQLdb），详细讲解在Python 3环境下的使用方法。

安装与配置

环境准备

在开始之前,请确保您的系统已安装MySQL数据库（建议使用5.7或更高版本），并已创建好目标数据库及具有适当权限的用户账户，可以通过以下命令验证MySQL是否正常运行：

mysql --version

安装MySQLdb

Linux/macOS系统

在Linux或macOS系统上,需要先安装MySQL开发库，再通过pip安装MySQLdb：

# Ubuntu/Debian系统
sudo apt-get update
sudo apt-get install libmysqlclient-dev python3-dev
# CentOS/RHEL系统
sudo yum install mysql-devel python3-devel
# 安装MySQLdb
pip install mysqlclient

Windows系统

Windows用户可以直接通过pip安装预编译的wheel包：

pip install mysqlclient

如果安装失败,可从mysqlclient非官方Windows预编译包下载对应Python版本的.whl文件，然后使用以下命令本地安装：

pip install 下载的文件名.whl

常见安装问题及解决方案

编译错误：如果遇到编译错误，可能缺少必要的开发工具或库文件
权限问题：确保pip有足够的权限安装系统级包
版本不匹配：确保Python版本与mysqlclient版本兼容

数据库连接与基本操作

建立数据库连接

使用MySQLdb.connect()方法创建与MySQL数据库的连接，需要提供必要的连接参数：

import MySQLdb
# 创建数据库连接
conn = MySQLdb.connect(
    host='localhost',          # 数据库主机地址
    user='your_username',      # 数据库用户名
    password='your_password',  # 数据库密码
    database='your_database',  # 要连接的数据库
    port=3306,                 # 端口号，默认3306
    charset='utf8mb4',        # 字符集，推荐使用utf8mb4支持完整Unicode
    connect_timeout=10,       # 连接超时时间（秒）
    autocommit=False          # 是否自动提交事务，默认为False
)
print("数据库连接成功！")

连接成功后,将返回一个Connection对象，后续所有数据库操作都基于此对象进行。

创建游标

游标（Cursor）是执行SQL语句的载体，通过conn.cursor()方法创建：

# 创建游标对象
cursor = conn.cursor()

游标提供了执行SQL语句、获取结果集等功能，是数据库操作的核心组件。

执行SQL语句

创建表与插入数据

创建表

# 创建表示例
create_table_sql = """
CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL,
    email VARCHAR(100) UNIQUE,
    age TINYINT UNSIGNED,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    INDEX idx_age (age)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
"""
try:
    cursor.execute(create_table_sql)
    print("表创建成功！")
except MySQLdb.Error as e:
    print(f"创建表失败: {e}")

插入数据

# 插入单条数据（使用参数化查询防止SQL注入）
insert_sql = "INSERT INTO users (username, email, age) VALUES (%s, %s, %s)"
user_data = ('alice', 'alice@example.com', 25)
try:
    cursor.execute(insert_sql, user_data)
    conn.commit()  # 提交事务
    print(f"插入成功，ID: {cursor.lastrowid}")
except MySQLdb.Error as e:
    conn.rollback()  # 回滚事务
    print(f"插入失败: {e}")
# 插入多条数据（executemany）
users_data = [
    ('bob', 'bob@example.com', 30),
    ('charlie', 'charlie@example.com', 22),
    ('diana', 'diana@example.com', 28)
]
try:
    cursor.executemany(insert_sql, users_data)
    conn.commit()
    print(f"批量插入{cursor.rowcount}条数据成功！")
except MySQLdb.Error as e:
    conn.rollback()
    print(f"批量插入失败: {e}")

查询数据

# 查询所有用户
query_sql = "SELECT id, username, email, age FROM users ORDER BY created_at DESC"
try:
    cursor.execute(query_sql)
    # 获取单条结果
    user = cursor.fetchone()
    print("单条结果:", user)
    # 获取所有结果
    all_users = cursor.fetchall()
    print("所有用户:", all_users)
    # 分批获取结果（适用于大量数据）
    cursor.execute("SELECT * FROM users LIMIT 1000")
    while True:
        batch = cursor.fetchmany(50)  # 每次获取50条
        if not batch:
            break
        print("当前批次:", batch)
except MySQLdb.Error as e:
    print(f"查询失败: {e}")

更新与删除数据

# 更新数据（将alice的年龄改为26）
update_sql = "UPDATE users SET age = %s WHERE username = %s"
try:
    cursor.execute(update_sql, (26, 'alice'))
    conn.commit()
    print(f"更新{cursor.rowcount}条数据成功！")
except MySQLdb.Error as e:
    conn.rollback()
    print(f"更新失败: {e}")
# 删除数据（删除年龄小于23的用户）
delete_sql = "DELETE FROM users WHERE age < %s"
try:
    cursor.execute(delete_sql, (23,))
    conn.commit()
    print(f"删除{cursor.rowcount}条数据成功！")
except MySQLdb.Error as e:
    conn.rollback()
    print(f"删除失败: {e}")

事务管理

事务是数据库操作的基本单元,确保一组操作要么全部成功执行，要么全部失败回滚，MySQLdb默认开启事务模式，需要手动提交（commit）或回滚（rollback）。

try:
    # 开启事务（MySQLdb默认已开启）
    # 执行多个操作
    cursor.execute("INSERT INTO users (username, email) VALUES (%s, %s)", 
                   ('user1', 'user1@example.com'))
    cursor.execute("UPDATE users SET age = age + 1 WHERE username = %s

标签： #Python MySQLdb