update

1e624a78 · litaolemo · d59fb6dd · 1e624a78
Commit 1e624a78 authored Aug 19, 2020 by litaolemo
Show whitespace changes
Inline Side-by-side

Showing with 3 additions and 2 deletions

from_sparksql_to_mysql.py tasks/from_sparksql_to_mysql.py +3 -2

No files found.
--- a/tasks/from_sparksql_to_mysql.py
+++ b/tasks/from_sparksql_to_mysql.py
@@ -106,9 +106,9 @@ for res in sql_res:
        partition_day=partition_day, pid=pid
    )
    print(instert_sql)
-    cursor.execute("set names 'UTF8'")
+    # cursor.execute("set names 'UTF8'")
    res = cursor.execute(instert_sql)
-
+    db.commit()
    print(res)
 # cursor.executemany()
 db.close()
\ No newline at end of file