Support connect to mysql using socket

install.php

@@ -1065,6 +1065,9 @@ function install_step_2_perform()
     // intval port number
     if (isset($dbConfig['port'])) {
         $dbConfig['port'] = intval($dbConfig['port']);
+        if (strpos($dbConfig['host'], '/') !== false && $type == 'Mysql') {
+            $dbConfig['port'] = null;
+        }
     }
 
     // bool ssl verify

var/Typecho/Db/Adapter/Mysqli.php

@@ -5,6 +5,7 @@
 use Typecho\Config;
 use Typecho\Db;
 use Typecho\Db\Adapter;
+use mysqli_sql_exception;
 
 if (!defined('__TYPECHO_ROOT_DIR__')) {
     exit;
@@ -49,26 +50,40 @@ public function connect(Config $config): \mysqli
     {
         $mysqli = mysqli_init();
         if ($mysqli) {
-            if (!empty($config->sslCa)) {
-                $mysqli->ssl_set(null, null, $config->sslCa, null, null);
+            try {
+                if (!empty($config->sslCa)) {
+                    $mysqli->ssl_set(null, null, $config->sslCa, null, null);
 
-                if (isset($config->sslVerify)) {
-                    $mysqli->options(MYSQLI_OPT_SSL_VERIFY_SERVER_CERT, $config->sslVerify);
+                    if (isset($config->sslVerify)) {
+                        $mysqli->options(MYSQLI_OPT_SSL_VERIFY_SERVER_CERT, $config->sslVerify);
+                    }
+                }
+
+                $host = $config->host;
+                $port = empty($config->port) ? null : $config->port;
+                $socket = null;
+                if (strpos($host, '/') !== false) {
+                    $socket = $host;
+                    $host = 'localhost';
+                    $port = null;
                 }
-            }
 
-            $mysqli->real_connect(
-                $config->host,
-                $config->user,
-                $config->password,
-                $config->database,
-                (empty($config->port) ? null : $config->port)
-            );
+                $mysqli->real_connect(
+                    $host,
+                    $config->user,
+                    $config->password,
+                    $config->database,
+                    $port,
+                    $socket
+                );
 
-            $this->dbLink = $mysqli;
+                $this->dbLink = $mysqli;
 
-            if ($config->charset) {
-                $this->dbLink->query("SET NAMES '{$config->charset}'");
+                if ($config->charset) {
+                    $this->dbLink->query("SET NAMES '{$config->charset}'");
+                }
+            } catch (mysqli_sql_exception $e) {
+                throw new ConnectionException($e->getMessage(), $e->getCode());
             }
 
             return $this->dbLink;
@@ -106,8 +121,13 @@ public function query(
         ?string $action = null,
         ?string $table = null
     ) {
-        if ($resource = @$this->dbLink->query($query)) {
-            return $resource;
+        try {
+            if ($resource = @$this->dbLink->query($query)) {
+                return $resource;
+            }
+        } catch (mysqli_sql_exception $e) {
+            /** 数据库异常 */
+            throw new SQLException($e->getMessage(), $e->getCode());
         }
 
         /** 数据库异常 */

var/Typecho/Db/Adapter/Pdo/Mysql.php

@@ -61,9 +61,14 @@ public function init(Config $config): \PDO
             }
         }
 
+        $dsn = !empty($config->dsn)
+            ? $config->dsn
+            : (strpos($config->host, '/') !== false
+                ? "mysql:dbname={$config->database};unix_socket={$config->host}"
+                : "mysql:dbname={$config->database};host={$config->host};port={$config->port}");
+
         $pdo = new \PDO(
-            !empty($config->dsn)
-                ? $config->dsn : "mysql:dbname={$config->database};host={$config->host};port={$config->port}",
+            $dsn,
             $config->user,
             $config->password,
             $options

var/Typecho/Db/Adapter/Pgsql.php

@@ -119,7 +119,7 @@ public function fetchObject($resource): ?\stdClass
 
     /**
      * @param resource $resource
-     * @return array|null
+     * @return array
      */
     public function fetchAll($resource): array
     {
@@ -146,6 +146,6 @@ public function affectedRows($resource, $handle): int
      */
     public function quoteValue($string): string
     {
-        return '\'' . pg_escape_string($string) . '\'';
+        return '\'' . str_replace("'", '"', $string) . '\'';
     }
 }