python mysql断开重连的实现方法

pymysql.err.InterfaceError: (0, '')

pymysql.err.OperationalError: (2013, 'Lost connection to MySQL server during query')

class MysqlConnection(object):

	"""
	mysql操作类，对mysql数据库进行增删改查
	"""

	def __init__(self, config):
		# Connect to the database
		self.connection = pymysql.connect(**config)
		self.cursor = self.connection.cursor()

	def Query(self, sql):
		"""
		查询数据
		:param sql:
		:return:
		"""
		self.cursor.execute(sql)
		return self.cursor.fetchall()

self.connection._write_timeout = 10000

try:
	self.cursor.execute(sql)
except:
	self.connection()
	self.cursor.execute(sql)

<pymysql.connections.Connection object at 0x0000000003E2CCC0>

 def ping(self, reconnect=True):
    """Check if the server is alive"""
    if self._sock is None:
      if reconnect:
        self.connect()
        reconnect = False
      else:
        raise err.Error("Already closed")
    try:
      self._execute_command(COMMAND.COM_PING, "")
      return self._read_ok_packet()
    except Exception:
      if reconnect:
        self.connect()
        return self.ping(False)
      else:
        raise

def reConnect(self):
	try:
		self.connection.ping()
	except:
		self.connection()

import pymysql
class DBManager(object):

  def __init__(self,config):
    self.connection = pymysql.connect(**config) # config为数据库登录验证配置信息
    self.cursor = self.connection.cursor()

  def query(self, sql, params):
    try:
      with self.connection.cursor() as cursor:
        cursor.execute(sql, params)
        result = cursor.fetchall()
        self.connection.commit()
        return result
        # self.connection.close()
    except Exception as e:
      traceback.print_exc()