sysPass/lib/SP/Storage/Database/MySQLFileParser.php

<?php
/*
 * sysPass
 *
 * @author nuxsmin
 * @link https://syspass.org
 * @copyright 2012-2021, Rubén Domínguez nuxsmin@$syspass.org
 *
 * This file is part of sysPass.
 *
 * sysPass is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * sysPass is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with sysPass.  If not, see <http://www.gnu.org/licenses/>.
 */

namespace SP\Storage\Database;

use SP\Storage\File\FileException;
use SP\Storage\File\FileHandler;

/**
 * Class MysqlFileParser
 *
 * @package SP\Storage
 */
final class MySQLFileParser implements DatabaseFileInterface
{
    private FileHandler $fileHandler;

    public function __construct(FileHandler $fileHandler)
    {
        $this->fileHandler = $fileHandler;
    }

    /**
     * Parses a database script file and returns an array of lines parsed
     *
     * @throws FileException
     */
    public function parse(string $delimiter = ';'): array
    {
        $queries = [];
        $query = '';
        $delimiterLength = strlen($delimiter);

        $this->fileHandler->checkIsReadable();

        $handle = $this->fileHandler->open('rb');

        while (($buffer = fgets($handle)) !== false) {
            $buffer = trim($buffer);
            $length = strlen($buffer);

            if ($length > 0
                && strpos($buffer, '--') !== 0
            ) {
                // CHecks if delimiter based EOL is reached
                $end = strrpos($buffer, $delimiter) === $length - $delimiterLength;

                // Checks if line is an SQL statement wrapped by a comment
                if (preg_match('#^(?<stmt>/\*!\d+.*\*/)#', $buffer, $matches)) {
                    if (!$end) {
                        $query .= $matches['stmt'] . PHP_EOL;
                    } else {
                        $queries[] = $query . $matches['stmt'];

                        $query = '';
                    }
                } else if (!$end) {
                    $query .= $buffer . PHP_EOL;
                } else if (strpos($buffer, 'DELIMITER') === false) {
                    $queries[] = $query .
                        trim(substr_replace(
                            $buffer,
                            '',
                            $length - $delimiterLength),
                            $delimiterLength
                        );

                    $query = '';
                }
            }
        }

        $this->fileHandler->close();

        return $queries;
    }
}