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版权协议,转载请附上原文出处链接和本声明。