导入MySQL数据库连接所需的库
import mysql.connector
from mysql.connector import pooling
配置数据库连接池参数
config = {
'user': 'your_username', # 数据库用户名
'password': 'your_password', # 数据库密码
'host': 'your_host', # 数据库主机地址
'database': 'your_database', # 数据库名
'raise_on_warnings': True,
'pool_name': 'mypool',
'pool_size': 5 # 连接池大小,可根据实际情况调整
}
创建数据库连接池
connection_pool = pooling.MySQLConnectionPool(pool_name=config['pool_name'],
pool_size=config['pool_size'],
**config)
测试连接池
try:
# 从连接池中获取连接
connection = connection_pool.get_connection()
cursor = connection.cursor()
# 创建数据库(如果数据库不存在)
cursor.execute("CREATE DATABASE IF NOT EXISTS your_database")
# 提交事务
connection.commit()
# 关闭游标和连接
cursor.close()
connection.close()
print("数据库连接池创建成功,并且数据库已创建或确认存在。")
except mysql.connector.Error as error:
print(f"数据库连接池创建失败或发生错误: {error}")
finally:
# 关闭连接池
if connection_pool is not None:
connection_pool.closeall()
print("数据库连接池已关闭。")