新增测试文件

user_data.py

@@ -16,9 +16,12 @@ def get_mysql_data(host,port,user,passwd,db,sql):
 
 
 def get_user():
-    sql = "select user_id,phone,name,city_id,channel,auth_type from api_userextra limit 6"
+    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)))
-    print(df.head(6))
+    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=10000)
+    print("insert done")
 
 
 if __name__ == "__main__":
@@ -27,6 +30,7 @@ if __name__ == "__main__":
     user = "work"
     passwd = "BJQaT9VzDcuPBqkd"
     db = "zhengxing"
+    yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@172.16.40.158:4000/jerry_test?charset=utf8')
     get_user()