python mysql 断开重新连接

import MySQLdb
import time

def connect():
    try:
        connect_db = MySQLdb.connect(
            "111.5.52.8", "root", "12345678", "com_mysql",connect_timeout=5,charset='utf8')
        connect_cursor = connect_db.cursor()
        return connect_db, connect_cursor
    except:
        print('连接失败')
        return  False,False




def fun():
    global connect_db,connect_cursor
    i = 0
    try:
        while True:
            time.sleep(5)
            try:
                connect_db.ping()   # 采用连接对象的ping()函数检测连接状态
                print('数据库连接-%d 成功' % i)
                i += 1

            # 出现异常重新连接
            except:
                print('出现异常重新连接')
                connect_db,connect_cursor = connect()
    except:
        fun()


connect_db,connect_cursor = connect()
fun()

版权声明:本文为weixin_45813782原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。