数据库连接池DBUtils的安装使用方法

pip install dbutils

import MySQLdb
from dbutils.pooled_db import PooledDB

# 创建数据库连接池
pool = PooledDB(
    creator=MySQLdb,    # 数据库驱动，使用 MySQLdb 连接 MySQL 数据库
    maxconnections=10,   # 连接池中允许的最大连接数
    mincached=2,         # 初始化时创建的空闲连接数
    maxcached=5,         # 连接池中空闲连接的最大数量
    maxshared=3,         # 连接池中共享连接的最大数目
    blocking=True,       # 如果没有可用连接时，是否阻塞等待
    host='localhost',    # 数据库主机地址
    user='your_username',# 数据库用户名
    passwd='your_password', # 数据库密码
    db='your_database',  # 数据库名
    port=3306            # 数据库端口
)

# 从连接池获取一个连接
conn = pool.connection()

# 获取游标
cursor = conn.cursor()

# 执行查询操作
try:
    cursor.execute("SELECT * FROM your_table")
    result = cursor.fetchall()
    for row in result:
        print(row)
finally:
    cursor.close()  # 关闭游标
    conn.close()    # 将连接归还到连接池

conn = pool.connection()
cursor = conn.cursor()

try:
    cursor.execute("INSERT INTO your_table (col1, col2) VALUES (%s, %s)", ('value1', 'value2'))
    conn.commit()  # 提交事务
finally:
    cursor.close()
    conn.close()

conn = pool.connection()
cursor = conn.cursor()

try:
    cursor.execute("UPDATE your_table SET col1 = %s WHERE col2 = %s", ('new_value', 'value2'))
    conn.commit()  # 提交事务
finally:
    cursor.close()
    conn.close()

try:
    conn = pool.connection()
    cursor = conn.cursor()
    cursor.execute("SELECT * FROM your_table")
    result = cursor.fetchall()
    for row in result:
        print(row)
except Exception as e:
    print(f"An error occurred: {e}")
finally:
    cursor.close()
    conn.close()