Python3 实现mysql数据库连接池

1.需要使用到的相关模块

这里我使用的是pymysql模块和DBUtils模块,直接 pip install即可,mysqlclient模块操作基本是一样的

import pymysql  # 数据库连接
from DBUtils.PooledDB import PooledDB  # 用于数据库连接池

2.配置相关数据库连接信息

# 数据库配置信息一般是私有的
__config = {
    "host": "ip_address",
    "port": 3306,
    "user": "root",
    "password": "password",
    "database": "db_name"
}

3.建立数据库连接池

POOL = PooledDB(
    pymysql, 5,  # 连接池里的最少连接数
    **__config,
    setsession=['SET AUTOCOMMIT = 1']  # 设置线程池是否打开自动更新的配置
)

上面数据库连接池已经准备好了,每次用的时候只需要创建连接就可以了,可以把封装写在一个单独的模块里,每次需要用到的时候导入

4.连接数据库获取信息

# 获取数据库连接
db = POOL.connection()    
# 创建游标
cursor = db.cursor()
# 准备sql
sql = ""
# 执行sql
cursor.execute(sql)
# data = cursor.fetchall()   # 获取全部数据,返回列表
data = cursor.fetchone()[0]  # 获取一条数据
发布了20 篇原创文章 · 获赞 18 · 访问量 8358

猜你喜欢

转载自blog.csdn.net/wankcn/article/details/92084980