Python使用PyMySQL操作MySQL数据库的增删查改实战

江屿

发布时间：2026-10-15| 4人浏览过

原创

本文详细介绍如何使用Python的PyMySQL库连接MySQL数据库，实现数据的插入、删除、查询和更新操作。通过具体代码示例，演示了连接参数配置、游标使用、事务提交与回滚机制，以及常见SQL语句的Python封装方法，帮助开发者快速掌握数据库交互核心技能。

环境配置与工具准备

首先需要在本地环境中完成PyMySQL库的安装与基础配置，确保开发环境具备连接数据库所需的依赖支持。

安装该数据库管理工具后，我们将手动创建数据库、数据表及字段结构；虽然也可以通过代码自动创建，但手动操作有助于理解底层逻辑。

接下来演示数据插入操作，这是数据库交互的基础步骤。

数据插入操作实现


import pymysql
'''
host 主机名 这里是你的ip地址 
user 数据库账号
password 数据库密码
port 端口 mysql数据库端口
db 数据库名
基本语句
cursor = conn.cursor()#初始化一个游标对象

sql = "数据库操作语句"

cursor.execute(sql)#执行该语句

conn.commit()#关闭游标对象

cursor.close()#关闭数据库
rollback 回滚
'''
db = pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='text')
sql = "insert into text(id,name) values (1,'老王')"
#获取下标
cursor = db.cursor()
try:
    cursor.execute(sql)
    db.commit()
    print('插入成功')
except:
    db.rollback()
    db.close()

随后介绍数据删除功能，用于移除指定条件下的记录。

数据删除操作实现


import pymysql
'''
host 主机名 这里是你的ip地址 #本地为localhost

user 数据库账号
password 数据库密码
port 端口 mysql数据库端口
db 数据库名

基本语句
cursor = conn.cursor()#初始化一个游标对象

sql = "数据库操作语句"

cursor.execute(sql)#执行该语句

conn.commit()#关闭游标对象

cursor.close()#关闭数据库
rollback 回滚
'''
db = pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='text')
sql ="delete from text where id=1 and name='老王' "
#获取下标
cursor = db.cursor()
try:
    cursor.execute(sql)
    db.commit()
    print('删除成功')
except:
    db.rollback()
    db.close()

查询操作允许我们从数据库中检索所需信息，是数据获取的核心方式。

为了演示删除操作的效果，我们需要先插入两条测试数据，以便后续进行验证。

测试数据准备与查询操作


'''
host 主机名 这里是你的ip地址 
user 数据库账号
password 数据库密码
port 端口 mysql数据库端口
db 数据库名

基本语句
cursor = conn.cursor()#初始化一个游标对象

sql = "数据库操作语句"

cursor.execute(sql)#执行该语句

conn.commit()#关闭游标对象

cursor.close()#关闭数据库
rollback 回滚

'''
import pymysql
db = pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='text')
sql1 = "insert into text(id,name) values (1,'老李')"
sql2 = "insert into text(id,name) values (2,'老王')"
#获取下标
cursor = db.cursor()
try:
    cursor.execute(sql1)
    cursor.execute(sql2)
    db.commit()
    print('插入成功')
except:
    db.rollback()
    db.close()

再次强调查询功能，展示如何从已存在的数据中提取特定字段信息。

数据查询功能详解


'''
host 主机名 这里是你的ip地址 
user 数据库账号
password 数据库密码
port 端口 mysql数据库端口
db 数据库名

基本语句
cursor = conn.cursor()#初始化一个游标对象

sql = "数据库操作语句"

cursor.execute(sql)#执行该语句

conn.commit()#关闭游标对象

cursor.close()#关闭数据库
rollback 回滚

'''
import pymysql
db = pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='text')
sql = "select id,name from text "
#获取下标
cursor = db.cursor()
try:
    cursor.execute(sql)
    #查询
    result = cursor.fetchall()
    db.commit()
    print(f'查询成功数据为:{result}')
except:
    db.rollback()
    db.close()

最后介绍数据更新操作，用于修改现有记录的值。

数据更新操作实现


'''
host 主机名 这里是你的ip地址 
user 数据库账号
password 数据库密码
port 端口 mysql数据库端口
db 数据库名

基本语句
cursor = conn.cursor()#初始化一个游标对象

sql = "数据库操作语句"

cursor.execute(sql)#执行该语句

conn.commit()#关闭游标对象

cursor.close()#关闭数据库
rollback 回滚

'''

import pymysql
db = pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='text')
sql = "update text set name='小林' where id=1"
#获取下标
cursor = db.cursor()
try:
    cursor.execute(sql)
    db.commit()
    print(f'修改成功')

except:
    db.rollback()
    db.close()