Lagdo\DbAdmin\DbAdmin\TableSelectAdmin::execSelect()

Complexity

Conditions	33
Paths	> 20000

Size

Total Lines	140
Code Lines	80

Duplication

Lines	0
Ratio	0 %

Importance

Changes	7
Bugs	0	Features	0

<?php
    public function execSelect(string $table, array $queryOptions): array
    {
        list(, $query, $select, $fields, , , $indexes, $where, $group, , $limit, $page,
            $textLength, , $unselected) = $this->prepareSelect($table, $queryOptions);

        $error = null;
        // From driver.inc.php
        $start = microtime(true);
        $statement = $this->driver->execute($query);
        // From adminer.inc.php
        $duration = $this->trans->formatTime($start); // Compute and format the duration

        if (!$statement) {
            return ['error' => $this->driver->error()];
        }
        // From select.inc.php
        $rows = [];
        while (($row = $statement->fetchAssoc())) {
            if ($page && $this->driver->jush() == "oracle") {
                unset($row["RNUM"]);
            }
            $rows[] = $row;
        }
        if (!$rows) {
            return ['error' => $this->trans->lang('No rows.')];
        }
        // $backward_keys = $this->driver->backwardKeys($table, $tableName);

        // Results headers
        $headers = [
            '', // !$group && $select ? '' : lang('Modify');
        ];
        $names = [];
        // $functions = [];
        reset($select);
        $rank = 1;
        foreach ($rows[0] as $key => $value) {
            $header = [];
            if (!isset($unselected[$key])) {
                $value = $queryOptions["columns"][key($select)] ?? [];
                $fun = $value["fun"] ?? '';
                $field = $fields[$select ? ($value ? $value["col"] : current($select)) : $key];
                $name = ($field ? $this->util->fieldName($field, $rank) : ($fun ? "*" : $key));
                $header = compact('value', 'field', 'name');
                if ($name != "") {
                    $rank++;
                    $names[$key] = $name;
                    $column = $this->driver->escapeId($key);
                    // $href = remove_from_uri('(order|desc)[^=]*|page') . '&order%5B0%5D=' . urlencode($key);
                    // $desc = "&desc%5B0%5D=1";
                    $header['column'] = $column;
                    $header['key'] = $this->util->html($this->util->bracketEscape($key));
                    $header['sql'] = $this->util->applySqlFunction($fun, $name); //! columns looking like functions
                }
                // $functions[$key] = $fun;
                next($select);
            }
            $headers[] = $header;
        }

        // $lengths = [];
        // if($queryOptions["modify"])
        // {
        //     foreach($rows as $row)
        //     {
        //         foreach($row as $key => $value)
        //         {
        //             $lengths[$key] = \max($lengths[$key], \min(40, strlen(\utf8_decode($value))));
        //         }
        //     }
        // }

        $results = [];
        foreach ($rows as $n => $row) {
            $uniqueIds = $this->util->uniqueIds($rows[$n], $indexes);
            if (empty($uniqueIds)) {
                foreach ($row as $key => $value) {
                    if (!\preg_match('~^(COUNT\((\*|(DISTINCT )?`(?:[^`]|``)+`)\)|(AVG|GROUP_CONCAT|MAX|MIN|SUM)\(`(?:[^`]|``)+`\))$~', $key)) {
                        //! columns looking like functions
                        $uniqueIds[$key] = $value;
                    }
                }
            }

            // Unique identifier to edit returned data.
            // $unique_idf = "";
            $rowIds = [
                'where' => [],
                'null' => [],
            ];
            foreach ($uniqueIds as $key => $value) {
                $key = \trim($key);
                $type = '';
                $collation = '';
                if (isset($fields[$key])) {
                    $type = $fields[$key]->type;
                    $collation = $fields[$key]->collation;
                }
                if (($this->driver->jush() == "sql" || $this->driver->jush() == "pgsql") &&
                    \preg_match('~char|text|enum|set~', $type) && strlen($value) > 64) {
                    $key = (\strpos($key, '(') ? $key : $this->driver->escapeId($key)); //! columns looking like functions
                    $key = "MD5(" . ($this->driver->jush() != 'sql' || \preg_match("~^utf8~", $collation) ?
                        $key : "CONVERT($key USING " . $this->driver->charset() . ")") . ")";
                    $value = \md5($value);
                }
                if ($value !== null) {
                    $rowIds['where'][$this->util->bracketEscape($key)] = $value;
                } else {
                    $rowIds['null'][] = $this->util->bracketEscape($key);
                }
                // $unique_idf .= "&" . ($value !== null ? \urlencode("where[" . $this->util->bracketEscape($key) . "]") .
                //     "=" . \urlencode($value) : \urlencode("null[]") . "=" . \urlencode($key));
            }

            $cols = [];
            foreach ($row as $key => $value) {
                if (isset($names[$key])) {
                    $field = $fields[$key] ?? new TableFieldEntity();
                    $value = $this->driver->value($value, $field);
                    if ($value != "" && (!isset($email_fields[$key]) || $email_fields[$key] != "")) {
                        //! filled e-mails can be contained on other pages
                        $email_fields[$key] = ($this->util->isMail($value) ? $names[$key] : "");
                    }

                    $link = "";

                    $value = $this->util->selectValue($value, $link, $field, $textLength);
                    $text = preg_match('~text|lob~', $field->type);

                    $cols[] = compact(/*'id', */'text', 'value'/*, 'editable'*/);
                }
            }
            $results[] = ['ids' => $rowIds, 'cols' => $cols];
        }

        $isGroup = count($group) < count($select);
        $total = $this->driver->result($this->driver->sqlForRowCount($table, $where, $isGroup, $group));

        $rows = $results;
        return compact('duration', 'headers', 'query', 'rows', 'limit', 'total', 'error');
    }