python操作mysql数据库的核心在于使用pymysql等库实现连接与sql操作。1. 安装pymysql并配置连接参数；2. 使用cursor执行sql语句，实现增删改查；3. 通过conn.commit()提交事务或conn.rollback()回滚；4. 使用参数化查询防止sql注入；5. 利用with语句或finally块确保资源释放；6. 统一使用utf8mb4编码避免乱码问题；7. 处理连接失败时需检查mysql服务状态、网络、账号密码等配置。整个过程需注重安全性、效率与事务一致性。
Python操作MySQL数据库，核心在于利用像
PyMySQL
mysql-connector-python
要使用Python与MySQL数据库进行交互，通常需要以下几个步骤。我个人习惯用
PyMySQL
首先，确保你的环境里装了
PyMySQL
立即学习“Python免费学习笔记（深入）”；
pip install PyMySQL
然后，你可以这样来连接数据库并执行一些操作。这里我直接展示一个连接、查询和插入的例子，这是最常见的需求：
import pymysql
# 数据库连接配置，这些信息需要根据你的实际情况来填
DB_CONFIG = {
'host': '127.0.0.1', # 或者你的MySQL服务器IP
'port': 3306,
'user': 'your_username',
'password': 'your_password',
'db': 'your_database_name',
'charset': 'utf8mb4', # 确保支持表情符号等
'cursorclass': pymysql.cursors.DictCursor # 这样查询结果会是字典，方便取值
}
conn = None
cursor = None
try:
# 建立连接
conn = pymysql.connect(**DB_CONFIG)
# 获取游标对象，用于执行SQL命令
cursor = conn.cursor()
# --- 1. 查询数据 ---
sql_select = "SELECT id, name, age FROM users WHERE age > %s"
# 使用参数化查询，防止SQL注入
cursor.execute(sql_select, (25,))
# 获取所有查询结果
users = cursor.fetchall()
print("查询结果:")
for user in users:
print(f"ID: {user['id']}, Name: {user['name']}, Age: {user['age']}")
# --- 2. 插入数据 ---
sql_insert = "INSERT INTO users (name, age) VALUES (%s, %s)"
new_user_data = [
('Alice', 30),
('Bob', 22)
]
# 使用executemany批量插入，效率更高
cursor.executemany(sql_insert, new_user_data)
# 提交事务，让更改生效
conn.commit()
print(f"\n成功插入 {cursor.rowcount} 条数据。")
# --- 3. 更新数据 ---
sql_update = "UPDATE users SET age = %s WHERE name = %s"
cursor.execute(sql_update, (31, 'Alice'))
conn.commit()
print(f"\n成功更新 {cursor.rowcount} 条数据。")
# --- 4. 删除数据 ---
sql_delete = "DELETE FROM users WHERE name = %s"
cursor.execute(sql_delete, ('Bob',))
conn.commit()
print(f"\n成功删除 {cursor.rowcount} 条数据。")
except pymysql.Error as e:
print(f"数据库操作失败: {e}")
if conn:
conn.rollback() # 发生错误时回滚事务
except Exception as e:
print(f"发生未知错误: {e}")
finally:
# 确保连接和游标被关闭，释放资源
if cursor:
cursor.close()
if conn:
conn.close()
print("\n数据库连接已关闭。")
这个例子涵盖了连接、基本的增删改查，以及错误处理和资源释放。实际项目中，这些都是最核心的部分。
在使用Python连接MySQL时，我发现有些坑是大家普遍会踩的，我自己也绕过不少弯路。
一个很常见的，就是连接失败。这可能是因为MySQL服务器没启动，或者IP地址、端口号写错了。有时候，防火墙也会成为拦路虎，需要检查一下服务器的3306端口是不是对外开放了。还有就是用户名或密码不对，这个最容易被忽略，尤其是刚搭建环境时，默认密码或者权限配置没搞定。解决办法很简单，首先确认MySQL服务是否运行，然后双重检查你的
host
port
user
password
另一个让人头疼的问题是字符编码。你可能会遇到存进去是中文，取出来却是乱码的情况，或者在执行包含中文的SQL语句时报错。这通常是数据库、表、字段的编码与Python程序连接时使用的编码不一致导致的。我个人建议，数据库、表、字段统一使用
utf8mb4
charset='utf8mb4'
再就是资源管理。很多人写完代码，连接和游标用完就直接不管了。虽然Python的垃圾回收机制会在一定程度上处理，但显式地关闭连接（
conn.close()
cursor.close()
finally
谈到数据库操作，安全和效率是两个绕不开的话题。我个人认为，防止SQL注入是第一位的安全考量，而效率则是在保证安全的前提下追求的。
防止SQL注入，最关键的就是使用参数化查询。永远不要直接拼接用户的输入到SQL字符串里。像我上面示例代码里用的
sql = "SELECT id, name FROM users WHERE age > %s"
cursor.execute(sql, (25,))
INSERT INTO users (name, age) VALUES (%s, %s)
提高查询效率方面，有几个小技巧。
首先是批量操作。如果需要插入或更新多条记录，使用
executemany()
execute()
其次是合理使用游标。如果你的查询结果集非常大，一次性
fetchall()
PyMySQL
还有就是使用上下文管理器。
PyMySQL
with
import pymysql
# ... DB_CONFIG ...
try:
with pymysql.connect(**DB_CONFIG) as conn:
with conn.cursor() as cursor:
# 在这里执行你的查询和操作
cursor.execute("SELECT VERSION()")
version = cursor.fetchone()
print(f"MySQL Version: {version}")
# conn.commit() 在with块结束时，如果没异常且conn.autocommit是False，会自动提交
except pymysql.Error as e:
print(f"数据库操作失败: {e}")
# with 语句会处理回滚，如果autocommit是False这种写法，是我个人非常推崇的，代码看起来整洁，也减少了忘记关闭资源的风险。
事务处理是数据库操作中一个非常重要的概念，尤其是在涉及到数据一致性的时候。简单来说，事务就是一组操作，要么全部成功，要么全部失败，绝不会出现部分成功的情况。比如，银行转账，从A账户扣钱和给B账户加钱，这两步必须同时成功或同时失败。
在Python中操作MySQL，事务处理的核心在于控制
commit()
rollback()
PyMySQL
import pymysql
# ... DB_CONFIG ...
conn = None
try:
conn = pymysql.connect(**DB_CONFIG)
# 关闭自动提交，这样所有的操作都需要手动commit或rollback
conn.autocommit(False)
cursor = conn.cursor()
# 假设一个转账场景：从用户1001扣100元，给用户1002加100元
# 步骤1: 扣款
sql_deduct = "UPDATE accounts SET balance = balance - %s WHERE user_id = %s AND balance >= %s"
cursor.execute(sql_deduct, (100, 1001, 100))
if cursor.rowcount == 0:
raise ValueError("用户1001余额不足或用户不存在，无法扣款。")
print("成功从用户1001扣款100元。")
# 模拟一个可能出错的场景，比如网络中断或逻辑错误
# if True: # 假设这里有个条件，满足时会出错
# raise Exception("模拟转账过程中发生意外错误！")
# 步骤2: 加款
sql_add = "UPDATE accounts SET balance = balance + %s WHERE user_id = %s"
cursor.execute(sql_add, (100, 1002))
if cursor.rowcount == 0:
raise ValueError("用户1002不存在，无法加款。")
print("成功给用户1002加款100元。")
# 如果所有操作都成功，提交事务
conn.commit()
print("事务提交成功，转账完成。")
except pymysql.Error as e:
print(f"数据库操作失败，回滚事务: {e}")
if conn:
conn.rollback() # 发生任何数据库错误时回滚
except ValueError as e:
print(f"业务逻辑错误，回滚事务: {e}")
if conn:
conn.rollback() # 业务逻辑错误也回滚
except Exception as e:
print(f"发生未知错误，回滚事务: {e}")
if conn:
conn.rollback() # 其他任何异常也回滚
finally:
if cursor:
cursor.close()
if conn:
conn.close()
print("数据库连接已关闭。")这段代码展示了如何通过
conn.autocommit(False)
conn.commit()
conn.rollback()
rollback
以上就是Python如何操作MySQL数据库？连接与查询实战的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
广告Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
909
收藏
