新增测试文件

user_data.py

@@ -19,8 +19,15 @@ 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"})
-    pd.io.sql.to_sql(df, "user", yconnect, schema='jerry_test', if_exists='append', index=False,
-                     chunksize=1)
+    df.tosql("user", con=yconnect, if_exists='append',chunksize = 2000)
+    # l = 0
+    # r = 2000
+    # length = len(df)
+    # while (l < length):
+    #
+    #
+    # pd.io.sql.to_sql(df, "user", yconnect, schema='jerry_test', if_exists='append', index=False,
+    #                  chunksize=1)
     print("insert done")