change test

user_data.py

@@ -46,6 +46,36 @@ def get_device():
         print("insert done")
 
 
+def get_du():
+    sql = "select device_id,user_id from statistic_device_user"
+    df = pd.DataFrame(list(get_mysql_data(host, port, user, passwd, db, sql)))
+    df = df.rename(columns={0: "device_id", 1: "user_id"})
+    print(df.shape)
+    l = 0
+    r = 10000
+    length = len(df)
+    while l < length:
+        pd.io.sql.to_sql(df[l:r], "device_user", yconnect, schema='jerry_test', if_exists='append', index=False)
+        l += 10000
+        r += 10000
+        print("insert done")
+
+
+def get_order():
+    sql = "select user_id,service_id,created_time from api_order"
+    df = pd.DataFrame(list(get_mysql_data(host, port, user, passwd, db, sql)))
+    df = df.rename(columns={0: "device_id", 1: "service_id",2:"created_time"})
+    print(df.shape)
+    l = 0
+    r = 10000
+    length = len(df)
+    while l < length:
+        pd.io.sql.to_sql(df[l:r], "meigou_order", yconnect, schema='jerry_test', if_exists='append', index=False)
+        l += 10000
+        r += 10000
+        print("insert done")
+
+
 if __name__ == "__main__":
     host = "172.16.30.141"
     port = 3306
@@ -53,7 +83,7 @@ if __name__ == "__main__":
     passwd = "BJQaT9VzDcuPBqkd"
     db = "zhengxing"
     yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@172.16.40.170:4000/jerry_test?charset=utf8')
-    get_device()
+    get_du()