.

2019-01-18 15:20:35 +08:00 · 2019-01-18 15:20:35 +08:00 · 20c6202d28
parent 9e70b0c842
commit 20c6202d28
1 changed files with 1 additions and 0 deletions
--- a/chapter3/spark.py
+++ b/chapter3/spark.py
@ -16,6 +16,7 @@ def mysql_query(sql):
    return data

 def mysql_execute(sql):
+    print("execute: %s" % sql)
    db = pymysql.connect("localhost","root","123456789","sparkproject" )
    cursor = db.cursor()