+global\MeekroDB::queryHelper()

Complexity

Conditions	29
Paths	9720

Size

Total Lines	131
Code Lines	87

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    protected function queryHelper() {
    $args = func_get_args();
    $type = array_shift($args);
    $database = $this->get();

    $is_buffered = true;
    $row_type = 'assoc'; // assoc, list, raw
    $full_names = false;

    switch ($type) {
        case 'assoc':
        break;
        case 'list':
        $row_type = 'list';
        break;
        case 'full':
        $row_type = 'list';
        $full_names = true;
        break;
        case 'raw_buf':
        $row_type = 'raw';
        break;
        case 'raw_unbuf':
        $is_buffered = false;
        $row_type = 'raw';
        break;
        default:
        $this->nonSQLError('Error -- invalid argument to queryHelper!');
    }

    $sql = call_user_func_array(array($this, 'parseQueryParams'), $args);

    if ($this->success_handler) {
        $starttime = microtime(true);
    }
    $result = $database->query($sql, $is_buffered ? MYSQLI_STORE_RESULT : MYSQLI_USE_RESULT);
    if ($this->success_handler) {
        $runtime = microtime(true) - $starttime;
    } else {
        $runtime = 0;
    }

    // ----- BEGIN ERROR HANDLING
    if (!$sql || $database->error) {
        if ($this->error_handler) {
        $db_error = $database->error;
        $db_errno = $database->errno;

        if (isset($_SESSION['user_id'])) {
            $database->query(
                "INSERT INTO ".$GLOBALS['pre']."log_system SET
              date=".time().",
              qui=".$_SESSION['user_id'].",
              label='Query: ".addslashes($sql)."<br />Error: ".addslashes($db_error)."<br />@ ".addslashes(filter_var($_SERVER['REQUEST_URI'], FILTER_SANITIZE_STRING))."',
              type='error'",
                MYSQLI_USE_RESULT
            );
        }

        $error_handler = is_callable($this->error_handler) ? $this->error_handler : 'meekrodb_error_handler';

        call_user_func($error_handler, array(
            'type' => 'sql',
            'query' => $sql,
            'error' => $db_error,
            'code' => $db_errno
        ));
        }

        if ($this->throw_exception_on_error) {
        $exeption = new MeekroDBException($db_error, $sql, $db_errno);
        throw $exeption;
        }
    } else if ($this->success_handler) {
        $runtime = sprintf('%f', $runtime * 1000);
        $success_handler = is_callable($this->success_handler) ? $this->success_handler : 'meekrodb_debugmode_handler';

        call_user_func($success_handler, array(
        'query' => $sql,
        'runtime' => $runtime,
        'affected' => $database->affected_rows
        ));
    }

    // ----- END ERROR HANDLING

    $this->insert_id = $database->insert_id;
    $this->affected_rows = $database->affected_rows;

    // mysqli_result->num_rows won't initially show correct results for unbuffered data
    if ($is_buffered && ($result instanceof MySQLi_Result)) {
        $this->num_rows = $result->num_rows;
    } else {
        $this->num_rows = null;
    }

    if ($row_type == 'raw' || !($result instanceof MySQLi_Result)) {
        return $result;
    }

    $return = array();

    if ($full_names) {
        $infos = array();
        foreach ($result->fetch_fields() as $info) {
        if (strlen($info->table)) {
            $infos[] = $info->table.'.'.$info->name;
        } else {
            $infos[] = $info->name;
        }
        }
    }

    while ($row = ($row_type == 'assoc' ? $result->fetch_assoc() : $result->fetch_row())) {
        if ($full_names) {
            $row = array_combine($infos, $row);
        }
        $return[] = $row;
    }

    // free results
    $result->free();
    while ($database->more_results()) {
        $database->next_result();
        if ($result = $database->use_result()) {
            $result->free();
        }
    }

    return $return;
    }

}