Конвертировать класс mysqli в pdo

Question

Привет, я пытаюсь преобразовать этот класс mysqli в pdo. Это версия mysqli класса, которую я не могу заставить работать версию pdo, как будет объяснено позже в моем посте

    class rb_mysqli extends rbDatabase {
    function query($query){
        $query = $this->connection->query($query);
        //$error = mysqli_error($this->connection); if(!empty($error)){ echo $error . "<br />Query that errored: ".$this->lastquery; } 
        return $query;
    }
    function real_escape_string($str)
    {
        $result = $this->connection->real_escape_string($str);
        return $result;
    }
    function fetch_assoc($query){
        $result = mysqli_fetch_assoc($query);
        return $result;
    }
    function fetch_row($query){
        $result = mysqli_fetch_row($query);
        return $result;
    }
    function fetch_array($result){
        $result = mysqli_fetch_array($result);
        return $result;
    }
    function num_rows($query){
        $result = mysqli_num_rows($query);


        return $result;
    }

    function result($res,$row=0,$col=0){ 
    $numrows = mysqli_num_rows($res); 
    if ($numrows && $row <= ($numrows-1) && $row >=0){
        mysqli_data_seek($res,$row);
        $resrow = (is_numeric($col)) ? mysqli_fetch_row($res) : mysqli_fetch_assoc($res);
        if (isset($resrow[$col])){
            return $resrow[$col];

        }
    }
    return false;
}

    function insert_id($query){
        return $this->connection->insert_id($query);
    }
}     

Это то, что я пытался сделать в pdo, но по какой-то причине он не может сделать то же самое, что и версия mysqli, может кто-нибудь помочь мне с этим, оценил бы это много?

    class my_pdo extends rbDatabase {
    function query($query){
        $query = $this->connection->prepare($query);
        $query->execute();
        return $query;
    }
    function real_escape_string($str)
    {
        return $str;
    }
    function fetch_assoc($query){
        $result = $query->fetchAll(PDO::FETCH_ASSOC);
        return $result;
    }
    function fetch_row($query){
        $result = $query->fetch(PDO::FETCH_ASSOC);
        return $result;
    }
    function fetch_array($result){
            $result = $result->fetch(PDO::FETCH_ASSOC);
        return $result;
    }
    function num_rows($query){
$this->connection->setAttribute(PDO::ATTR_STRINGIFY_FETCHES, false);
$this->connection->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$this->connection->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE,PDO::FETCH_ASSOC);
$this->connection->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);
$result = $query->fetch(PDO::FETCH_NUM);
        var_dump($result[0]);

return $result[0];



    }

    function result($res,$row=0,$col=0){ 

        $result = $res->fetch();
        return $result[$col];
    }

    function insert_id($query){
        return $this->connection->lastInsertId($query);
    }
}