python mysql连接池

# 导入所需的库
import mysql.connector
from mysql.connector import pooling

# 创建连接池
try:
    # 配置数据库连接参数
    dbconfig = {
        "host": "localhost",
        "user": "root",
        "password": "password",
        "database": "testdb"
    }

    # 创建连接池，最多5个连接
    connection_pool = mysql.connector.pooling.MySQLConnectionPool(
        pool_name="mypool",
        pool_size=5,
        **dbconfig
    )

    # 从连接池中获取一个连接
    connection = connection_pool.get_connection()

    if connection.is_connected():
        print("成功连接到数据库")

        # 创建游标对象
        cursor = connection.cursor()

        # 执行查询
        cursor.execute("SELECT DATABASE();")

        # 获取查询结果
        record = cursor.fetchone()
        print("当前数据库：", record)

        # 关闭游标和连接
        cursor.close()
        connection.close()
        print("MySQL连接已关闭")

except mysql.connector.Error as err:
    print("数据库连接失败: {}".format(err))

解释说明：

1. 导入库：

   • mysql.connector 是用于与 MySQL 数据库交互的库。
   • pooling 模块提供了连接池的功能。

2. 配置数据库连接参数：

   • dbconfig 字典包含了连接数据库所需的参数，如主机地址、用户名、密码和数据库名称。

3. 创建连接池：

   • 使用 MySQLConnectionPool 创建一个连接池，指定连接池的名称 (pool_name) 和大小 (pool_size)。这里设置为最多5个连接。

4. 获取连接：

   • 使用 get_connection() 方法从连接池中获取一个可用的数据库连接。

5. 执行查询：

   • 创建游标对象并执行 SQL 查询。
   • 使用 fetchone() 获取查询结果。

6. 关闭连接：

   • 查询完成后，关闭游标和连接，释放资源。

7. 异常处理：

   • 捕获并处理可能的数据库连接错误，确保程序不会因异常而崩溃。