python mysql连接池 断开后自动重连

在 Python 中，可以使用 `pymysql` 库来连接 MySQL 数据库。要实现断开后自动重连的功能，可以使用连接池和心跳机制。

连接池是一组已经建立好的数据库连接，可以重复使用。心跳机制是在数据库连接断开时，通过发送一个小的查询语句来检测数据库是否正常，如果不正常则重新连接。

下面是一个使用连接池和心跳机制实现断开后自动重连的示例代码：

import pymysql
from pymysql import err

from DBUtils.PooledDB import PooledDB  # 导入连接池模块

POOL = PooledDB(
    creator=pymysql,
    maxconnections=6,
    mincached=2,
    maxcached=5,
    blocking=True,
    ping=1,  # 开启心跳机制，每隔1秒进行一次检测
    host='localhost',
    port=3306,
    user='root',
    password='root',
    database='test'
)  # 创建连接池

def query(sql, args=None):
    conn = POOL.connection()  # 从连接池中获取一个连接
    cursor = conn.cursor()
    try:
        cursor.execute(sql, args)
        result = cursor.fetchall()
        conn.commit()
    except err.OperationalError as e:  # 如果出现 OperationalError 操作错误异常，则重新连接
        if e.args[0] in (2006, 2013):
            conn.ping(reconnect=True)
            cursor = conn.cursor()
            cursor.execute(sql, args)
            result = cursor.fetchall()
            conn.commit()
        else:
            raise e
    else:
        return result
    finally:
        cursor.close()
        conn.close()

在上面的代码中，使用 `PooledDB` 创建了一个连接池，其中 `ping` 参数设置了心跳机制的时间间隔为 1 秒。在 `query` 函数中，首先从连接池中获取一个连接，然后执行数据库操作。如果出现 `OperationalError` 异常，判断错误码是否为 2006 或 2013，如果是，则说明数据库连接已经断开，需要重新连接。最后释放连接。

这样，就可以实现断开后自动重连的功能了。