Python MySQL数据库连接池组件pymysqlpool详解

引言

pymysqlpool （本地下载）是数据库工具包中新成员，目的是能提供一个实用的数据库连接池中间件，从而避免在应用中频繁地创建和释放数据库连接资源。

功能

• 连接池本身是线程安全的，可在多线程环境下使用，不必担心连接资源被多个线程共享的问题；
• 提供尽可能紧凑的接口用于数据库操作；
• 连接池的管理位于包内完成，客户端可以通过接口获取池中的连接资源（返回 pymysql.Connection）；
• 将最大程度地与 dataobj 等兼容，便于使用；
• 连接池本身具备动态增加连接数的功能，即 max_pool_size 和 step_size 会用于控制每次增加的连接数和最大连接数；
• 连接池最大连接数亦动态增加，需要开启 enable_auto_resize 开关，此后当任何一次连接获取超时发生，均记为一次惩罚，并且将 max_pool_size 扩大一定倍数。
  

基本工作流程

注意，当多线程同时请求时，若池中没有可用的连接对象，则需要排队等待

• 初始化后优先创建 step_size 个连接对象，放在连接池中；
• 客户端请求连接对象，连接池会从中挑选最近没使用的连接对象返回（同时会检查连接是否正常）；
• 客户端使用连接对象，执行相应操作后，调用接口返回连接对象；
• 连接池回收连接对象，并将其加入池中的队列，供其它请求使用。
  

|--------|        |--------------|
|  | <==borrow connection object== | Pool manager |
| Client |        |    |
|  | ==return connection object==> | FIFO queue |
|--------|        |--------------|

参数配置

• pool_name: 连接池的名称，多种连接参数对应多个不同的连接池对象，多单例模式；
• host: 数据库地址
• user: 数据库服务器用户名
• password: 用户密码
• database: 默认选择的数据库
• port: 数据库服务器的端口
• charset: 字符集，默认为 ‘utf8'
• use_dict_cursor: 使用字典格式或者元组返回数据；
• max_pool_size: 连接池优先最大连接数；
• step_size: 连接池动态增加连接数大小；
• enable_auto_resize: 是否动态扩展连接池，即当超过 max_pool_size 时，自动扩展 max_pool_size；
• pool_resize_boundary: 该配置为连接池最终可以增加的上上限大小，即时扩展也不可超过该值；
• auto_resize_scale: 自动扩展 max_pool_size 的增益，默认为 1.5 倍扩展；
• wait_timeout: 在排队等候连接对象时，最多等待多久，当超时时连接池尝试自动扩展当前连接数；
• kwargs: 其他配置参数将会在创建连接对象时传递给 pymysql.Connection
  

使用示例

1、使用 cursor 上下文管理器（快捷方式，但每次获取都会申请连接对象，多次调用效率不高）：

from pymysqlpool import ConnectionPool
config = {
 'pool_name': 'test',
 'host': 'localhost',
 'port': 3306,
 'user': 'root',
 'password': 'root',
 'database': 'test'
}
def connection_pool():
 # Return a connection pool instance
 pool = ConnectionPool(**config)
 pool.connect()
 return pool
# 直接访问并获取一个 cursor 对象，自动 commit 模式会在这种方式下启用
with connection_pool().cursor() as cursor:
 print('Truncate table user')
 cursor.execute('TRUNCATE user')
 print('Insert one record')
 result = cursor.execute('INSERT INTO user (name, age) VALUES (%s, %s)', ('Jerry', 20))
 print(result, cursor.lastrowid)
 print('Insert multiple records')
 users = [(name, age) for name in ['Jacky', 'Mary', 'Micheal'] for age in range(10, 15)]
 result = cursor.executemany('INSERT INTO user (name, age) VALUES (%s, %s)', users)
 print(result)
 print('View items in table user')
 cursor.execute('SELECT * FROM user')
 for user in cursor:
  print(user)
 print('Update the name of one user in the table')
 cursor.execute('UPDATE user SET name="Chris", age=29 WHERE id = 16')
 cursor.execute('SELECT * FROM user ORDER BY id DESC LIMIT 1')
 print(cursor.fetchone())
 print('Delete the last record')
 cursor.execute('DELETE FROM user WHERE id = 16')

2、使用 connection 上下文管理器：

import pandas as pd
from pymysqlpool import ConnectionPool
config = {
 'pool_name': 'test',
 'host': 'localhost',
 'port': 3306,
 'user': 'root',
 'password': 'root',
 'database': 'test'
}
def connection_pool():
 # Return a connection pool instance
 pool = ConnectionPool(**config)
 pool.connect()
 return pool
with connection_pool().connection() as conn:
 pd.read_sql('SELECT * FROM user', conn)
# 或者
connection = connection_pool().borrow_connection()
pd.read_sql('SELECT * FROM user', conn)
connection_pool().return_connection(connection)

更多测试请移步 test_example.py。

依赖

• pymysql：将依赖该工具包完成数据库的连接等操作；
• pandas：测试时使用了 pandas。

安装

轻移步 pymysqlpool: https://github.com/ChrisLeeGit/pymysqlpool 下载源码（也可以通过本地下载），然后使用 pip 安装即可：pip3 setup.py install，注意需要使用 Python3 环境。

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对的支持。

# pymysql  # pool  # python  # mysql  # 数据库连接池  # Python中操作mysql的pymysql模块详解  # Python中模块pymysql查询结果后如何获取字段列表  # 在python中使用pymysql往mysql数据库中插入(insert)数据实例  # pymysql之cur.fetchall() 和cur.fetchone()用法详解  # Python使用pymysql从MySQL数据库中读出数据的方法  # python使用pymysql实现操作mysql  # pyMySQL SQL语句传参问题  # 单个参数或多个参数说明  # 详解使用pymysql在python中对mysql的增删改查操作(综合)  # Python中pymysql 模块的使用详解  # 封装一个python的pymysql操作类  # 连接池  # 连接数  # 池中  # 本地下载  # 多个  # 客户端  # 会在  # 工具包  # 可以通过  # 管理器  # 多线程  # 默认为  # 放在  # 最多  # 可在  # 不高  # 这篇文章  # 谢谢大家  # 提供一个  # 快捷方式 

相关文章： 表情包在线制作网站免费,表情包怎么弄？  英语简历制作免费网站推荐,如何将简历翻译成英文？  Python文件管理规范_工程实践说明【指导】  宁波免费建站如何选择可靠模板与平台？  如何选择高效稳定的ISP建站解决方案？  青岛网站建设如何选择本地服务器？  邀请函制作网站有哪些,有没有做年会邀请函的网站啊？在线制作，模板很多的那种？  南宁网站建设制作定制,南宁网站建设可以定制吗？  建站之星如何助力网站排名飙升？揭秘高效技巧  中山网站制作网页,中山新生登记系统登记流程？  如何制作一个表白网站视频,关于勇敢表白的小标题？  如何通过虚拟主机快速完成网站搭建？  官网建站费用明细查询_企业建站套餐价格及收费标准指南  宝盒自助建站智能生成技巧：SEO优化与关键词设置指南  制作网站公司那家好,网络公司是做什么的？  网站网页制作电话怎么打,怎样安装和使用钉钉软件免费打电话？  头像制作网站在线观看,除了站酷，还有哪些比较好的设计网站？  如何在Ubuntu系统下快速搭建WordPress个人网站？  php能控制zigbee模块吗_php通过串口与cc2530 zigbee通信【介绍】  上海制作企业网站有哪些,上海有哪些网站可以让企业免费发布招聘信息？  教学论文网站制作软件有哪些,写论文用什么软件 ？  如何用好域名打造高点击率的自主建站？  阿里云高弹*务器配置方案｜支持分布式架构与多节点部署  c# Task.Yield 的作用是什么 它和Task.Delay(1)有区别吗  已有域名能否直接搭建网站？  建站主机服务器选购指南：轻量应用与VPS配置解析  ppt在线制作免费网站推荐,有什么下载免费的ppt模板网站？  简单实现Android验证码  ,交易猫的商品怎么发布到网站上去？  建站主机选哪种环境更利于SEO优化？  如何用花生壳三步快速搭建专属网站？  c# 在ASP.NET Core中管理和取消后台任务  内网网站制作软件,内网的网站如何发布到外网？  制作网站的软件下载免费,今日头条开宝箱老是需要下载怎么回事？  大连网站制作公司哪家好一点,大连买房网站哪个好？  名字制作网站免费,所有小说网站的名字？  最好的网站制作公司,网购哪个网站口碑最好，推荐几个？谢谢？  平台云上自主建站：模板化设计与智能工具打造高效网站  手机网站制作与建设方案,手机网站如何建设？  建站之星代理商如何保障技术支持与售后服务？  建站上市公司网站建设方案与SEO优化服务定制指南  如何设置并定期更换建站之星安全管理员密码？  C++如何将C风格字符串（char*）转换为std::string？（代码示例）  无锡营销型网站制作公司,无锡网选车牌流程？  网站制作免费,什么网站能看正片电影？  香港服务器网站生成指南：免费资源整合与高速稳定配置方案  建站之星ASP如何实现CMS高效搭建与安全管理？  建站之星安装步骤有哪些常见问题？  临沂网站制作企业,临沂第三中学官方网站？  黑客入侵网站服务器的常见手法有哪些？