function views_plugin_query_default::execute

Executes the query and fills the associated view object with according values.

Values to set: $view->result, $view->total_rows, $view->execute_time, $view->current_page.

Overrides views_plugin_query::execute

File

plugins/views_plugin_query_default.inc, line 1152

Class

views_plugin_query_default

Object used to create a SELECT query.

Code

function execute(&$view) {
    $external = FALSE;
    // Whether this query will run against an external database.
    $query = $this->final_query;
    $count_query = $this->count_query;
    $args = $this->query_args;
    vpr($query);
    $items = array();
    if ($query) {
        $replacements = $this->view
            ->substitutions();
        $query = str_replace(array_keys($replacements), $replacements, $query);
        $count_query = 'SELECT COUNT(*) FROM (' . str_replace(array_keys($replacements), $replacements, $count_query) . ') count_alias';
        if (is_array($args)) {
            foreach ($args as $id => $arg) {
                $args[$id] = str_replace(array_keys($replacements), $replacements, $arg);
            }
        }
        // Detect an external database.
        if (isset($view->base_database)) {
            $this->db_set_active($view->base_database);
            $external = TRUE;
        }
        $start = views_microtime();
        if ($this->pager
            ->use_count_query() || !empty($view->get_total_rows)) {
            $this->pager
                ->execute_count_query($count_query, $args);
        }
        // Let the pager modify the query to add limits.
        $this->pager
            ->pre_execute($query, $args);
        if (!empty($this->limit) || !empty($this->offset)) {
            // We can't have an offset without a limit, so provide a very large limit instead.
            $limit = intval(!empty($this->limit) ? $this->limit : 999999);
            $offset = intval(!empty($this->offset) ? $this->offset : 0);
            $result = $this->db_query_range($query, $args, $offset, $limit);
        }
        else {
            $result = $this->db_query($query, $args);
        }
        $view->result = array();
        while ($item = $this->db_fetch_object($result)) {
            $view->result[] = $item;
        }
        $this->pager
            ->post_execute($view->result);
        if ($this->pager
            ->use_pager()) {
            $view->total_rows = $this->pager
                ->get_total_items();
        }
        if ($external) {
            $this->db_set_active();
        }
    }
    else {
        $start = views_microtime();
    }
    $view->execute_time = views_microtime() - $start;
}