Mysql plugin specified port bug fix

Author: Hello-Hyman

mqttwarn/services/mysql.py

@@ -55,7 +55,8 @@ def plugin(srv, item):
         conn = MySQLdb.connect(host=host,
                                user=user,
                                passwd=passwd,
-                               db=dbname)
+                               db=dbname,
+                               port=port)
         cursor = conn.cursor()
     except Exception as e:
         srv.logging.warn("Cannot connect to mysql: %s" % e)

mqttwarn/services/mysql_dynamic.py

@@ -101,7 +101,8 @@ def plugin(srv, item):
         conn = MySQLdb.connect(host=host,
                                user=user,
                                passwd=passwd,
-                               db=dbname)
+                               db=dbname,
+                               port=port)
         cursor = conn.cursor()
     except Exception as e:
         srv.logging.warn("Cannot connect to mysql: %s" % e)

mqttwarn/services/mysql_remap.py

@@ -65,7 +65,7 @@ def plugin(srv, item):
         return False
 
     try:
-        conn = MySQLdb.connect(host=host, user=user, passwd=passwd, db=dbname)
+        conn = MySQLdb.connect(host=host, user=user, passwd=passwd, db=dbname, port=port)
         cursor = conn.cursor()
     except Exception as e:
         srv.logging.warn("Cannot connect to mysql: %s" % e)