change test file

user_data.py

@@ -47,17 +47,18 @@ def get_device():
 
 
 def get_du():
-    sql = "select device_id,user_id from statistic_device_user"
+    sql = "select b.device_id,a.user_id from statistic_device_user a " \
+          "left join statistic_device b on a.device_id = b.id"
     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
+    r = 200000
     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
+        l += 200000
+        r += 200000
         print("insert done")
 
 
@@ -103,26 +104,28 @@ def user_to_csv():
 
 
 if __name__ == "__main__":
-    # host = "172.16.30.141"
-    # port = 3306
-    # user = "work"
-    # passwd = "BJQaT9VzDcuPBqkd"
-    # db = "zhengxing"
-    # yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@172.16.40.170:4000/jerry_test?charset=utf8')
-    #
-    host = "172.16.40.170"
-    port = 4000
-    user = "root"
-    passwd = "3SYz54LS9#^9sBvC"
-    db = "jerry_test"
-    devcie_to_csv()
-    print("devcie ok")
-    user_to_csv()
-    print("user ok")
-    user_device_to_csv()
-    print("ud ok")
-    meigou_to_csv()
-    print("meigou ok")
+    host = "172.16.30.141"
+    port = 3306
+    user = "work"
+    passwd = "BJQaT9VzDcuPBqkd"
+    db = "zhengxing"
+    yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@172.16.40.170:4000/jerry_test?charset=utf8')
+    get_du()
+    print("end")
+
+    # host = "172.16.40.170"
+    # port = 4000
+    # user = "root"
+    # passwd = "3SYz54LS9#^9sBvC"
+    # db = "jerry_test"
+    # devcie_to_csv()
+    # print("devcie ok")
+    # user_to_csv()
+    # print("user ok")
+    # user_device_to_csv()
+    # print("ud ok")
+    # meigou_to_csv()
+    # print("meigou ok")