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 |
|--------| |--------------|
参数配置
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。
依赖
安装
轻移步 pymysqlpool: https://github.com/ChrisLeeGit/pymysqlpool 下载源码（也可以通过本地下载），然后使用 pip 安装即可：pip3 setup.py install，注意需要使用 Python3 环境。
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对软件开发网的支持。
您可能感兴趣的文章:Python操作MySQL数据库9个实用实例python Django连接MySQL数据库做增删改查python连接mysql数据库示例(做增删改操作)Python连接mysql数据库的正确姿势Python如何读取MySQL数据库表数据Python的mysql数据库的更新如何实现python操作MySQL数据库的方法分享python3使用PyMysql连接mysql数据库实例Python3实现的Mysql数据库操作封装类Python3实现将本地JSON大数据文件写入MySQL数据库的方法python针对mysql数据库的连接、查询、更新、删除操作示例
