Fix missing DB port and socket

phpList#73
reetp · Jan 8, 2024 · 8c556c4 · 8c556c4
1 parent 30ca9d5
commit 8c556c4
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/plugins/restapi/includes/pdo.php b/plugins/restapi/includes/pdo.php
@@ -15,7 +15,15 @@ public static function getConnection()
         $dbuser = $GLOBALS['database_user'];
         $dbpass = $GLOBALS['database_password'];
         $dbname = $GLOBALS['database_name'];
-        $dbh = new \PDO("mysql:host=$dbhost;dbname=$dbname;charset=UTF8;", $dbuser, $dbpass, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'utf8';"));
+        $dbport = $GLOBALS['database_port'];
+        $dbsock = $GLOBALS['database_socket'];
+
+        // There is no error checking here
+        if (isset($dbsock) ) {
+            $dbh = new \PDO("mysql:dbname=$dbname;unix_socket=$dbsock;charset=UTF8;", $dbuser, $dbpass, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'utf8';"));
+        } else {
+            $dbh = new \PDO("mysql:host=$dbhost;dbname=$dbname;port=$dbport;charset=UTF8;", $dbuser, $dbpass, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'utf8';"));
+        }
         $dbh->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
 
         return $dbh;