如何高效管理PHP OOP中的数据库连接：避免冗余与资源浪费

protected function insertUser(){
    $connectionvar = new PDO('mysql:host='. $this->host .';dbname='.$this->db, $this->user, $this->password);
    // ... 后续的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) {
            // 在生产环境中，应记录错误而非直接输出
            error_log("数据库连接失败: " . $e->getMessage());
            die("数据库连接失败，请稍后再试。");
        }
    }
}

// 假设这是我们的核心数据库操作类
class QueryBuilder extends DB {

    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 查询结果集
     */
    public function runQueryAndGetResult(string $sql, array $parameters = []): array {
        try {
            $statement = $this->connection->prepare($sql);
            $statement->execute($parameters);
            return $statement->fetchAll(PDO::FETCH_ASSOC);
        } catch (PDOException $e) {
            error_log("SQL查询失败: " . $e->getMessage() . " SQL: " . $sql);
            throw new Exception("数据库查询错误，请联系管理员。");
        }
    }

    /**
     * 执行非查询SQL（插入、更新、删除）
     *
     * @param string $sql SQL语句
     * @param array $parameters 预处理语句的参数数组
     * @return int 受影响的行数
     */
    public function execute(string $sql, array $parameters = []): int {
        try {
            $statement = $this->connection->prepare($sql);
            $statement->execute($parameters);
            return $statement->rowCount();
        } catch (PDOException $e) {
            error_log("SQL执行失败: " . $e->getMessage() . " SQL: " . $sql);
            throw new Exception("数据库操作错误，请联系管理员。");
        }
    }

    // 可以添加更多如 insert, update, delete 等封装方法
}

// 示例：在某个业务逻辑类中使用QueryBuilder
class UserManager {
    private QueryBuilder $db;

    public function __construct(QueryBuilder $db) {
        $this->db = $db; // 通过依赖注入获取数据库操作对象
    }

    public function createUser(string $username, string $email, string $password): bool {
        $sql = "INSERT INTO users (username, email, password) VALUES (?, ?, ?)";
        $affectedRows = $this->db->execute($sql, [$username, $email, password_hash($password, PASSWORD_DEFAULT)]);
        return $affectedRows > 0;
    }

    public function getUserById(int $id): ?array {
        $sql = "SELECT id, username, email FROM users WHERE id = ?";
        $result = $this->db->runQueryAndGetResult($sql, [$id]);
        return $result ? $result[0] : null;
    }
}

// 使用示例
$dbConfig = [
    'host' => 'localhost',
    'db' => 'mydatabase',
    'user' => 'root',
    'password' => 'root'
];

$queryBuilder = new QueryBuilder($dbConfig['host'], $dbConfig['db'], $dbConfig['user'], $dbConfig['password']);
$userManager = new UserManager($queryBuilder); // 注入数据库操作对象

// 创建用户
if ($userManager->createUser('john_doe', 'john@example.com', 'secure_password')) {
    echo "用户创建成功！\n";
}

// 获取用户
$user = $userManager->getUserById(1);
if ($user) {
    print_r($user);
}