5154

在当今数据驱动的时代,将编程语言与数据库相结合是构建动态应用和进行数据分析的基石，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语句并获取返回的数据。

1. 创建游标：使用connection.cursor()方法。
2. 执行查询：使用cursor.execute()方法，传入您的SQL查询字符串。
3. 获取数据：根据需求，使用以下方法之一获取结果：
   • 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()

核心方法速查表

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

相关问答FAQs

问题1：连接时出现错误 "Access denied for user 'user'@'host'" 怎么办？

解答：这是一个非常常见的认证错误，请仔细检查您在connect()函数中提供的user和password是否完全正确，确保该MySQL用户拥有从您当前主机（例如localhost或您的IP地址）连接到数据库的权限，您可以使用MySQL的管理员账户登录，并执行GRANT语句来授予权限，GRANT ALL PRIVILEGES ON your_database.* TO 'your_username'@'localhost';，然后执行FLUSH PRIVILEGES;刷新权限。

问题2：什么是SQL注入，如何预防？

解答：SQL注入是一种代码注入技术，攻击者通过在Web应用的输入字段中“注入”恶意的SQL代码，来欺骗服务器执行非预期的数据库操作，如果您的代码直接拼接字符串来构建查询，攻击者可以输入类似 ' OR '1'='1 的内容来绕过登录验证，预防SQL注入最有效的方法就是永远不要使用字符串拼接来构建SQL查询，而应始终使用参数化查询，如上文示例所示，将SQL语句中的变量值用占位符（如%s）代替，然后将实际值作为元组传递给execute()方法，这样，数据库驱动会自动对这些值进行转义和处理，确保它们只被当作数据而非SQL代码的一部分来执行。