|
@@ -29,7 +29,7 @@ from (
|
|
)t
|
|
)t
|
|
where t.rn=1)t
|
|
where t.rn=1)t
|
|
"""
|
|
"""
|
|
- totalNum = TidbProConn.quary(self.conn, sql)[0][0]
|
|
|
|
|
|
+ totalNum = TidbConn.quary(self.Innerconn, sql)[0][0]
|
|
pageCount = ceil(totalNum / 10000)
|
|
pageCount = ceil(totalNum / 10000)
|
|
for i in range(pageCount):
|
|
for i in range(pageCount):
|
|
try:
|
|
try:
|
|
@@ -45,14 +45,14 @@ order by signature,stat_date limit {num},10000
|
|
""".format(num=i * 10000)
|
|
""".format(num=i * 10000)
|
|
print(sql)
|
|
print(sql)
|
|
TidbConn.upsert(conn=self.Innerconn, sql_buff=sql)
|
|
TidbConn.upsert(conn=self.Innerconn, sql_buff=sql)
|
|
- TidbProConn.upsert(conn=self.conn, sql_buff=sql)
|
|
|
|
|
|
+ #TidbProConn.upsert(conn=self.conn, sql_buff=sql)
|
|
self.conn.commit()
|
|
self.conn.commit()
|
|
self.Innerconn.commit()
|
|
self.Innerconn.commit()
|
|
except Exception as e:
|
|
except Exception as e:
|
|
logging.error(e)
|
|
logging.error(e)
|
|
return -1
|
|
return -1
|
|
TidbConn.conn_close(conn=self.Innerconn)
|
|
TidbConn.conn_close(conn=self.Innerconn)
|
|
- TidbProConn.conn_close(conn=self.conn)
|
|
|
|
|
|
+ #TidbProConn.conn_close(conn=self.conn)
|
|
return 0
|
|
return 0
|
|
except Exception as e:
|
|
except Exception as e:
|
|
logging.error(e)
|
|
logging.error(e)
|