修改str.cat

tensnsorflow/ffm.py

@@ -45,10 +45,10 @@ def get_data():
                                        df["y"].values.tolist(),df["z"].values.tolist()], sep=",")
     df = df.drop("z", axis=1)
     print(df.head())
-    df = df[df["stat_date"] != "2018-11-25"]
-    transform(df,"train")
-    df = df[df["stat_date"] == "2018-11-25"]
-    transform(df, "test")
+    train = df[df["stat_date"] != "2018-11-25"]
+    transform(train,"train")
+    test = df[df["stat_date"] == "2018-11-25"]
+    transform(test, "test")
 
 
 def transform(df,table):
@@ -67,10 +67,17 @@ def transform(df,table):
     df = df.drop(0, axis=1)
     print("size")
     print(df.shape)
-    # for i in range(len(df.shape[0]))
-    # yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@10.66.157.22:4000/jerry_test?charset=utf8')
-    # pd.io.sql.to_sql(df, table, yconnect, schema='jerry_test', if_exists='append', index=False)
-    # print("insert done")
+    yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@10.66.157.22:4000/jerry_test?charset=utf8')
+    for i in range(df.shape[0],10000):
+        if i == 0:
+            temp = df.loc[0:10000]
+        elif i+10000 > df.shape[0]:
+            temp = df.loc[i:]
+        else:
+            temp = df.loc[i+1:i+10000]
+        pd.io.sql.to_sql(temp, table, yconnect, schema='jerry_test', if_exists='append', index=False)
+        print("insert done")
+
 
 
 class multiFFMFormatPandas: