|
@@ -44,10 +44,9 @@ class TidbProConn:
|
|
time.sleep(stime) # 连接不成功,休眠3秒钟,继续循环,知道成功或重试次数结束
|
|
time.sleep(stime) # 连接不成功,休眠3秒钟,继续循环,知道成功或重试次数结束
|
|
|
|
|
|
@classmethod
|
|
@classmethod
|
|
- def quary(cls, sql):
|
|
|
|
- mysql_conn = TidbProConn.get_connection()
|
|
|
|
- TidbProConn._reCon()
|
|
|
|
- cur = mysql_conn.cursor()
|
|
|
|
|
|
+ def quary(cls, conn, sql):
|
|
|
|
+ TidbProConn._reCon(conn)
|
|
|
|
+ cur = conn.cursor()
|
|
cur.execute(sql)
|
|
cur.execute(sql)
|
|
result = cur.fetchall()
|
|
result = cur.fetchall()
|
|
return result
|
|
return result
|
|
@@ -74,23 +73,23 @@ class TidbProConn:
|
|
|
|
|
|
@staticmethod
|
|
@staticmethod
|
|
def upsert(conn, sql_buff):
|
|
def upsert(conn, sql_buff):
|
|
- TidbProConn._reCon()
|
|
|
|
|
|
+ TidbProConn._reCon(conn)
|
|
try:
|
|
try:
|
|
TidbProConn.exec_sql(conn, sql_buff)
|
|
TidbProConn.exec_sql(conn, sql_buff)
|
|
except Exception as e:
|
|
except Exception as e:
|
|
logging.error('失败详细信息:', repr(e))
|
|
logging.error('失败详细信息:', repr(e))
|
|
TidbProConn.get_connection().commit()
|
|
TidbProConn.get_connection().commit()
|
|
|
|
|
|
- @classmethod
|
|
|
|
- def _reCon(cls):
|
|
|
|
|
|
+ @staticmethod
|
|
|
|
+ def _reCon(conn):
|
|
""" MySQLdb.OperationalError异常"""
|
|
""" MySQLdb.OperationalError异常"""
|
|
# self.con.close()
|
|
# self.con.close()
|
|
while True:
|
|
while True:
|
|
try:
|
|
try:
|
|
- TidbProConn.get_connection().ping()
|
|
|
|
|
|
+ conn.ping()
|
|
break
|
|
break
|
|
except OperationalError:
|
|
except OperationalError:
|
|
- TidbProConn.get_connection().ping(True)
|
|
|
|
|
|
+ conn.ping(True)
|
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
if __name__ == '__main__':
|