- 当前位置：首页 >IT科技 >太全了！用Python操作MySQL的使用教程集锦！
太全了！用Python操作MySQL的使用教程集锦！
发布时间：2025-11-05 13:36:39 来源：码上建站 作者：域名
一. python操作数据库介绍
Python 标准数据库接口为 Python DB-API，太全Python DB-API为开发人员提供了数据库应用编程接口。用P用教Python 数据库接口支持非常多的操程集数据库，你可以选择适合你项目的太全数据库：
GadFly
mSQL
MySQL
PostgreSQL
Microsoft SQL Server 2000
Informix
Interbase
Oracle
Sybase …
你可以访问Python数据库接口及API查看详细的支持数据库列表。
不同的用P用教数据库你需要下载不同的DB API模块，例如你需要访问Oracle数据库和Mysql数据，操程集你需要下载Oracle和MySQL数据库模块。太全
DB-API 是用P用教一个规范. 它定义了一系列必须的对象和数据库存取方式, 以便为各种各样的底层数据库系统和多种多样的数据库接口程序提供一致的访问接口 。
Python的操程集DB-API，为大多数的太全数据库实现了接口，使用它连接各数据库后，用P用教就可以用相同的操程集方式操作各数据库。
Python DB-API使用流程：
引入 API 模块。太全
获取与数据库的用P用教连接。
执行SQL语句和存储过程。操程集
关闭数据库连接。
二. python操作MySQL模块
Python操作MySQL主要使用两种方式：
DB模块(原生SQL)
PyMySQL(支持python2.x/3.x)
MySQLdb(目前仅支持python2.x)
ORM框架
SQLAchemy
2.1 PyMySQL模块
本文主要介绍PyMySQL模块,MySQLdb使用方式类似
2.1.1 安装PyMySQL
PyMySQL是一个Python编写的MySQL驱动程序，让我们可以用Python语言操作MySQL数据库。亿华云
pip install PyMySQL2.2 基本使用
#! /usr/bin/env python
# -*- coding: utf-8 -*-
# __author__ = "shuke"
# Date: 2018/5/13
import pymysql
# 创建连接
conn = pymysql.connect(host="127.0.0.1", port=3306, user=zff, passwd=zff123, db=zff, charset=utf8mb4)
# 创建游标(查询数据返回为元组格式)
# cursor = conn.cursor()
# 创建游标(查询数据返回为字典格式)
cursor = conn.cursor(pymysql.cursors.DictCursor)
# 1. 执行SQL,返回受影响的行数
effect_row1 = cursor.execute("select * from USER")
# 2. 执行SQL,返回受影响的行数,一次插入多行数据
effect_row2 = cursor.executemany("insert into USER (NAME) values(%s)", [("jack"), ("boom"), ("lucy")]) # 3
# 查询所有数据,返回数据为元组格式
result = cursor.fetchall()
# 增/删/改均需要进行commit提交,进行保存
conn.commit()
# 关闭游标
cursor.close()
# 关闭连接
conn.close()
print(result)
"""
[{id: 6, name: boom}, {id: 5, name: jack}, {id: 7, name: lucy}, {id: 4, name: tome}, {id: 3, name: zff}, {id: 1, name: zhaofengfeng}, {id: 2, name: zhaofengfeng02}]
"""2.3 获取最新创建的数据自增ID
#! /usr/bin/env python
# -*- coding: utf-8 -*-
# __author__ = "shuke"
# Date: 2018/5/13
import pymysql
# 创建连接
conn = pymysql.connect(host="127.0.0.1", port=3306, user=zff, passwd=zff123, db=zff, charset=utf8mb4)
# 创建游标(查询数据返回为元组格式)
cursor = conn.cursor()
# 获取新创建数据自增ID
effect_row = cursor.executemany("insert into USER (NAME)values(%s)", [("eric")])
# 增删改均需要进行commit提交
conn.commit()
# 关闭游标
cursor.close()
# 关闭连接
conn.close()
new_id = cursor.lastrowid
print(new_id)
"""
8
"""2.4 查询操作
#! /usr/bin/env python
# -*- coding: utf-8 -*-
# __author__ = "shuke"
# Date: 2018/5/13
import pymysql
# 创建连接
conn = pymysql.connect(host="127.0.0.1", port=3306, user=zff, passwd=zff123, db=zff, charset=utf8mb4)
# 创建游标
cursor = conn.cursor()
cursor.execute("select * from USER")
# 获取第一行数据
row_1 = cursor.fetchone()
# 获取前n行数据
row_2 = cursor.fetchmany(3)
#
# # 获取所有数据
row_3 = cursor.fetchall()
# 关闭游标
cursor.close()
# 关闭连接
conn.close()
print(row_1)
print(row_2)
print(row_3)⚠️ 在fetch数据时按照顺序进行，可以使用cursor.scroll(num,mode)来移动游标位置，如：
cursor.scroll(1,mode=relative) # 相对当前位置移动
cursor.scroll(2,mode=absolute) # 相对绝对位置移动
2.5 防止SQL注入
#! /usr/bin/env python
# -*- coding: utf-8 -*-
# __author__ = "shuke"
# Date: 2018/5/13
import pymysql
# 创建连接
conn = pymysql.connect(host="127.0.0.1", port=3306, user=zff, passwd=zff123, db=zff, charset=utf8mb4)
# 创建游标
cursor = conn.cursor()
# 存在sql注入情况(不要用格式化字符串的方式拼接SQL)
sql = "insert into USER (NAME) values(%s)" % (zhangsan,)
effect_row = cursor.execute(sql)
# 正确方式一
# execute函数接受一个元组/列表作为SQL参数,元素个数只能有1个
sql = "insert into USER (NAME) values(%s)"
effect_row1 = cursor.execute(sql, [wang6])
effect_row2 = cursor.execute(sql, (wang7,))
# 正确方式二
sql = "insert into USER (NAME) values(%(name)s)"
effect_row1 = cursor.execute(sql, {name: wudalang})
# 写入插入多行数据
effect_row2 = cursor.executemany("insert into USER (NAME) values(%s)", [(ermazi), (dianxiaoer)])
# 提交
conn.commit()
# 关闭游标
cursor.close()
# 关闭连接
conn.close()这样，SQL操作就更安全了。如果需要更详细的文档参考PyMySQL文档吧。不过好像这些SQL数据库的实现还不太一样，PyMySQL的参数占位符使用%s这样的C格式化符，而Python自带的sqlite3模块的占位符好像是问号(?)。因此在使用其他数据库的时候还是仔细阅读文档吧。Welcome to PyMySQL’s documentation
三. 数据库连接池
上文中的方式存在一个问题,单线程情况下可以满足,程序需要频繁的创建释放连接来完成对数据库的操作,那么,我们的程序/脚本在多线程情况下会引发什么问题呢?此时,我们就需要使用数据库连接池来解决这个问题!
3.1 DBUtils模块
DBUtils是Python的一个用于实现数据库连接池的模块。
此连接池有两种连接模式：
为每个线程创建一个连接，线程即使调用了close方法，也不会关闭，b2b信息网只是把连接重新放到连接池，供自己线程再次使用。当线程终止时，连接才会自动关闭
创建一批连接到连接池，供所有线程共享使用(推荐使用)
3.2 模式一
#! /usr/bin/env python
# -*- coding: utf-8 -*-
# __author__ = "shuke"
# Date: 2018/5/13
from DBUtils.PersistentDB import PersistentDB
import pymysql
POOL = PersistentDB(
creator=pymysql, # 使用链接数据库的模块
maxusage=None, # 一个链接最多被重复使用的次数，None表示无限制
setsession=[], # 开始会话前执行的命令列表。如：["set datestyle to ...", "set time zone ..."]
ping=0,
# ping MySQL服务端，检查是否服务可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
closeable=False,
# 如果为False时， conn.close() 实际上被忽略，供下次使用，再线程关闭时，才会自动关闭链接。如果为True时， conn.close()则关闭链接，那么再次调用pool.connection时就会报错，因为已经真的关闭了连接（pool.steady_connection()可以获取一个新的链接）
threadlocal=None, # 本线程独享值得对象，用于保存链接对象，如果链接对象被重置
host=127.0.0.1,
port=3306,
user=zff,
password=zff123,
database=zff,
charset=utf8,
)
def func():
conn = POOL.connection(shareable=False)
cursor = conn.cursor()
cursor.execute(select * from USER)
result = cursor.fetchall()
cursor.close()
conn.close()
return result
result = func()
print(result)3.2 模式二
#! /usr/bin/env python
# -*- coding: utf-8 -*-
# __author__ = "shuke"
# Date: 2018/5/13
import time
import pymysql
import threading
from DBUtils.PooledDB import PooledDB, SharedDBConnection
POOL = PooledDB(
creator=pymysql, # 使用链接数据库的模块
maxconnections=6, # 连接池允许的最大连接数，0和None表示不限制连接数
mincached=2, # 初始化时，链接池中至少创建的空闲的链接，0表示不创建
maxcached=5, # 链接池中最多闲置的云服务器链接，0和None不限制
maxshared=3,
# 链接池中最多共享的链接数量，0和None表示全部共享。PS: 无用，因为pymysql和MySQLdb等模块的 threadsafety都为1，所有值无论设置为多少，_maxcached永远为0，所以永远是所有链接都共享。
blocking=True, # 连接池中如果没有可用连接后，是否阻塞等待。True，等待；False，不等待然后报错
maxusage=None, # 一个链接最多被重复使用的次数，None表示无限制
setsession=[], # 开始会话前执行的命令列表。如：["set datestyle to ...", "set time zone ..."]
ping=0,
# ping MySQL服务端，检查是否服务可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
host=127.0.0.1,
port=3306,
user=zff,
password=zff123,
database=zff,
charset=utf8
)
def func():
# 检测当前正在运行连接数的是否小于最大链接数，如果不小于则：等待或报raise TooManyConnections异常
# 否则
# 则优先去初始化时创建的链接中获取链接 SteadyDBConnection。
# 然后将SteadyDBConnection对象封装到PooledDedicatedDBConnection中并返回。
# 如果最开始创建的链接没有链接，则去创建一个SteadyDBConnection对象，再封装到PooledDedicatedDBConnection中并返回。
# 一旦关闭链接后，连接就返回到连接池让后续线程继续使用。
conn = POOL.connection()
# print(连接被拿走了, conn._con)
# print(池子里目前有, POOL._idle_cache, \r\n)
cursor = conn.cursor()
cursor.execute(select * from USER)
result = cursor.fetchall()
conn.close()
return result
result = func()
print(result)⚠️ 由于pymysql、MySQLdb等threadsafety值为1，所以该模式连接池中的线程会被所有线程共享,因此是线程安全的。如果没有连接池，使用pymysql来连接数据库时，单线程应用完全没有问题，但如果涉及到多线程应用那么就需要加锁，一旦加锁那么连接势必就会排队等待，当请求比较多时，性能就会降低了。
3.3 加锁
#! /usr/bin/env python
# -*- coding: utf-8 -*-
# __author__ = "shuke"
# Date: 2018/5/13
import pymysql
import threading
from threading import RLock
LOCK = RLock()
CONN = pymysql.connect(host=127.0.0.1,
port=3306,
user=zff,
password=zff123,
database=zff,
charset=utf8)
def task(arg):
with LOCK:
cursor = CONN.cursor()
cursor.execute(select * from USER )
result = cursor.fetchall()
cursor.close()
print(result)
for i in range(10):
t = threading.Thread(target=task, args=(i,))
t.start()3.4 无锁(报错)
#! /usr/bin/env python
# -*- coding: utf-8 -*-
# __author__ = "shuke"
# Date: 2018/5/13
import pymysql
import threading
CONN = pymysql.connect(host=127.0.0.1,
port=3306,
user=zff,
password=zff123,
database=zff,
charset=utf8)
def task(arg):
cursor = CONN.cursor()
cursor.execute(select * from USER )
# cursor.execute(select sleep(10))
result = cursor.fetchall()
cursor.close()
print(result)
for i in range(10):
t = threading.Thread(target=task, args=(i,))
t.start()此时可以在数据库中查看连接情况: show status like Threads%;
四. 数据库连接池结合pymsql使用
# cat sql_helper.py
import pymysql
import threading
from DBUtils.PooledDB import PooledDB, SharedDBConnection
POOL = PooledDB(
creator=pymysql, # 使用链接数据库的模块
maxconnections=20, # 连接池允许的最大连接数，0和None表示不限制连接数
mincached=2, # 初始化时，链接池中至少创建的空闲的链接，0表示不创建
maxcached=5, # 链接池中最多闲置的链接，0和None不限制
#maxshared=3, # 链接池中最多共享的链接数量，0和None表示全部共享。PS: 无用，因为pymysql和MySQLdb等模块的 threadsafety都为1，所有值无论设置为多少，_maxcached永远为0，所以永远是所有链接都共享。
blocking=True, # 连接池中如果没有可用连接后，是否阻塞等待。True，等待；False，不等待然后报错
maxusage=None, # 一个链接最多被重复使用的次数，None表示无限制
setsession=[], # 开始会话前执行的命令列表。如：["set datestyle to ...", "set time zone ..."]
ping=0,
# ping MySQL服务端，检查是否服务可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
host=192.168.11.38,
port=3306,
user=root,
passwd=apNXgF6RDitFtDQx,
db=m2day03db,
charset=utf8
)
def connect():
# 创建连接
# conn = pymysql.connect(host=192.168.11.38, port=3306, user=root, passwd=apNXgF6RDitFtDQx, db=m2day03db)
conn = POOL.connection()
# 创建游标
cursor = conn.cursor(pymysql.cursors.DictCursor)
return conn,cursor
def close(conn,cursor):
# 关闭游标
cursor.close()
# 关闭连接
conn.close()
def fetch_one(sql,args):
conn,cursor = connect()
# 执行SQL，并返回收影响行数
effect_row = cursor.execute(sql,args)
result = cursor.fetchone()
close(conn,cursor)
return result
def fetch_all(sql,args):
conn, cursor = connect()
# 执行SQL，并返回收影响行数
cursor.execute(sql,args)
result = cursor.fetchall()
close(conn, cursor)
return result
def insert(sql,args):
"""
创建数据
:param sql: 含有占位符的SQL
:return:
"""
conn, cursor = connect()
# 执行SQL，并返回收影响行数
effect_row = cursor.execute(sql,args)
conn.commit()
close(conn, cursor)
def delete(sql,args):
"""
创建数据
:param sql: 含有占位符的SQL
:return:
"""
conn, cursor = connect()
# 执行SQL，并返回收影响行数
effect_row = cursor.execute(sql,args)
conn.commit()
close(conn, cursor)
return effect_row
def update(sql,args):
conn, cursor = connect()
# 执行SQL，并返回收影响行数
effect_row = cursor.execute(sql, args)
conn.commit()
close(conn, cursor)
return effect_rowPS: 可以利用静态方法封装到一个类中,方便使用
- 小米MIX速度如何？（小米MIX的性能测试及用户反馈）
- 剪映无缝剪辑教程（掌握剪映无缝剪辑技巧，打造专业级视频制作）
- Dell电脑错误提示（有效的关闭Dell电脑错误提示，让您的电脑更加高效运行）
- 电脑显示电池信息错误（探究电脑显示电池信息错误的原因与解决方法）
- 三星手表Gear3（功能强大，设计精致，让您与科技时尚同行）
- 年富供应链（以年富供应链为例，探索供应链管理的关键要素和创新点）
- 华为导航（华为导航带来更智能、便捷的导航体验）
- 如何将台式电脑旧主机改装为高性能电脑（改装教程分享，让旧主机焕发新生）
- 小米6安卓系统评测——性能优越，操作流畅稳定（一款高性价比手机中的安卓之王）
- 教你如何设置台式电脑每天定时关机（轻松掌握定时关机技巧，提高电脑使用效率）
- 以WinPE制作教程（从安装到使用，一步步教你打造最佳BT下载利器）
- 盛大手机怎么样？（详细评测及用户反馈）
- 微软电脑在设计领域的应用优势（探索微软电脑在设计领域的多功能性与创新性）
- 电脑编程入门（从零开始学编程，轻松掌握计算机世界的奥秘）
- 如何挑选合适的主板（以品质、性能和兼容性为关键，选择最佳主板）
- 以西沃电脑升级系统教程（简单易懂的升级系统指南，提升电脑性能）
- 蒙娜丽莎的真实面貌（解读蒙娜丽莎的面容之谜，探究她神秘微笑背后的故事）
- 三星手机S6质量评测（用心打造的高质量手机——三星手机S6）
- 揭秘电脑键盘数据输入错误的背后（寻找数据输入错误的关键因素和解决办法）
- 神舟主机（打造无与伦比的电脑游戏体验）
随便看看
- Copyright © 2025 Powered by 太全了！用Python操作MySQL的使用教程集锦！,码上建站 滇ICP备2023006006号-47sitemap