python mysql断开重连的实现方法

实现python对MySQL数据库的断开重连需要安装pymysql模块。pymysql是python中一个第三方的MySQL数据库驱动库，可以通过pip进行安装。

在实现python与MySQL数据库的断开重连时，可以通过以下方式：

1.设置自动重连方式

可以通过pymysql中的“connect”函数参数实现自动重连，具体实现方式为：

import pymysql

def connect():
    connection = pymysql.connect(
        host='localhost',
        user='root',
        password='root',
        db='test',
        charset='utf8',
        cursorclass=pymysql.cursors.DictCursor, 
        connect_timeout=20, 
        autocommit=True, 
        read_timeout=20) # 设置自动重连次数为5
    return connection

在“connect”函数中，设置参数“connect_timeout”和“read_timeout”为设置重连的时间间隔。设置该参数可以在一定程度上提高程序的重连成功率。

2.手动重连方式

手动重连方式即在程序中手动实现断开连接和重连操作。该方式的实现步骤如下：

import pymysql

def connect():
    connection = pymysql.connect(
        host='localhost',
        user='root',
        password='root',
        db='test',
        charset='utf8',
        cursorclass=pymysql.cursors.DictCursor, 
        autocommit=True)    
    return connection

def select_data():
    try:
        connect().ping() # 测试数据库连接
    except Exception as e:
        print('连接断开，正在重新连接：', e)
        connect().connect()
    with connect().cursor() as cursor:
        sql = 'SELECT * FROM table1'
        cursor.execute(sql)
        result = cursor.fetchall()
        return result

该方法中，当数据库连接发生错误时，通过异常捕获方式进行手动重连操作。在重连前，通过调用“ping”函数进行测试，保证数据库确实断开连接。等待重连完成后，再次发起数据库查询请求。

示例1：

import pymysql

def connect():
    connection = pymysql.connect(
        host='localhost',
        user='root',
        password='root',
        db='test',
        charset='utf8',
        cursorclass=pymysql.cursors.DictCursor,
        autocommit=True,
        connect_timeout=20,
        read_timeout=20)  
    return connection

def select_data():
    for i in range(3):
        try:
            with connect().cursor() as cursor:
                sql = 'SELECT * FROM table1'
                cursor.execute(sql)
                result = cursor.fetchall()
                return result
        except Exception as e:
            print('连接断开，正在重新连接：', e)
            connect().connect()

result = select_data()
if result:
    print(result)

示例2：

import pymysql

def connect():
  connection = pymysql.connect(
      host='localhost',
      user='root',
      password='root',
      db='test',
      charset='utf8',
      cursorclass=pymysql.cursors.DictCursor,
      autocommit=True,
      connect_timeout=20,
      read_timeout=20)    
  return connection

def insert_data(data):
    for i in range(3):
        try:
            with connect().cursor() as cursor:
                sql = 'INSERT INTO table1 (name, age) VALUES (%s, %s)'
                cursor.execute(sql, data)
                connect().commit()
                return True
        except Exception as e:
            print('连接断开，正在重新连接：', e)
            connect().connect()

result = insert_data(('Mike', 26))
if result:
    print('数据插入成功')

通过以上两种方法可以实现python与MySQL数据库的断开重连操作，保证程序在数据库发生故障时依然能正常运行。