add support for db connections with port specified in host

jkowens · Mar 11, 2016 · 8fd7ac1 · 8fd7ac1
1 parent 7cf952a
commit 8fd7ac1
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/app/code/community/Jowens/JobQueue/Model/Worker.php b/app/code/community/Jowens/JobQueue/Model/Worker.php
@@ -88,6 +88,10 @@ protected function setupDJJob() {
  $dsn = "";
  if (strpos($config->host, '/') !== false) {
  $dsn = "mysql:unix_socket=" . $config->host . ";dbname=" . $config->dbname;
+ }
+ elseif (strpos($config->host, ':') !== false) {
+ list($host, $port) = explode(':', $config->host);
+ $dsn = "mysql:host=" . $host . ";dbname=" . $config->dbname . ";port=" . $port;
  } else {
  $dsn = "mysql:host=" . $config->host . ";dbname=" . $config->dbname . ";port=" . $config->port;
  }