|
@@ -46,7 +46,7 @@ class TidbConn:
|
|
@classmethod
|
|
@classmethod
|
|
def quary(cls, sql):
|
|
def quary(cls, sql):
|
|
mysql_conn = TidbConn.get_connection()
|
|
mysql_conn = TidbConn.get_connection()
|
|
- TidbConn._reConn()
|
|
|
|
|
|
+ TidbConn._reCon()
|
|
cur = mysql_conn.cursor()
|
|
cur = mysql_conn.cursor()
|
|
cur.execute(sql)
|
|
cur.execute(sql)
|
|
result = cur.fetchall()
|
|
result = cur.fetchall()
|
|
@@ -74,7 +74,7 @@ class TidbConn:
|
|
|
|
|
|
@staticmethod
|
|
@staticmethod
|
|
def upsert(conn, sql_buff):
|
|
def upsert(conn, sql_buff):
|
|
- TidbConn._reConn()
|
|
|
|
|
|
+ TidbConn._reCon()
|
|
try:
|
|
try:
|
|
TidbConn.exec_sql(conn, sql_buff)
|
|
TidbConn.exec_sql(conn, sql_buff)
|
|
except Exception as e:
|
|
except Exception as e:
|