PythonMySQL数据库连接池组件pymysqlpool详解_python多线程写入mysql - CSDN文库

172 浏览量更新于2023-05-03 评论收藏 87KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

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'

}

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余1页未读，立即下载

评论0

weixin_38725450

粉丝: 1
资源: 913

会员权益专享

图片转文字

全年可省5，000元立即开通

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈