Python3使用PyMySQL连接MySQL数据库及增删改查操作指南

宋时安

发布时间：2026-10-13| 3人浏览过

原创

本文详细介绍Python3环境下使用PyMySQL库连接MySQL数据库的方法，涵盖安装步骤、数据库连接配置、创建数据表、插入、查询、更新及删除数据的完整操作示例，并深入解析事务的ACID特性及错误处理机制，帮助开发者掌握Python与MySQL交互的核心技能。

本文旨在介绍如何在Python3环境中利用PyMySQL库连接数据库，并演示实现基础的增删改查（CRUD）功能。

什么是PyMySQL？

PyMySQL是一个专为Python3.x版本设计的用于连接MySQL服务器的第三方库；在早期的Python2.x版本中，通常使用的是mysqdb库。

PyMySQL安装

在开始使用PyMySQL之前，必须确保该库已正确安装到您的开发环境中。

PyMySQL的官方下载地址为：https://github.com/PyMySQL/PyMySQL。

若尚未安装，可执行以下命令以安装最新版本的PyMySQL：

$ pip install PyMySQL

如果您的系统环境中未包含pip命令，可以通过以下方式完成安装：

1、使用git命令下载源码包进行安装（您也可以手动下载源码包）：

$ git clone https://github.com/PyMySQL/PyMySQL
$ cd PyMySQL
$ python3 setup.py install

2、若需指定特定版本号进行安装，可使用curl命令执行：

$ # X.X 为PyMySQL 的版本号
$ curl -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz
$ cd PyMySQL*
$ python3 setup.py install

注意：请确保您拥有root权限以执行上述模块的安装操作。

数据库连接

在建立数据库连接之前，请确认满足以下条件：

您已在MySQL中创建了名为TESTDB的数据库。
在TESTDB数据库中，您已创建了名为EMPLOYEE的数据表。
EMPLOYEE表的字段结构包含FIRST_NAME、LAST_NAME、AGE、SEX和INCOME。
连接TESTDB数据库所使用的用户名为“testuser”，密码为“test123”；您也可以根据实际需求设定其他用户名，或直接使用root用户及其密码。若需授予MySQL数据库用户权限，请使用Grant命令进行操作。
您的本地机器上已安装PyMySQL模块。

实例：

以下示例演示如何连接至MySQL的TESTDB数据库：

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute() 方法执行 SQL 查询 
cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()

print ("Database version : %s " % data)

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

创建数据库表

若数据库连接成功，我们可以使用execute()方法来创建数据表。如下所示，我们将创建EMPLOYEE表：

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute() 方法执行 SQL，如果表存在则删除
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 使用预处理语句创建表
sql = """CREATE TABLE EMPLOYEE (
 FIRST_NAME CHAR(20) NOT NULL,
 LAST_NAME CHAR(20),
 AGE INT, 
 SEX CHAR(1),
 INCOME FLOAT )"""

cursor.execute(sql)

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

数据库插入操作

以下示例演示如何执行SQL Insert语句，向EMPLOYEE表中插入一条记录：

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
 LAST_NAME, AGE, SEX, INCOME)
 VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
 # 执行sql语句
 cursor.execute(sql)
 # 提交到数据库执行
 db.commit()
except:
 # 如果发生错误则回滚
 db.rollback()

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

上述插入示例也可以采用如下参数化形式编写：

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 插入语句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
 LAST_NAME, AGE, SEX, INCOME) \
 VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
 ('Mac', 'Mohan', 20, 'M', 2000)
try:
 # 执行sql语句
 cursor.execute(sql)
 # 执行sql语句
 db.commit()
except:
 # 发生错误时回滚
 db.rollback()

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

数据库查询操作

在Python中查询MySQL数据时，使用fetchone()方法可获取单条数据，而使用fetchall()方法则可获取多条数据。

fetchone()：该方法用于获取查询结果集中的下一条数据，返回的结果集对象包含当前行的数据。
fetchall()：该方法用于接收并返回所有的结果行。
rowcount：这是一个只读属性，用于返回执行execute()方法后受影响的行数。

实例：

查询EMPLOYEE表中salary（工资）字段值大于1000的所有数据记录：

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
 WHERE INCOME > '%d'" % (1000)
try:
 # 执行SQL语句
 cursor.execute(sql)
 # 获取所有记录列表
 results = cursor.fetchall()
 for row in results:
 fname = row[0]
 lname = row[1]
 age = row[2]
 sex = row[3]
 income = row[4]
 # 打印结果
 print ("fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
 (fname, lname, age, sex, income ))
except:
 print ("Error: unable to fecth data")

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

数据库更新操作

更新操作用于修改数据表中的数据。以下示例演示如何将TESTDB表中SEX字段全部修改为'M'，并将AGE字段值递增1：

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1
 WHERE SEX = '%c'" % ('M')
try:
 # 执行SQL语句
 cursor.execute(sql)
 # 提交到数据库执行
 db.commit()
except:
 # 发生错误时回滚
 db.rollback()

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

删除操作

删除操作用于移除数据表中的数据。以下示例演示了如何删除EMPLOYEE表中AGE大于20的所有数据记录：

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 删除语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
 # 执行SQL语句
 cursor.execute(sql)
 # 提交修改
 db.commit()
except:
 # 发生错误时回滚
 db.rollback()

# 关闭连接
db.close()

执行事务

事务机制能够确保数据的一致性。

事务必须具备4个基本属性：原子性、一致性、隔离性、持久性，这通常被称为ACID特性。

原子性（atomicity）：一个事务被视为一个不可分割的工作单位，事务中包含的所有操作要么全部执行成功，要么全部不执行。
一致性（consistency）：事务必须使数据库从一个一致性状态变换到另一个一致性状态，且一致性紧密依赖于原子性。
隔离性（isolation）：一个事务的执行过程不应受到其他并发事务的干扰。即事务内部的操作及其使用的数据对其他并发事务是隔离的，并发执行的事务之间互不干扰。
持久性（durability）：持久性也称为永久性（permanence），指一旦事务提交，其对数据库中数据的修改就是永久性的，后续的其他操作或系统故障不应对其产生任何影响。

实例

# SQL删除记录语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
 # 执行SQL语句
 cursor.execute(sql)
 # 向数据库提交
 db.commit()
except:
 # 发生错误时回滚
 db.rollback()

对于支持事务的数据库，在Python数据库编程中，当游标建立之时，便自动开始了一个隐形的数据库事务。

commit()方法用于提交游标的所有更新操作，rollback()方法用于回滚当前游标的所有操作。每一个方法调用都会开始一个新的事务。

错误处理

异常	描述
Warning	当有严重警告时触发，例如插入数据是被截断等等。必须是StandardError的子类。
Error	警告以外所有其他错误类。必须是StandardError的子类。
InterfaceError	当有数据库接口模块本身的错误（而不是数据库的错误）发生时触发。必须是Error的子类。
DatabaseError	和数据库有关的错误发生时触发。必须是Error的子类。
DataError	当有数据处理时的错误发生时触发，例如：除零错误，数据超范围等等。必须是DatabaseError的子类。
OperationalError	指非用户控制的，而是操作数据库时发生的错误。例如：连接意外断开、数据库名未找到、事务处理失败、内存分配错误等等操作数据库是发生的错误。必须是DatabaseError的子类。
IntegrityError	完整性相关的错误，例如外键检查失败等。必须是DatabaseError子类。
InternamError	数据库的内部错误，例如游标（cursor）失效了、事务同步失败等等。必须是DatabaseError子类。
ProgrammingError	程序错误，例如数据表（table）没找到或已存在、SQL语句语法错误、参数数量错误等等。必须是DatabaseError的子类。
NotSupportedError	不支持错误，指使用了数据库不支持的函数或API等。例如在连接对象上使用rollback()函数，然而数据库并不支持事务或者事务已关闭。必须是DatabaseError的子类。