@@ -413,9 +413,11 @@ class SpApiRequest:
conn.begin()
cursor.executemany(insertsql,tuple(update_df[origin_columns].to_numpy().tolist()))
conn.commit()
+ return '插入完成'
except Exception as e:
print("插入错误:",e)
conn.rollback()
+ return '出错回滚'
@classmethod
def get_allShops(cls):