Discuz 風格 MySQL 查詢類封裝：dbQuery 核心原理解析與現代化重構建議

原始碼核心結構分析

該類封裝了 mysql_* 系列函數（已棄用），提供連線管理、查詢執行、結果集遍歷、錯誤處理等基礎功能，典型 Discuz/X 系列框架風格。

關鍵方法對照表

關鍵設計細節解讀

1. 字符集自動協商（4.1+）

if ($this->version() > '4.1') {
    global $dbcharset;
    if ($dbcharset) {
        mysql_query("SET character_set_connection=$dbcharset,
                          character_set_results=$dbcharset,
                          character_set_client=binary", $this->link);
    }
}

解決 character_set_client=binary 避免客戶端編碼干擾，connection/results 統一為應用字符集。

2. SQL_MODE 淨化（5.0.1+）

if ($this->version() > '5.0.1') {
    mysql_query("SET sql_mode=''", $this->link);
}

清空 SQL_MODE 避免 ONLY_FULL_GROUP_BY、STRICT_TRANS_TABLES 等嚴格模式導致舊代碼報錯。

3. UNBUFFERED 查詢支援

$func = $type == 'UNBUFFERED' && function_exists('mysql_unbuffered_query')
    ? 'mysql_unbuffered_query' : 'mysql_query';

大結果集串流讀取，減少 PHP 記憶體佔用，但需一次性讀完才能執行下一條查詢。

現代化重構建議（PDO 版）

<?php
declare(strict_types=1);

class DbQuery {
    private PDO $pdo;
    private int $queryCount = 0;

    public function __construct(string $dsn, string $user, string $pass, array $options = []) {
        $defaultOptions = [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
            PDO::ATTR_EMULATE_PREPARES => false,
            PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8mb4 COLLATE utf8mb4_unicode_ci",
        ];
        $this->pdo = new PDO($dsn, $user, $pass, $defaultOptions + $options);
    }

    public function query(string $sql, array $params = []): PDOStatement {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        $this->queryCount++;
        return $stmt;
    }

    public function fetchAll(string $sql, array $params = []): array {
        return $this->query($sql, $params)->fetchAll();
    }

    public function fetchOne(string $sql, array $params = []): ?array {
        return $this->query($sql, $params)->fetch() ?: null;
    }

    public function execute(string $sql, array $params = []): int {
        return $this->query($sql, $params)->rowCount();
    }

    public function lastInsertId(string $name = null): string {
        return $this->pdo->lastInsertId($name);
    }

    public function getQueryCount(): int {
        return $this->queryCount;
    }

    public function beginTransaction(): void {
        $this->pdo->beginTransaction();
    }

    public function commit(): void {
        $this->pdo->commit();
    }

    public function rollBack(): void {
        $this->pdo->rollBack();
    }

    public function getPdo(): PDO {
        return $this->pdo;
    }
}

遷移清單

延伸閱讀

• MySQL 查詢快取變量的相關解釋
• MySQL 條件查詢語句的用法
• 五種常用的 MySQL 命令列