PHP面向对象中高效管理数据库连接的教程

protected function insertUser(){
    $connectionvar = new PDO('mysql:host='. $this->host .';dbname='.$this->db, $this->user, $this->password);
    // ... 使用 $connectionvar 执行SQL ...
}

class DB {
    protected PDO $connection; // 声明一个PDO类型的属性来存储连接

    /**
     * 构造函数：在类实例化时建立数据库连接
     *
     * @param string $host 数据库主机
     * @param string $db 数据库名称
     * @param string $user 用户名
     * @param string $password 密码
     */
    public function __construct(string $host, string $db, string $user, string $password) {
        try {
            $dsn = 'mysql:host=' . $host . ';dbname=' . $db . ';charset=utf8mb4';
            $options = [
                PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION, // 错误模式：抛出异常
                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,       // 默认获取模式：关联数组
                PDO::ATTR_EMULATE_PREPARES   => false,                  // 禁用模拟预处理，使用原生预处理
            ];
            $this->connection = new PDO($dsn, $user, $password, $options);
        } catch (PDOException $e) {
            // 记录错误或抛出自定义异常
            throw new Exception("数据库连接失败: " . $e->getMessage());
        }
    }

    /**
     * 获取数据库连接实例
     *
     * @return PDO
     */
    protected function getConnection(): PDO {
        return $this->connection;
    }
}

class UserRepository extends DB { // 假设UserRepository处理用户相关数据
    public function __construct(string $host, string $db, string $user, string $password) {
        parent::__construct($host, $db, $user, $password); // 调用父类的构造函数建立连接
    }

    /**
     * 执行SQL查询并获取结果
     *
     * @param string $sql SQL查询语句
     * @param array $parameters 绑定到预处理语句的参数
     * @return array 查询结果
     */
    protected function runQueryAndGetResult(string $sql, array $parameters = []): array {
        $statement = $this->getConnection()->prepare($sql); // 通过父类方法获取连接
        $statement->execute($parameters);
        return $statement->fetchAll(PDO::FETCH_ASSOC);
    }

    /**
     * 插入新用户
     *
     * @param string $username 用户名
     * @param string $email 邮箱
     * @return bool 插入是否成功
     */
    public function insertUser(string $username, string $email): bool {
        $sql = "INSERT INTO users (username, email) VALUES (:username, :email)";
        $parameters = [
            ':username' => $username,
            ':email' => $email
        ];
        // 由于 runQueryAndGetResult 返回数组，这里需要调整为执行非查询操作
        // 或者提供一个专门的 execute 方法
        $statement = $this->getConnection()->prepare($sql);
        return $statement->execute($parameters);
    }

    /**
     * 获取所有用户
     *
     * @return array 用户列表
     */
    public function getAllUsers(): array {
        $sql = "SELECT id, username, email FROM users";
        return $this->runQueryAndGetResult($sql);
    }
}

// 使用示例
try {
    $userRepo = new UserRepository('localhost', 'mydatabase', 'myuser', 'mypassword');

    // 插入用户
    if ($userRepo->insertUser('john_doe', 'john.doe@example.com')) {
        echo "用户插入成功。\n";
    } else {
        echo "用户插入失败。\n";
    }

    // 获取所有用户
    $users = $userRepo->getAllUsers();
    print_r($users);

} catch (Exception $e) {
    echo "发生错误: " . $e->getMessage() . "\n";
}