PHP-PDO OOP模式下MySQL重复连接问题及解决方法

这个问题很典型——你的Dbh类每次调用connect()方法时都会新建一个PDO连接，而你的User类的三个方法应该都各自调用了connect()，所以才会三次输出"Connected"。解决思路就是确保整个应用生命周期内只创建一次数据库连接，最常用的两种实现方式如下：

方案一：在connect()方法内复用PDO实例 #

通过给Dbh类添加一个静态属性来存储已创建的PDO实例，每次调用connect()时先检查实例是否存在，存在则直接返回，不存在再创建新连接：

class Dbh {
    private $host;
    private $dbName;
    private $password;
    private $dbUser;
    private $charset;
    // 静态属性：存储唯一的PDO连接实例
    private static $pdoInstance = null;

    protected function connect() {
        // 先判断是否已有连接实例，有则直接返回
        if (self::$pdoInstance !== null) {
            return self::$pdoInstance;
        }

        $this->host = 'localhost';
        $this->dbName = 'test';
        $this->password = '';
        $this->dbUser = 'root';
        $this->charset = 'utf8mb4';

        try {
            $dsn = 'mysql:host=' . $this->host . ';dbname=' . $this->dbName . ';charset=' . $this->charset;
            self::$pdoInstance = new PDO($dsn, $this->dbUser, $this->password);
            self::$pdoInstance->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
            echo 'Connected'; // 现在只会输出一次
            return self::$pdoInstance;
        } catch (PDOException $exception) {
            $message = 'Connection failed:' . $exception->getMessage();
            return $message;
        }
    }
}

修改后，第一次调用connect()会创建连接并保存实例，后续所有调用都会复用这个实例，自然只会输出一次"Connected"。

方案二：将Dbh实现为单例类 #

单例模式可以确保整个应用中只有一个Dbh实例，连接在实例初始化时创建，后续所有操作都复用这个实例的连接：

class Dbh {
    private $host;
    private $dbName;
    private $password;
    private $dbUser;
    private $charset;
    private $pdoInstance;
    // 静态属性：存储唯一的Dbh实例
    private static $instance = null;

    // 私有构造函数：禁止外部直接new Dbh()
    private function __construct() {
        $this->host = 'localhost';
        $this->dbName = 'test';
        $this->password = '';
        $this->dbUser = 'root';
        $this->charset = 'utf8mb4';
        // 初始化连接
        $this->initConnection();
    }

    // 私有初始化方法：创建PDO连接
    private function initConnection() {
        try {
            $dsn = 'mysql:host=' . $this->host . ';dbname=' . $this->dbName . ';charset=' . $this->charset;
            $this->pdoInstance = new PDO($dsn, $this->dbUser, $this->password);
            $this->pdoInstance->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
            echo 'Connected';
        } catch (PDOException $exception) {
            die('Connection failed:' . $exception->getMessage());
        }
    }

    // 静态方法：获取Dbh实例（唯一入口）
    public static function getInstance() {
        if (self::$instance === null) {
            self::$instance = new self();
        }
        return self::$instance;
    }

    // 对外提供获取PDO连接的方法
    public function getConnection() {
        return $this->pdoInstance;
    }

    // 私有克隆方法：禁止克隆实例
    private function __clone() {}
}

然后在User类中，通过单例入口获取连接，所有方法复用同一个连接：

class User {
    private $db;

    public function __construct() {
        // 获取唯一的Dbh实例，进而获取PDO连接
        $this->db = Dbh::getInstance()->getConnection();
    }

    public function getAllUsers() {
        // 使用$this->db执行查询逻辑
        $stmt = $this->db->query("SELECT * FROM users");
        return $stmt->fetchAll();
    }

    public function updateUser() {
        // 使用$this->db执行更新逻辑
    }

    public function insertUsers() {
        // 使用$this->db执行插入逻辑
    }
}

这种方式更严谨，从根本上确保了Dbh实例的唯一性，连接只会初始化一次。

内容的提问来源于stack exchange，提问作者Shadow