Python程序中如何重试MySQL连接

在Python开发中，与MySQL数据库进行交互是常见的需求。然而，由于网络波动、数据库服务器临时故障等原因，连接MySQL数据库时可能会遇到失败的情况。为了确保程序的稳定性和健壮性，我们需要实现重试机制来处理这类问题。

1. 使用try - except块捕获异常

我们可以使用Python的try - except块来捕获连接MySQL时可能出现的异常。以mysql - connector - python库为例：

import mysql.connector

try:
    cnx = mysql.connector.connect(user='your_user', password='your_password',
                                  host='your_host', database='your_database')
    # 执行数据库操作
    cursor = cnx.cursor()
    cursor.execute("SELECT * FROM your_table")
    results = cursor.fetchall()
    for row in results:
        print(row)
    cursor.close()
    cnx.close()
except mysql.connector.Error as err:
    print(f"连接错误: {err}")

2. 简单重试机制

如果连接失败，我们可以简单地进行重试。以下是一个包含重试逻辑的示例：

import mysql.connector
import time

max_retries = 3
retry_delay = 5

for attempt in range(max_retries):
    try:
        cnx = mysql.connector.connect(user='your_user', password='your_password',
                                      host='your_host', database='your_database')
        print("连接成功")
        # 执行数据库操作
        cursor = cnx.cursor()
        cursor.execute("SELECT * FROM your_table")
        results = cursor.fetchall()
        for row in results:
            print(row)
        cursor.close()
        cnx.close()
        break
    except mysql.connector.Error as err:
        print(f"连接尝试 {attempt + 1} 失败: {err}")
        if attempt < max_retries - 1:
            print(f"等待 {retry_delay} 秒后重试...")
            time.sleep(retry_delay)

3. 指数退避重试

为了避免在短时间内频繁重试对数据库服务器造成过大压力，可以采用指数退避算法。指数退避会使重试间隔时间随着重试次数增加而指数级增长：

import mysql.connector
import time

max_retries = 3
base_delay = 1

for attempt in range(max_retries):
    try:
        cnx = mysql.connector.connect(user='your_user', password='your_password',
                                      host='your_host', database='your_database')
        print("连接成功")
        # 执行数据库操作
        cursor = cnx.cursor()
        cursor.execute("SELECT * FROM your_table")
        results = cursor.fetchall()
        for row in results:
            print(row)
        cursor.close()
        cnx.close()
        break
    except mysql.connector.Error as err:
        print(f"连接尝试 {attempt + 1} 失败: {err}")
        if attempt < max_retries - 1:
            delay = base_delay * (2 ** attempt)
            print(f"等待 {delay} 秒后重试...")
            time.sleep(delay)

通过上述方法，我们可以在Python程序中有效地处理MySQL连接失败的情况，提高程序的容错能力和稳定性，确保数据库操作的顺利进行。