XoopsModules\Wgsitenotice\Common\MigrateHelper::createSchemaFromSqlfile()

Complexity

Conditions	28
Paths	4186

Size

Total Lines	122
Code Lines	81

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function createSchemaFromSqlfile(): bool
    {
        if (!\file_exists($this->fileSql)) {
            \xoops_error('Error: Sql file not found!');

The function xoops_error was not found. Maybe you did not declare it correctly or list all dependencies?

            return false;
        }

        $tables    = [];
        $schema    = [];
        $tableName = '';

        // read sql file
        $lines = \file($this->fileSql);

        // remove unnecessary lines
        foreach ($lines as $key => $value) {
            $line = \trim($value);
            // remove blank lines
            if ('' === $line) {
                unset($lines[$key]);
            }
            // remove comment lines
            if ('#' === \substr($line, 0, 1)) {
                unset($lines[$key]);
            }
        }

        $skip = true;
        $skipWords = ['CREATE DATABASE ', 'CREATE VIEW ', 'INSERT INTO ', 'SELECT ', 'DELETE ', 'UPDATE ', 'ALTER ', 'DROP '];
        $options = '';
        // read remaining lines line by line and create new schema
        foreach ($lines as $key => $value) {
            $line = \trim($value);
            foreach ($skipWords as $skipWord) {
                if ($skipWord === \mb_strtoupper(\substr($line, 0, \strlen($skipWord)))) {
                    $skip = true;
                }
            }
            if ('CREATE TABLE' === \mb_strtoupper(\substr($line, 0, 12))) {
                $skip = false;
                $options = '';
                // start table definition
                $tableName = $this->getTableName ($line);
                $tables[$tableName] = [];
                $tables[$tableName]['options'] = '';
                $tables[$tableName]['columns'] = [];
                $tables[$tableName]['keys'] = [];
            } else {
                if (false == $skip) {

It seems like you are loosely comparing two booleans. Considering using the strict comparison === instead.

                    if (')' === \mb_strtoupper(\substr($line, 0, 1))) {
                        // end of table definition
                        // get options
                        $this->getOptions($line, $options);
                        $tables[$tableName]['options'] = $options;
                    } elseif ('ENGINE' === \mb_strtoupper(\substr($line, 0, 6))) {
                        $this->getOptions($line, $options);
                        $tables[$tableName]['options'] = $options;
                    } elseif ('DEFAULT CHARSET ' === \mb_strtoupper(\substr($line, 0, 16))) {
                        $this->getOptions($line, $options);
                        $tables[$tableName]['options'] = $options;
                    } else {
                        // get keys and fields
                        switch (\mb_strtoupper(\substr($line, 0, 3))) {
                            case 'KEY':
                            case 'PRI':
                            case 'UNI':
                                $tables[$tableName]['keys'][] = $this->getKey($line);
                                break;
                            case 'else':
                            default:
                                $columns = $this->getColumns($line);
                                $tables[$tableName]['columns'][] = $columns;
                                break;
                        }
                    }
                }
            }
        }

        // create array for new schema
        $level1 = \str_repeat(' ', 4);
        $level2 = \str_repeat(' ', 8);
        $level3 = \str_repeat(' ', 12);

        foreach ($tables as $tkey => $table) {
            $schema[] = "{$tkey}:\n";
            foreach ($table as $lkey => $line) {
                if ('keys' == $lkey) {
                    $schema[] = $level1 . "keys:\n";
                    foreach ($line as $kkey => $kvalue) {
                        foreach ($kvalue as $kkey2 => $kvalue2) {
                            $schema[] = $level2 . $kkey2 . ":\n";
                            $schema[] = $level3 . 'columns: ' . $kvalue2['columns'] . "\n";
                            $schema[] = $level3 . 'unique: ' . $kvalue2['unique'] . "\n";
                        }
                    }
                } elseif ('options' == $lkey) {
                    $schema[] = $level1 . 'options: ' . $line . "\n";
                } else {
                    $schema[] = $level1 . 'columns: ' . "\n";
                    foreach ($line as $kkey => $kvalue) {
                        $schema[] = $level2 . '-' . "\n";
                        foreach ($kvalue as $kkey2 => $kvalue2) {
                            $schema[] = $level3 . $kkey2 . ": " . $kvalue2 . "\n";
                        }
                    }
                }
            }
        }

        // create new file and write schema array into this file
        $myfile = \fopen($this->fileYaml, "w");
        if (false == $myfile || \is_null($myfile)) {
            \xoops_error('Error: Unable to open sql file!');
            return false;
        }
        foreach ($schema as $line) {
            \fwrite($myfile, $line);
        }
        \fclose($myfile);

        return true;