update

c74496fe · litaolemo · 9609e24d · c74496fe
Commit c74496fe authored Aug 19, 2020 by litaolemo
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 2 deletions

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

No files found.
--- a/tasks/from_sparksql_to_mysql.py
+++ b/tasks/from_sparksql_to_mysql.py
@@ -105,7 +105,8 @@ for res in sql_res:
        content_click_pv=content_click_pv,slide_wel_click_pv=slide_wel_click_pv,self_wel_click_pv=self_wel_click_pv,
        partition_day=partition_day, pid=pid
    )
-    print(sql)
-    cursor.execute(sql)
+    # print(sql)
+    res = cursor.execute(sql)
+    print(res)
 # cursor.executemany()
 db.close()
\ No newline at end of file