在当今数据驱动的时代,将编程语言与数据库相结合是构建动态应用和进行数据分析的基石，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() | 关闭数据库连接。 |
相关问答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代码的一部分来执行。
【版权声明】：本站所有内容均来自网络，若无意侵犯到您的权利，请及时与我们联系将尽快删除相关内容!
发表回复