Correcting the url by adding port

hi-primus · Jun 12, 2019 · cf7f99f · cf7f99f
1 parent aa8ae1f
commit cf7f99f
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/optimus/io/jdbc.py b/optimus/io/jdbc.py
@@ -21,13 +21,7 @@ def __init__(self, db_type, url, database, user, password, port=None):
         # RaiseIt.value_error(db_type, ["redshift", "postgres", "mysql", "sqlite"])
         self.db_type = db_type
 
-        # Create string connection
-        if self.db_type is "sqlite":
-            url = "jdbc:" + db_type + ":" + url + "/" + database
-        else:
-            url = "jdbc:" + db_type + "://" + url + "/" + database
-
-        # Handle the default port
+         # Handle the default port
         if port is None:
             if self.db_type is "redshift":
                 self.port = 5439
@@ -38,6 +32,12 @@ def __init__(self, db_type, url, database, user, password, port=None):
             elif self.db_type is "mysql":
                 self.port = 3306
 
+        # Create string connection
+        if self.db_type is "sqlite":
+            url = "jdbc:" + db_type + ":" + url + "/" + database
+        else:
+            url = "jdbc:" + db_type + "://" + url + ":" + port + "/" + database
+
         self.url = url
         self.database = database
         self.user = user