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

<?php
/**
 * sysPass
 *
 * @author nuxsmin
 * @link https://syspass.org
 * @copyright 2012-2018, 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\FileException;
use SP\Storage\FileHandler;

/**
 * Class MysqlFileParser
 *
 * @package SP\Storage
 */
class MySQLFileParser implements DatabaseFileInterface
{

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

        $handle = $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
                $setComment = preg_match(/** @lang RegExp */
                    '#^(?P<statement>/\*!\d+.*\*/)#', $buffer, $matches);

                if ($setComment) {
                    if (!$end) {
                        $query .= $matches['statement'] . PHP_EOL;
                    } else {
                        $queries[] = $query . $matches['statement'];

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

                        $query = '';
                    }
                }
            }
        }

        $fileHandler->close();

        return $queries;
    }
}