Python使用连接池操作MySQL

测试环境说明:Python版本是 3.8.10 ,DBUtils版本是3.1.0 ,pymysql版本是1.0.3

  1. 首先安装指定版本的连接池库DBUtils 、还有pymysql
pip install DBUtils==3.1.0
pip install pymysql==1.0.3
  1. 创建文件 sqlConfig.py
# sqlConfig.pyimport pymysql
from dbutils.pooled_db import PooledDB
# 有些版本使用下面语句引入,要注意一下
# from DBUtils.PooledDB import PooledDBhost = '127.0.0.1'
port = 3306
user = 'myname'
password = 'mypass'
database = 'contest'class MySQLConnectionPool:def __init__(self,):self.pool = PooledDB(creator=pymysql,  # 使用链接数据库的模块mincached=10,  # 初始化时,链接池中至少创建的链接,0表示不创建maxconnections=200,  # 连接池允许的最大连接数,0和None表示不限制连接数blocking=True,  # 连接池中如果没有可用连接后,是否阻塞等待。True,等待;False,不等待然后报错host=host,port=port,user=user,password=password,database=database)def open(self):self.conn = self.pool.connection()self.cursor = self.conn.cursor(cursor=pymysql.cursors.DictCursor)  # 表示读取的数据为字典类型return self.conn, self.cursordef close(self, cursor, conn):cursor.close()conn.close()def select_one(self, sql, *args):"""查询单条数据"""conn, cursor = self.open()cursor.execute(sql, args)result = cursor.fetchone()self.close(conn, cursor)return resultdef select_all(self, sql, args):"""查询多条数据"""conn, cursor = self.open()cursor.execute(sql, args)result = cursor.fetchall()self.close(conn, cursor)return resultdef insert_one(self, sql, args):"""插入单条数据"""self.execute(sql, args, isNeed=True)def insert_all(self, sql, datas):"""插入多条批量插入"""conn, cursor = self.open()try:cursor.executemany(sql, datas)conn.commit()return {'result': True, 'id': int(cursor.lastrowid)}except Exception as err:conn.rollback()return {'result': False, 'err': err}def update_one(self, sql, args):"""更新数据"""self.execute(sql, args, isNeed=True)def delete_one(self, sql, *args):"""删除数据"""self.execute(sql, args, isNeed=True)def execute(self, sql, args, isNeed=False):"""执行:param isNeed 是否需要回滚"""conn, cursor = self.open()if isNeed:try:cursor.execute(sql, args)conn.commit()except:conn.rollback()else:cursor.execute(sql, args)conn.commit()self.close(conn, cursor)
  1. 创建文件 sqlTest.py ,并引入sqlConfig.py使用
# sqlTest.py# 引入连接池类
from sqlConfig import MySQLConnectionPool# 创建连接池对象
ConnPool = MySQLConnectionPool()# 模糊查询
strSelectAll = "select * from names where name like %s"
results = ConnPool.select_all(strSelectAll, ('%唐%',))
print(results)# 精确查询
# strSelectAll = "select * from names where name=%s"
# results = ConnPool.select_all(strSelectAll, ('唐三',))
# print(results)# 单条查询
# strSelectOne = 'select * from `names` where `name`=%s'
# results = ConnPool.select_one(strSelectOne, ('唐三',))
# print(results)# 单条插入
# strInsertOne = "insert into `names` (`name`, sex, age) values (%s,%s,%s)"
# ConnPool.insert_one(strInsertOne, ('唐三', '男', 22))# 批量插入
# datas = [
#     ('戴沐白', '男', 26),
#     ('奥斯卡', '男', 26),
#     ('唐三', '男', 25),
#     ('小舞', '女', 100000),
#     ('马红俊', '男', 23),
#     ('宁荣荣', '女', 22),
#     ('朱竹清', '女', 21),
# ]
# sql_insert_all = "insert into `names` (`name`, sex, age) values (%s,%s,%s)"
# ConnPool.insert_all(sql_insert_all, datas)# sql_update_one = "update `names` set age=%s where `name`=%s"
# ConnPool.update_one(sql_update_one, (28, '唐三'))# sql_delete_one = 'delete from `names` where `name`=%s '
# ConnPool.delete_one(sql_delete_one, ('唐三',))

运行代码
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/15085.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Math类

类 Math 包含执行基本数值运算的方法,例如基本指数、对数、平方根和三角函数。下面是我写代码时用到的一些字段和方法,归纳如下。 字段 修饰符和类型 Field描述static final double Edouble 值比任何其他值都更接近e, 自然对数的底…

YOLOv10论文解读:实时端到端的目标检测模型

《博主简介》 小伙伴们好,我是阿旭。专注于人工智能、AIGC、python、计算机视觉相关分享研究。 ✌更多学习资源,可关注公-仲-hao:【阿旭算法与机器学习】,共同学习交流~ 👍感谢小伙伴们点赞、关注! 《------往期经典推…

618购物节快递量激增,EasyCVR视频智能分析助力快递网点智能升级

随着网络618购物节的到来,物流仓储与快递行业也迎来业务量暴增的情况。驿站网点和快递门店作为物流体系的重要组成部分,其安全性和运营效率日益受到关注。为了提升这些场所的安全防范能力和服务水平,实施视频智能监控方案显得尤为重要。 一、…

蓝桥杯嵌入式国赛笔记(2):拓展板按键程序设计

目录 1、前言 2、电路原理 3、代码编写 3.1 读取Btn电压 3.2 检索按键 3.3 main文件编写 3.3.1 进行变量定义 3.3.2 AD_Key函数 3.3.3 LCD函数 3.3.4 main函数 3.3.5 完整代码 4、测试 5、总结 1、前言 本文进行拓展板按键程序设计,拓展板的按键是通…

人生苦短,我学python之数据类型(下)

个人主页:星纭-CSDN博客 系列文章专栏:Python 踏上取经路,比抵达灵山更重要!一起努力一起进步! 目录 一.集合 1.1子集与超集 1.2交集,并集,补集,差集 1.intersection(英文&a…

webman使用summernote富文本编辑器

前言 Summernote富文本编辑器功能强大,可以直接从word直接复制内容过来而不破坏原有的文档格式,非常适合做商品详情等内容的编辑工具。本文将展示如何在php高性能框架webman中使用summernote编辑器。 下载 去Bootstrap 中文网、Summernote、jQuery官网…

【设计模式】JAVA Design Patterns——Converter(转换器模式)

🔍目的 转换器模式的目的是提供相应类型之间双向转换的通用方法,允许进行干净的实现,而类型之间无需相互了解。此外,Converter模式引入了双向集合映射,从而将样板代码减少到最少 🔍解释 真实世界例子 在真实…

低代码开发:拖拽式可视化构建工业物联网系统

什么是低代码? 低代码(Low Code)是一种可视化的软件开发方法,通过最少的手动编码可以更快地交付应用程序。低代码平台的图形用户界面和拖放功能可自动执行开发过程的各个方面,从而消除对传统计算机编程方法的依赖。 什么是低代码平台&#…

Pandas 创建层次化索引

1.创建多层次索引 1.1 隐式构造 最常见的方法是给DataFrame构造函数的index参数传递两个或更多的数组 # 导入pandasimport numpy as npimport pandas as pd​data np.random.randint(0,100,size(6,6))​# 行索引index [ ["1班","1班","1班&qu…

如何合理设置Java线程池大小

如何合理设置Java线程池大小:依据任务类型定制策略 Java线程池的合理配置直接关系到系统性能和资源利用率。根据任务性质的不同,合理的线程池大小设置策略也有所区别,主要包括CPU密集型、IO密集型及混合型任务。 1. CPU密集型任务 特点&am…

【全网最全】2024电工杯数学建模B题53页成品论文+完整matlab代码+完整python代码+数据预处理+可视化结果等(后续会更新)

您的点赞收藏是我继续更新的最大动力! 一定要点击如下的卡片链接,那是获取资料的入口! 【全网最全】2024电工杯数学建模B题53页成品论文完整matlab、py代码19建模过程代码数据等(后续会更新)「首先来看看目前已有的资…

微软新功能Recall引发隐私担忧,英国数据监管机构展开调查

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗?订阅我们的简报,深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同,从行业内部的深度分析和实用指南中受益。不要错过这个机会,成为AI领…

AP5163 是一款效率高,稳定可靠的 LED 灯恒流驱动控制芯片.

AP5163 特别内置了一个 LDO、其输出电压为 5V,最大可提供 5ma 电流输出。AP5163 采用小 SOT23-6 封装。特别适合宽输入电压范围的应用,其输入电压范围从 5.5V 到 36V。 AP5163 通过一个外接电阻设定输出电流,最大输出电流 3.5A。电流检测精度…

Vue小程序项目知识积累(一)

1.JS中的substring() 方法: substring() 方法用于提取字符串中介于两个指定下标之间的字符,包括空格键。 substring() 方法返回的子串包括 开始 处的字符,但不包括 结束 处的字符。 string.substring(from, to) from:必需。一个非负的整数…

头歌OpenGauss数据库-F.连接查询与子查询第3关:IN、ANY、ALL嵌套子查询

编程要求 我们为你提供了如下数据表: tb_salary表数据: idpositionsalary1Java80002Java84003Java90004Python65005Python10000 根据提供的数据,在右侧编辑器中补充代码: 查询薪资表中比Java最高工资高的所有员工职位名称和薪资&a…

[Spring Cloud] (9)XSS拦截器

文章目录 简述本文涉及代码已开源Fir Cloud 完整项目防XSS攻击必要性:作用: 整体效果后端增加拦截器开关配置pom中增加jsoup依赖添加JSON处理工具类添加xss拦截工具类防XSS-请求拦截器 前端 简述 本文涉及代码已开源 本文网关gateway,微服务…

微调LLM的理由

原文链接:https://www.freddyboulton.com/blog/when-to-finetune?continueFlag03133d546a002fc4ba73dda1632eeebe 考虑到大语言模型(llama 70b, mixtral, claude...)的能力在不断的增强的情况下,微调是否仍然是值得做的事。 下面是值得微调的一些原因…

医疗大模型和数据集整理

医疗大模型整理 LLM 类型 基座模型 持续预训练/Finetune 评估 ClinicalGPT 论文 BLOOM-7B cMedQA2, cMedQA-KG, MD-EHR, MEDQA-MCMLE, and MedDialog MedDialog MEDQA-MCMLE MD-HER cMedQA2 HuatuoGPT 论文+开源项目 Baichuan-7B Ziya-LLaMA-13B-Pretrain-v1 Distilled Instru…

Visual Studio Code插件

文章目录 工具类AIChinese (Simplified) (简体中文)cmake集Code RunnerGitLens — Git superchargedPath IntellisenseTodo TreeBookmarks (书签)markdownclangd 美化类Output Colorizer (输出窗口彩色)Doxygen Documentation Gen…

人工智能和机器学习辅助决策在空战中的未来选择

人工智能(AI)和机器学习在空战决策中的未来选择主要体现在以下几个方面: 自主决策系统:通过训练AI模型,使其具备自主决策能力。这种系统能够根据战场态势的变化,自主做出决策,并实时调整作战计划。例如,AI可以预测敌方空中机动路线,生成全面的近实时空中画面,为指挥官…