Выбор к какой функции делать обращение

    class bb
    {
 
        public $db_id;
    
        function __construct() {
        
            $this->db_id = new PDO('mysql:dbname=table;host=localhost', 'user', 'pass', [PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'utf8'"]);
            $this->db_id->errorInfo() && $this->display_error($this->db_id->errorInfo(), $this->sql);
    
        }
    
        function query($sql, $value, $type = 'fetchAll')
        {
                        $this->sql = $sql;
            $this->db_id->prepare($sql);
            $this->db_id->execute($value);
            return $this->db_id->fetchAll(PDO::FETCH_ASSOC);
        }
 
        function display_error($error, $sql = '')
        {
            print_r($sql);
            print_r($error);
 
        }
    
        function __destruct() {
                //Как закрыть соединение?
        }
        
    }

$type = 'fetchAll'

$this->db_id->fetchAll(PDO::FETCH_ASSOC);

$this->db_id->fetch(PDO::FETCH_ASSOC);

    function query($sql, $value, $type = 'fetchAll')
    {
        $stmt = $this->db_id->prepare($sql);
        $stmt->execute($value);
 
        if ($type == 'fetchAll') {
            return $stmt->fetchAll(PDO::FETCH_ASSOC);
        }
 
        if ($type === 'fetch') {
            return $stmt->fetch(PDO::FETCH_ASSOC);
        }
        
        throw new Exception('Unknown fetch type');
    }

    function __construct()
    {
        $this->db_id = new PDO('mysql:dbname=table;host=localhost', 'user', 'pass', [
            PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'utf8'",
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION
        ]);
    }

$this->db_id->errorInfo()

PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION

$stmt->$type(PDO::FETCH_ASSOC);
$stmt->$type();

throw new Exception('Unknown fetch type');

$this->db_id->errorInfo() && $this->display_error($this->db_id->errorInfo(), $this->sql);

throw new Exception($this->display_error($this->db_id->errorInfo(), $this->sql));

throw new Exception(e);
             $this->display_error(e, $this->sql)