当前位置:主页 > python教程 >

Python MySQL数据库中pymysqlpool是如何使用的?

发布:2022-06-22 06:37:21 123


给大家整理一篇Python相关的编程文章,网友权源源根据主题投稿了本篇教程内容,涉及到pymysqlpool、Python、MySQL相关内容,已被645网友关注,内容中涉及的知识点可以在下方直接下载获取。

这篇文章主要跟大家介绍了关于Python MySQL数据库连接池组件pymysqlpool的相关资料,文中通过示例代码介绍的非常详细,对大家具有一定的参考学习价值,需要的朋友们下面来一起看看吧。

引言

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

Python MySQL数据库中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。

以上就是Python MySQL数据库中pymysqlpool是如何使用的?的详细内容,更多请关注码农之家其它相关文章!


相关文章

  • Python+MySQL随机试卷及答案生成程序的实力分析

    发布:2021-08-26

    这篇文章主要介绍了Python+MySQL随机试卷及答案生成程序的示例代码,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下


  • Python备份MySQL数据库的代码详解

    发布:2020-01-04

    这篇文章主要介绍了Python实现备份MySQL数据库的方法,涉及Python针对mysql数据库的连接及基于mysqldump命令操作数据库备份的相关实现技巧,需要的朋友可以参考下


  • python3 pandas 如何读取MySQL数据和插入

    发布:2020-02-19

    下面为大家分享一篇python3 pandas 读取MySQL数据和插入的实例,具有很好的参考价值,希望对大家有所帮助。一起过来看看吧


  • python3.4用函数操作mysql5.7方法

    发布:2020-05-05

    1 #!/usr/bin/env python 2 # -*- coding:utf-8 -*- 3 # __author__ =


  • Python配置mysql的详细步骤方法

    发布:2020-05-28

    下面小编就为大家带来一篇Python配置mysql的教程(推荐)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧


  • Python实现 多进程导入CSV数据到 MySQL

    发布:2022-04-21

    本文给大家分享的是使用python实现多进程导入CSV文件数据到MySQL的思路方法以及具体的代码分享,有相同需求的小伙伴可以参考下


  • python3 用ssh隧道连接mysql的操作

    发布:2021-05-07

    这篇文章主要介绍了python3 使用ssh隧道连接mysql的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧


网友讨论