clones/friendica
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

mysql connection via unix sockets (mysqli + PDO)

This commit is contained in:
k-alin 2022-02-14 23:18:41 +01:00
parent 203d87e047
commit 31ff583c5e
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Database/Database.php
View File

@ -114,6 +114,7 @@ class Database
$pass = trim($this->configCache->get('database', 'password')); $pass = trim($this->configCache->get('database', 'password'));
$db = trim($this->configCache->get('database', 'database')); $db = trim($this->configCache->get('database', 'database'));
$charset = trim($this->configCache->get('database', 'charset')); $charset = trim($this->configCache->get('database', 'charset'));
$socket = trim($this->configCache->get('database', 'socket'));
if (!(strlen($server) && strlen($user))) { if (!(strlen($server) && strlen($user))) {
return false; return false;
@ -125,7 +126,7 @@ class Database
if (!$this->configCache->get('database', 'disable_pdo') && class_exists('\PDO') && in_array('mysql', PDO::getAvailableDrivers())) { if (!$this->configCache->get('database', 'disable_pdo') && class_exists('\PDO') && in_array('mysql', PDO::getAvailableDrivers())) {
$this->driver = self::PDO; $this->driver = self::PDO;
$connect = "mysql:host=" . $server . ";dbname=" . $db; $connect = "mysql:host=" . $server . ";dbname=" . $db . ";unix_socket=" . $socket;
if ($port > 0) { if ($port > 0) {
$connect .= ";port=" . $port; $connect .= ";port=" . $port;
@ -149,9 +150,9 @@ class Database
$this->driver = self::MYSQLI; $this->driver = self::MYSQLI;
if ($port > 0) { if ($port > 0) {
$this->connection = @new mysqli($server, $user, $pass, $db, $port); $this->connection = @new mysqli($server, $user, $pass, $db, $port, $socket);
} else { } else {
$this->connection = @new mysqli($server, $user, $pass, $db); $this->connection = @new mysqli($server, $user, $pass, $db, $socket);
} }
if (!mysqli_connect_errno()) { if (!mysqli_connect_errno()) {