Commit d18af794 authored by 张彦钊's avatar 张彦钊

新增测试文件

parent b94bab9f
......@@ -19,7 +19,7 @@ def get_user():
sql = "select user_id,phone,name,city_id,channel,auth_type from api_userextra"
df = pd.DataFrame(list(get_mysql_data(host,port,user,passwd,db,sql)))
df = df.rename(columns={0: "user_id", 1: "phone",2:"name",3:"city_id",4:"channel",5:"auth_type"})
df.to_sql("user", con=yconnect, if_exists='append',chunksize = 2000,index = False)
df.to_sql("user", con=yconnect, if_exists='append',chunksize = 1000,index = False)
# l = 0
# r = 2000
# length = len(df)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment