PHP OOP中数据库连接的有效管理：避免冗余PDO实例

class UserOperations {
    // ... 属性定义 ...

    protected function insertUser(){
        // 每次调用此方法都会创建一个新的PDO连接
        $connectionvar = new PDO('mysql:host='. $this->host .';dbname='.$this->db, $this->user, $this->password);
        // ... 剩余的插入逻辑 ...
    }

    protected function updateUser(){
        // 每次调用此方法又会创建一个新的PDO连接
        $connectionvar = new PDO('mysql:host='. $this->host .';dbname='.$this->db, $this->user, $this->password);
        // ... 剩余的更新逻辑 ...
    }
}

class DatabaseConnection
{
    protected PDO $connection;

    /**
     * 构造函数：在类实例化时创建并存储PDO连接
     * @param string $host 数据库主机
     * @param string $dbName 数据库名
     * @param string $username 用户名
     * @param string $password 密码
     */
    public function __construct(string $host, string $dbName, string $username, string $password)
    {
        try {
            $dsn = "mysql:host={$host};dbname={$dbName};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, $username, $password, $options);
        } catch (PDOException $e) {
            // 记录错误或抛出自定义异常
            error_log("数据库连接失败: " . $e->getMessage());
            throw new Exception("无法连接到数据库。");
        }
    }

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

class QueryBuilder
{
    private PDO $pdo;

    /**
     * 构造函数：通过依赖注入接收PDO连接实例
     * @param PDO $pdo 已建立的PDO连接
     */
    public function __construct(PDO $pdo)
    {
        $this->pdo = $pdo;
    }

    /**
     * 执行一个SELECT查询并返回结果集
     * @param string $sql SQL查询语句
     * @param array $parameters 预处理语句的参数
     * @return array 查询结果（关联数组）
     * @throws PDOException
     */
    public function select(string $sql, array $parameters = []): array
    {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($parameters);
        return $stmt->fetchAll(PDO::FETCH_ASSOC);
    }

    /**
     * 执行INSERT, UPDATE, DELETE等非查询操作
     * @param string $sql SQL语句
     * @param array $parameters 预处理语句的参数
     * @return int 受影响的行数
     * @throws PDOException
     */
    public function execute(string $sql, array $parameters = []): int
    {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($parameters);
        return $stmt->rowCount();
    }

    /**
     * 获取最后插入的ID
     * @return string|false
     */
    public function lastInsertId()
    {
        return $this->pdo->lastInsertId();
    }

    // 可以在这里添加更多通用的数据库操作方法，如事务处理等
}

// 1. 初始化数据库连接（通常在应用程序启动时只执行一次）
try {
    $dbConfig = [
        'host' => 'localhost',
        'dbname' => 'mydatabase',
        'user' => 'root',
        'password' => 'password'
    ];
    $dbConnector = new DatabaseConnection(
        $dbConfig['host'],
        $dbConfig['dbname'],
        $dbConfig['user'],
        $dbConfig['password']
    );
    $pdoInstance = $dbConnector->getConnection();
} catch (Exception $e) {
    die("应用程序启动失败: " . $e->getMessage());
}

// 2. 创建QueryBuilder实例，传入已有的PDO连接
$queryBuilder = new QueryBuilder($pdoInstance);

// 3. 业务逻辑类使用QueryBuilder进行数据库操作
class UserService
{
    private QueryBuilder $db;

    public function __construct(QueryBuilder $db)
    {
        $this->db = $db;
    }

    public function createUser(string $username, string $email): int
    {
        $sql = "INSERT INTO users (username, email) VALUES (:username, :email)";
        $this->db->execute($sql, ['username' => $username, 'email' => $email]);
        return (int)$this->db->lastInsertId();
    }

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

    public function updateUserName(int $id, string $newUsername): int
    {
        $sql = "UPDATE users SET username = :username WHERE id = :id";
        return $this->db->execute($sql, ['username' => $newUsername, 'id' => $id]);
    }
}

// 4. 在应用程序中使用UserService
$userService = new UserService($queryBuilder);

// 示例：创建用户
$newUserId = $userService->createUser('john_doe', 'john@example.com');
echo "新用户ID: " . $newUserId . "\n";

// 示例：获取用户
$user = $userService->getUserById($newUserId);
if ($user) {
    print_r($user);
}

// 示例：更新用户
$affectedRows = $userService->updateUserName($newUserId, 'john_updated');
echo "更新了 " . $affectedRows . " 行\n";