MySQLConnectionPool 断开后自动重连

MySQLConnectionPool 是一个连接池，用于管理 MySQL 连接的创建和释放。如果连接池中的某个连接在使用过程中因为网络等原因断开了，连接池会自动创建新的连接来代替断开的连接，保证应用程序的正常运行。

在 Python 中使用 MySQLConnectionPool 时，可以设置连接池中连接的最大数量、最小数量、超时时间等参数，以及连接 MySQL 的配置信息。当连接池中的连接数量达到最大值时，新的连接请求将被阻塞，直到有连接被释放。

下面是一个使用 MySQLConnectionPool 的示例代码，其中使用了自动重连功能：

import mysql.connector
from mysql.connector.pooling import MySQLConnectionPool

# MySQL 连接池的配置信息
config = {
    'user': 'root',
    'password': '123456',
    'host': '127.0.0.1',
    'database': 'test',
    'pool_name': 'my_pool',
    'pool_size': 5,
    'autocommit': True,
    'raise_on_warnings': True,
    'use_pure': False,
    'connect_timeout': 30
}

# 创建 MySQL 连接池
pool = MySQLConnectionPool(**config)

# 从连接池中获取连接
connection = pool.get_connection()

# 执行 SQL 查询
try:
    cursor = connection.cursor()
    cursor.execute('SELECT * FROM users')
    results = cursor.fetchall()
    for row in results:
        print(row)
except mysql.connector.Error as error:
    print('Error: {}'.format(error))
finally:
    # 释放连接
    if connection.is_connected():
        cursor.close()
        connection.close()

# 自动重连示例
while True:
    try:
        # 从连接池中获取连接
        connection = pool.get_connection()
        print('got connection from pool')
        # 执行 SQL 查询
        cursor = connection.cursor()
        cursor.execute('SELECT * FROM users')
        results = cursor.fetchall()
        for row in results:
            print(row)
    except mysql.connector.errors.InterfaceError as error:
        # 当出现 InterfaceError 异常时，说明连接已经断开，需要重新连接
        if 'MySQL Connection not available.' in str(error):
            print('connection lost, trying to reconnect...')
            # 释放连接
            if connection.is_connected():
                cursor.close()
                connection.close()
            # 重新获取连接
            connection = pool.get_connection()
            print('reconnected successfully')
    except KeyboardInterrupt:
        print('interrupted by user')
        break
    finally:
        # 释放连接
        if connection.is_connected():
            cursor.close()
            connection.close()

在示例代码中，我们使用了一个无限循环来不断地从 MySQL 连接池中获取连接，并执行 SQL 查询。当连接断开时会抛出 InterfaceError 异常，我们在异常处理中判断异常信息是否为连接不可用的错误，并在重新连接成功后继续执行查询操作。需要注意的是，当程序运行结束后需要释放连接池中的所有连接，以便程序能够正常退出。