diff --git a/python/tag_mysql.py b/python/tag_mysql.py
index e13a86b..b8f7dc8 100644
--- a/python/tag_mysql.py
+++ b/python/tag_mysql.py
@@ -82,6 +82,7 @@ class Tag():
         self.last_send_time = time.time()
         print query
         # TODO: CHECK ON THIS LOGIC -- with con:
+        con.connect()
         cur = con.cursor()
         cur.execute(query)
         con.commit()