Phing\Task\System\Pdo\DefaultPDOQuerySplitter::nextQuery()

Complexity

Conditions	23
Paths	122

Size

Total Lines	89
Code Lines	47

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function nextQuery(): ?string
    {
        $sql = '';
        $hasQuery = false;

        while (($line = $this->sqlReader->readLine()) !== null) {
            $delimiter = $this->parent->getDelimiter();
            $project = $this->parent->getOwningTarget()->getProject();
            if (!$this->keepformat) {
                $line = trim($line);
            }
            if ($this->expandProperties) {
                $line = $project->replaceProperties($line);
            }

            if (
                !$this->keepformat
                && ($line !== $delimiter)
                && (StringHelper::startsWith('//', $line)
                    || StringHelper::startsWith('--', $line)
                    || StringHelper::startsWith('#', $line))
            ) {
                continue;
            }

            if (
                strlen($line) > 4
                && stripos($line, 'REM ') === 0
            ) {
                continue;
            }

            // MySQL supports defining new delimiters
            if (preg_match('/DELIMITER [\'"]?([^\'" $]+)[\'"]?/i', $line, $matches)) {
                $this->parent->setDelimiter($matches[1]);

                continue;
            }

            if ('' !== $this->sqlBacklog) {
                $sql = $this->sqlBacklog;
                $this->sqlBacklog = '';
            }

            $sql .= ' ' . $line . "\n";

            // SQL defines "--" as a comment to EOL
            // and in Oracle it may contain a hint
            // so we cannot just remove it, instead we must end it
            if (!$this->keepformat && false !== strpos((string) $line, '--')) {
                $sql .= "\n";
            }

            // DELIM_ROW doesn't need this (as far as i can tell)
            if (PDOSQLExecTask::DELIM_NORMAL === $this->delimiterType) {
                $reg = "#((?:\"(?:\\\\.|[^\"])*\"?)+|'(?:\\\\.|[^'])*'?|" . preg_quote($delimiter, null) . ')#';

                $sqlParts = preg_split($reg, $sql, 0, PREG_SPLIT_DELIM_CAPTURE);
                $this->sqlBacklog = '';
                foreach ($sqlParts as $sqlPart) {
                    // we always want to append, even if it's a delim (which will be stripped off later)
                    $this->sqlBacklog .= $sqlPart;

                    // we found a single (not enclosed by ' or ") delimiter, so we can use all stuff before the delim as the actual query
                    if ($sqlPart === $delimiter) {
                        $sql = $this->sqlBacklog;
                        $this->sqlBacklog = '';
                        $hasQuery = true;
                    }
                }
            }

            if ($hasQuery || (PDOSQLExecTask::DELIM_ROW === $this->delimiterType && $line === $delimiter)) {
                // this assumes there is always a delimter on the end of the SQL statement.
                return StringHelper::substring(
                    $sql,
                    0,
                    strlen($sql) - strlen($delimiter)
                    - (PDOSQLExecTask::DELIM_ROW === $this->delimiterType ? 2 : 1)
                );
            }
        }

        // Catch any statements not followed by ;
        if ('' !== $sql) {
            return $sql;
        }

        return null;
    }