Python操作MySQL数据库的方法实例

更新时间：2026年07月29日 09:14:25 作者：炸炸鱼.

我们经常需要将大量数据保存起来以备后续使用,数据库是一个很好的解决方案,这篇文章主要介绍了Python操作MySQL数据库的相关资料,需要的朋友可以参考下

前言

在现代应用程序中，数据库至关重要。MySQL 是流行的关系型数据库管理系统，广泛用于各类应用。本文以 MySQL 服务器：192.168.10.101、Python 服务器：192.168.10.102 为例，讲解 Python 远程操作 MySQL 完整流程，包含连接、CRUD、模糊查询、JOIN、事务、隔离级别、连接池，并补充 MySQL 端创建远程用户、授权、旧认证插件兼容。

一、安装 Python MySQL 连接库

1. 安装命令

pip install mysql-connector-python
pip install pymysql

2. 补充知识点

pymysql：纯 Python 实现的 MySQL 客户端，跨平台，支持 TCP/IP 远程连接。
dbutils：数据库连接池组件，用于复用连接，减少创建 / 销毁连接的开销。
mysql-connector-python：MySQL 官方驱动，可作为 pymysql 备选。
生产环境建议固定库版本，避免兼容性问题。

二、MySQL 服务器端配置（192.168.10.101）

执行位置：MySQL 命令行（mysql -u root -p）

1. 创建远程访问用户

CREATE USER 'root'@'192.168.10.102' IDENTIFIED BY 'pwd123';

2. 授权数据库权限

sql

GRANT REPLICATION  ON *.* TO 'root'@'192.168.10.102';

3. 旧密码认证插件兼容

sql

ALTER USER 'root'@'192.168.10.102' IDENTIFIED WITH mysql_native_password BY 'pwd123';

4. 刷新权限

FLUSH PRIVILEGES;

5.添加数据

-- 创建数据库
CREATE DATABASE IF NOT EXISTS testdb;

-- 切换到 testdb 数据库
USE testdb;

-- 创建 users 表
CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    age INT NOT NULL
);

-- 创建 orders 表
CREATE TABLE IF NOT EXISTS orders (
    id INT AUTO_INCREMENT PRIMARY KEY,
    user_id INT,
    amount DECIMAL(10, 2) NOT NULL,
    order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
);

-- 插入数据到 users 表
INSERT INTO users (name, age) VALUES
('Alice', 25),
('Bob', 30),
('Charlie', 35),
('David', 28);

-- 插入数据到 orders 表
INSERT INTO orders (user_id, amount) VALUES
(1, 100.50),
(2, 150.75),
(3, 200.00),
(1, 50.25);

-- -- 查询所有用户信息
-- SELECT * FROM users;

-- -- 查询所有订单信息
-- SELECT * FROM orders;

-- -- 查询用户及其对应的订单信息（JOIN查询）
-- SELECT users.name, users.age, orders.amount
-- FROM users
-- JOIN orders ON users.id = orders.user_id;

-- -- 更新某个用户的数据，修改 Bob 的年龄
-- UPDATE users SET age = 31 WHERE name = 'Bob';

-- -- 删除 Charlie 用户及其对应的订单数据
-- DELETE FROM orders WHERE user_id = (SELECT id FROM users WHERE name = 'Charlie');
-- DELETE FROM users WHERE name = 'Charlie';

-- -- 设置事务隔离级别为 REPEATABLE READ
-- SET TRANSACTION ISOLATION LEVEL REPEATABLE READ;

补充知识点

MySQL 8.0+ 默认认证插件：caching_sha2_password，pymysql 不支持。
mysql_native_password：MySQL 5.x 与 pymysql 兼容插件。
@'192.168.10.102'：仅允许该 Python 服务器连接，更安全。
授权后必须 FLUSH PRIVILEGES 才能生效。

三、Python 连接 MySQL 数据库

创建文件：01_connect.py

import pymysql

db = pymysql.connect(
    host="192.168.10.101",  #MySQL数据库的地址
    user="root",           #数据库的用户名
    password="pwd123",     #密码
    database="testdb",     #要连接的数据库的名称
    charset="utf8mb4"
)         #创建数据库的连接

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

cursor.execute("select * from users")   #执行SQL语句

results=cursor.fetchall()
for row in results:
    print(row)       #获取查询结果


data = cursor.fetchone()
print("MySQL 版本：", data)


cursor.close()   #关闭游标连接
db.close()     #关闭数据库连接

补充知识点

host：必须写 MySQL 远程 IP，不能写 localhost。
charset=utf8mb4：支持中文、表情，生产标准字符集。
cursor：执行 SQL、获取结果的对象。
必须关闭游标与连接，避免资源泄漏。

执行命令

python3 01_connect.py

四、常见的 MySQL 操作

创建文件：02_operate.py （根据情况来写是添加还是删除，可以在01_connect.py的文件基础上做改动，改SQL语句就行！！！然后根据情况改是添加还是修改什么的。然后可以在MySQL上面进行查看）

import pymysql

db = pymysql.connect(
    host="192.168.10.101",
    user="root",
    password="pwd123",
    database="testdb",
    charset="utf8mb4"
)
cursor = db.cursor()

# 创建表
cursor.execute("""
CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(50),
    age INT
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
""")

# 插入
cursor.execute("INSERT INTO users(name, age) VALUES(%s, %s)", ("Alice", 25))
db.commit()

# 查询
cursor.execute("SELECT * FROM users")
results = cursor.fetchall()
for row in results:
    print(row)

# 更新
cursor.execute("UPDATE users SET age=%s WHERE name=%s", (26, "Alice"))
db.commit()

# 删除
cursor.execute("DELETE FROM users WHERE name=%s", ("Alice",))
db.commit()

# 模糊查询
cursor.execute("SELECT * FROM users WHERE name LIKE %s", ("%li%",))
print("模糊查询：", cursor.fetchall())

# 联合查询
cursor.execute("""
SELECT users.name, orders.amount
FROM users
INNER JOIN orders ON users.id = orders.user_id
""")
print("联合查询：", cursor.fetchall())

cursor.close()
db.close()

补充知识点

增删改必须 commit()，否则不写入数据库。
%s 占位符防止 SQL 注入。
fetchall()：获取全部；fetchone()：获取一条。
LIKE %xxx%：全模糊匹配。
INNER JOIN：只返回匹配成功的记录。

执行命令

python3 02_operate.py

五、事务管理

创建文件：03_transaction.py

import pymysql

db = pymysql.connect(
    host="192.168.10.101",
    user="root",
    password="pwd123",
    database="testdb"
)
cursor = db.cursor()

db.autocommit = False

try:
    cursor.execute("INSERT INTO users(name, age) VALUES('Tom', 20)")
    cursor.execute("UPDATE users SET age=21 WHERE name='Tom'")
    db.commit()
    print("事务执行成功")
except:
    db.rollback()
    print("事务已回滚")
finally:
    cursor.close()
    db.close()

补充知识点（ACID 完整）

原子性（Atomicity）事务是最小单元，所有 SQL 要么全成功，要么全失败回滚。
一致性（Consistency）事务前后数据完整性约束（主键、外键、非空）不被破坏。
隔离性（Isolation）并发事务相互隔离，避免脏读、不可重复读、幻读。
持久性（Durability）事务提交后，修改永久生效，数据库崩溃也不丢失。

执行命令

python3 03_transaction.py

六、MySQL 四种事务隔离级别

执行位置：MySQL 命令行

SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
SET TRANSACTION ISOLATION LEVEL READ COMMITTED;
SET TRANSACTION ISOLATION LEVEL REPEATABLE READ;
SET TRANSACTION ISOLATION LEVEL SERIALIZABLE;

补充知识点

READ UNCOMMITTED：可读取未提交数据 → 脏读。
READ COMMITTED：只能读已提交数据 → 解决脏读。
REPEATABLE READ：MySQL 默认 → 解决脏读、不可重复读。
SERIALIZABLE：最高级别，串行执行 → 无并发问题，性能最低。

七、使用连接池

1.需要先安装相关软件

pip install dbutils

2.创建文件：04_pool.py

from dbutils.pooled_db import PooledDB
import pymysql

#数据库的连接配置
pool = PooledDB(
    creator=pymysql,
    host="192.168.10.101",
    user="root",
    password="pwd123",
    database="testdb",
    charset="utf8mb4",
    maxconnections=10,
    mincached=2
)     
  
#创建连接池
connection_pool=PooledDb(
    creator=pymysql,    #使用pymysql作为数据库连接库
    maxconnection=5,    #连接池中最大连接数
    **dbconfig
)

#获取连接
db_connection=connection_pool.connection()
cursor=db_connecction.cursor()

cursor.execute("select * from users")
results=cursor.fetchall()

for row in results:
    print(row)

cursor.close()
db_connection.close()   #连接会自动归还给连接池

补充知识点

连接池预先创建连接，避免频繁创建 / 销毁，性能提升明显。
close() 是归还连接池，不是关闭物理连接。
maxconnections：最大连接数，保护数据库。
mincached：初始空闲连接数，提升启动速度。
高并发项目必须使用连接池。

执行命令

python3 04_pool.py

总结

到此这篇关于Python操作MySQL数据库的文章就介绍到这了,更多相关Python操作MySQL数据库内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

为什么Python中没有"a++"这种写法
一开始学习 Python 的时候习惯性的使用 C 中的 a++ 这种写法，发现会报 SyntaxError: invalid syntax 错误，为什么 Python 没有自增运算符的这种写法呢？下面小编给大家带来本文帮助大家了解下这方面的知识
2018-11-11
python抓取并保存html页面时乱码问题的解决方法
这篇文章主要介绍了python抓取并保存html页面时乱码问题的解决方法,结合实例形式分析了Python页面抓取过程中乱码出现的原因与相应的解决方法,需要的朋友可以参考下
2016-07-07
pytorch 多分类问题,计算百分比操作
这篇文章主要介绍了pytorch 多分类问题,计算百分比操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-07-07
python 提取tuple类型值中json格式的key值方法
今天小编就为大家分享一篇python 提取tuple类型值中json格式的key值方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-12-12
分析语音数据增强及python实现
数据增强是一种生成合成数据的方法，即通过调整原始样本来创建新样本。这样我们就可获得大量的数据。这不仅增加了数据集的大小，还提供了单个样本的多个变体，这有助于我们的机器学习模型避免过度拟合
2021-06-06
Django数据库表反向生成实例解析
这篇文章主要介绍了Django数据库表反向生成实例解析，分享了相关代码示例，小编觉得还是挺不错的，具有一定借鉴价值，需要的朋友可以参考下
2018-02-02
对python requests发送json格式数据的实例详解
今天小编就为大家分享一篇对python requests发送json格式数据的实例详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-12-12
pygame实现飞机大战
这篇文章主要为大家详细介绍了pygame实现飞机大战，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2020-03-03
Python利用ftplib库实现ftp文件传输自动化全攻略
本文介绍了Python标准库ftplib的使用方法,详细描述了连接与登录、目录操作、文件上传下载、文件管理、目录列表查看等核心函数,并提供了两个实战案例,帮助实现FTP自动化操作,需要的朋友可以参考下
2026-04-04
django 多数据库及分库实现方式
这篇文章主要介绍了django 多数据库及分库实现方式，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-04-04