Python连接MySQL数据库的具体步骤和完整代码是怎样的？

爱国 • 2025-10-06 00:13 • 云计算 • 阅读 7

在当今数据驱动的时代,将编程语言与数据库相结合是构建动态应用和进行数据分析的基石，Python，以其简洁明了的语法和强大的库生态，与MySQL这一广受欢迎的开源关系型数据库的连接，是许多开发者必须掌握的核心技能，本文将系统地介绍如何使用Python连接MySQL数据库，并执行基本的数据库操作。

准备工作：环境与依赖

在开始编写代码之前,请确保您的开发环境已经准备就绪，这包括安装Python、运行中的MySQL服务器，以及一个用于测试的数据库和表，最关键的一步是安装Python的MySQL驱动程序，它充当了Python代码与MySQL服务器之间的桥梁。

最常用且官方推荐的驱动是mysql-connector-python，您可以通过Python的包管理器pip轻松安装它，打开您的终端或命令提示符，输入以下命令：

pip install mysql-connector-python

安装完成后,您就可以在Python脚本中导入mysql.connector模块，开始与数据库进行交互了。

建立数据库连接

连接是所有数据库操作的第一步,使用mysql.connector.connect()函数，并提供必要的认证信息即可建立连接，这些信息通常包括数据库主机地址（host）、用户名（user）、密码（password）以及要连接的数据库名称（database）。

为了确保代码的健壮性,最佳实践是使用try...except...finally结构来处理可能出现的连接错误，并确保数据库连接在任何情况下都能被正确关闭。

import mysql.connector
from mysql.connector import Error
def create_connection():
    connection = None
    try:
        connection = mysql.connector.connect(
            host='localhost',
            user='your_username',
            password='your_password',
            database='your_database'
        )
        print("MySQL数据库连接成功")
    except Error as e:
        print(f"连接错误 '{e}'")
    return connection
# 使用示例
conn = create_connection()
# ... 后续操作 ...
if conn and conn.is_connected():
    conn.close()
    print("MySQL连接已关闭")

执行SQL查询与获取数据

成功建立连接后,您需要创建一个“游标”对象，游标可以理解为遍历查询结果集的指针，它允许您执行SQL语句并获取返回的数据。

创建游标：使用connection.cursor()方法。
执行查询：使用cursor.execute()方法，传入您的SQL查询字符串。
获取数据：根据需求，使用以下方法之一获取结果：
- fetchone()：获取结果集中的下一行。
- fetchall()：获取结果集中的所有行，返回一个元组列表。
- fetchmany(size)：获取指定数量的行。

下面是一个完整的示例,展示了如何从表中查询所有数据：

def query_all_data(connection):
    cursor = connection.cursor()
    try:
        cursor.execute("SELECT id, name, email FROM users")
        records = cursor.fetchall()
        print("总共有", cursor.rowcount, "条记录。")
        for row in records:
            print(f"ID: {row[0]}, 姓名: {row[1]}, 邮箱: {row[2]}")
    except Error as e:
        print(f"查询数据时出错 '{e}'")
    finally:
        cursor.close()
# 假设 conn 是一个已建立的连接
if conn and conn.is_connected():
    query_all_data(conn)
    conn.close()

执行数据修改操作（增、删、改）

除了查询数据,您还需要执行插入（INSERT）、更新（UPDATE）和删除（DELETE）操作，这些操作的过程与查询类似，但有一个关键区别：它们需要“提交”事务。

默认情况下,MySQL驱动程序在自动提交模式下是关闭的，这意味着您执行的修改操作不会立即永久保存到数据库中，您必须调用connection.commit()来确认并保存这些更改，如果您想撤销操作，可以调用connection.rollback()。

重要提示：为了防止SQL注入攻击，永远不要直接使用字符串格式化（如f-string或）来构建SQL查询，应始终使用参数化查询，将值作为execute()方法的第二个参数传递。

def insert_user(connection, name, email):
    cursor = connection.cursor()
    sql_query = "INSERT INTO users (name, email) VALUES (%s, %s)"
    user_data = (name, email)
    try:
        cursor.execute(sql_query, user_data)
        connection.commit() # 提交事务
        print(f"成功插入用户 {name}.")
    except Error as e:
        print(f"插入数据时出错 '{e}'")
        connection.rollback() # 出错时回滚
    finally:
        cursor.close()
# 假设 conn 是一个已建立的连接
if conn and conn.is_connected():
    insert_user(conn, "张三", "zhangsan@example.com")
    conn.close()

核心方法速查表

为了方便您快速回顾,下表小编总结了本文中提到的核心方法：

方法/函数	描述
`mysql.connector.connect()`	建立与MySQL数据库的连接。
`connection.cursor()`	创建一个游标对象，用于执行SQL命令。
`cursor.execute()`	执行单个SQL查询或命令。
`cursor.fetchall()`	获取查询结果中的所有行。
`connection.commit()`	提交当前事务，将所有更改保存到数据库。
`connection.close()`	关闭数据库连接。