diff --git a/chapter3/spark.py b/chapter3/spark.py index 1188536..f86ba98 100644 --- 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()