Merge pull request Altinity#161 from flyrdm/src-port-config-fix

Port (--src-port) cli/config setting was being ignored

Author: sunsingerus

clickhouse_mysql/dbclient/mysqlclient.py

@@ -58,6 +58,7 @@ def connect(self, db):
         try:
             self.connection = MySQLdb.connect(
                 host=self.host,
+                port=self.port,                
                 user=self.user,
                 passwd=self.password,
                 db=db,
@@ -66,15 +67,17 @@ def connect(self, db):
                 use_unicode=True,
             )
             self.cursor = self.connection.cursor()
-            logging.debug("Connect to the database host={} user={} password={} db={}".format(
+            logging.debug("Connect to the database host={} port={} user={} password={} db={}".format(
                 self.host,
+                self.port,
                 self.user,
                 self.password,
                 db
             ))
         except:
-            raise Exception("Can not connect to the database host={} user={} password={} db={}".format(
+            raise Exception("Can not connect to the database host={} port={} user={} password={} db={}".format(
                 self.host,
+                self.port,
                 self.user,
                 self.password,
                 db
@@ -106,8 +109,9 @@ def tables_list(self, db):
 
         except Exception as err:
             logging.debug("Unexpected error: {}".format(str(err)))
-            raise Exception("Can not list tables on host={} user={} password={} db={}".format(
+            raise Exception("Can not list tables on host={} port={} user={} password={} db={}".format(
                 self.host,
+                self.port,
                 self.user,
                 self.password,
                 db