设置pymysql每次连接检查是否断开

common/mysql_operate.py

@@ -23,6 +23,8 @@ def __del__(self): # 对象资源被释放时触发，在对象即将被删除
 
     def select_db(self, sql):
         """查询"""
+        # 检查连接是否断开，如果断开就进行重连
+        self.conn.ping(reconnect=True)
         # 使用 execute() 执行sql
         self.cur.execute(sql)
         # 使用 fetchall() 获取查询结果
@@ -32,6 +34,8 @@ def select_db(self, sql):
     def execute_db(self, sql):
         """更新/新增/删除"""
         try:
+            # 检查连接是否断开，如果断开就进行重连
+            self.conn.ping(reconnect=True)
             # 使用 execute() 执行sql
             self.cur.execute(sql)
             # 提交事务