League\Csv\MySQLConverter

Complexity

Total Complexity

20

Size/Duplication

Total Lines	159
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	3
A	convert()	0	9	1
A	generateUseStatement()	0	4	1
A	generateDropStatement()	0	4	1
A	generateCreateStatement()	0	5	1
A	generateInsertStatement()	0	5	1
A	getTableStr()	0	4	1
A	prepareRecords()	0	19	4
B	prepareColumns()	0	44	7

<?php

/**
 * League.Csv (https://csv.thephpleague.com)
 *
 * (c) Ignace Nyamagana Butera <nyamsprod@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace League\Csv;

use Traversable;

/**
 * Converts tabular data into a SQL string.
 */
class MySQLConverter
{
    /**
     * @var string
     */
    protected $table = 'csv_data';

    /**
     * @var string
     */
    protected $database = 'csv_data';

    /**
     * MySQLConverter constructor.
     * @param string $database
     * @param string $table
     */
    public function __construct(string $database = '', string $table = '')
    {
        if (! empty($table)) {
            $this->table = $table;
        }
        if (! empty($database)) {
            $this->database = $database;
        }
    }

    /**
     * @param Traversable $records
     * @return string
     */
    public function convert(Traversable $records): string
    {
        $sql = $this->generateUseStatement();
        $sql .= $this->generateDropStatement();
        $sql .= $this->generateCreateStatement($records);
        $sql .= $this->generateInsertStatement($records);

        return $sql;
    }

    /**
     * @return string
     */
    protected function generateUseStatement(): string
    {
        return 'USE `'.$this->database.'`;'.PHP_EOL;
    }

    /**
     * @return string
     */
    protected function generateDropStatement(): string
    {
        return 'DROP TABLE IF EXISTS '.$this->getTableStr().';'.PHP_EOL;
    }

    /**
     * @param Traversable $records
     * @return string
     */
    protected function generateCreateStatement(Traversable $records): string
    {
        $fields = $this->prepareColumns($records);
        return 'CREATE TABLE '.$this->getTableStr().' ('.PHP_EOL.$fields.PHP_EOL.') ENGINE=innodb;'.PHP_EOL;
    }

    /**
     * @param Traversable $records
     * @return string
     */
    protected function generateInsertStatement(Traversable $records): string
    {
        $records = $this->prepareRecords($records);
        return $records;
    }

    /**
     * @return string
     */
    protected function getTableStr(): string
    {
        return '`'.$this->database.'`.`'.$this->table.'`';
    }

    /**
     * @param Traversable $records
     * @return string
     */
    protected function prepareRecords(Traversable $records): string
    {
        $values = [];
        foreach ($records as $row) {
            $fields = [];
            foreach ($row as $data) {
                $data = trim($data);
                if (empty($data)) {
                    $fields[] = 'NULL';
                } else {
                    $fields[] = "'".trim($data)."'";
                }
            }
            $fields = 'INSERT INTO '.$this->getTableStr().' VALUES ('.implode(',', $fields).');';
            $values[] = $fields;
        }
        $values = implode(PHP_EOL, $values);
        return $values;
    }


    /**
     * @param Traversable $records
     * @return string
     */
    protected function prepareColumns(Traversable $records): string
    {
        $records->rewind();

It seems like you code against a concrete implementation and not the interface Traversable as the method rewind() does only exist in the following implementations of said interface: APCUIterator, AppendIterator, ArrayIterator, CachingIterator, CallbackFilterIterator, DirectoryIterator, EmptyIterator, File_Iterator, FilesystemIterator, FilterIterator, Generator, GlobIterator, HttpMessage, HttpRequestPool, Imagick, ImagickPixelIterator, InfiniteIterator, Issue523, IteratorIterator, League\Csv\MapIterator, League\Csv\Stream, LimitIterator, MongoCommandCursor, MongoCursor, MongoGridFSCursor, MultipleIterator, Nette\Iterators\CachingIterator, Nette\Iterators\Mapper, NoRewindIterator, PHPUnit\Framework\TestSuiteIterator, PHPUnit\Runner\Filter\ExcludeGroupFilterIterator, PHPUnit\Runner\Filter\GroupFilterIterator, PHPUnit\Runner\Filter\IncludeGroupFilterIterator, PHPUnit\Runner\Filter\NameFilterIterator, PHP_Token_Stream, ParentIterator, Phar, PharData, PharIo\Manifest\AuthorCollectionIterator, PharIo\Manifest\AuthorElementCollection, PharIo\Manifest\BundledComponentCollectionIterator, PharIo\Manifest\ComponentElementCollection, PharIo\Manifest\ElementCollection, PharIo\Manifest\ExtElementCollection, PharIo\Manifest\RequirementCollectionIterator, PhpCsFixer\Doctrine\Annotation\Tokens, PhpCsFixer\Runner\FileCachingLintingIterator, PhpCsFixer\Runner\FileFilterIterator, PhpCsFixer\Runner\FileLintingIterator, PhpCsFixer\Tokenizer\Tokens, RecursiveArrayIterator, RecursiveCachingIterator, RecursiveCallbackFilterIterator, RecursiveDirectoryIterator, RecursiveFilterIterator, RecursiveIteratorIterator, RecursiveRegexIterator, RecursiveTreeIterator, RegexIterator, SQLiteResult, SebastianBergmann\CodeCoverage\Node\Iterator, SimpleXMLIterator, SplDoublyLinkedList, SplFileObject, SplFixedArray, SplHeap, SplMaxHeap, SplMinHeap, SplObjectStorage, SplPriorityQueue, SplQueue, SplStack, SplTempFileObject, Symfony\Component\Finder\Iterator\CustomFilterIterator, Symfony\Component\Finder\Iterator\DateRangeFilterIterator, Symfony\Component\Finder\Iterator\DepthRangeFilterIterator, Symfony\Component\Finder\Iterator\ExcludeDirectoryFilterIterator, Symfony\Component\Finder\Iterator\FileTypeFilterIterator, Symfony\Component\Finder\Iterator\FilecontentFilterIterator, Symfony\Component\Finder\Iterator\FilenameFilterIterator, Symfony\Component\Finder\Iterator\MultiplePcreFilterIterator, Symfony\Component\Finder\Iterator\PathFilterIterator, Symfony\Component\Finder\Iterator\RecursiveDirectoryIterator, Symfony\Component\Finder\Iterator\SizeRangeFilterIterator, Symfony\Component\Finder\Tests\Iterator\InnerNameIterator, Symfony\Component\Finder\Tests\Iterator\InnerSizeIterator, Symfony\Component\Finder\Tests\Iterator\InnerTypeIterator, Symfony\Component\Finder\Tests\Iterator\Iterator, Symfony\Component\Finder\Tests\Iterator\MockFileListIterator, Symfony\Component\Finder\Tests\Iterator\TestMultiplePcreFilterIterator, TestIterator, TestIterator2, TheSeer\Tokenizer\TokenCollection.

        $sample_data = $records->current();

It seems like you code against a concrete implementation and not the interface Traversable as the method current() does only exist in the following implementations of said interface: APCUIterator, AppendIterator, ArrayIterator, CachingIterator, CallbackFilterIterator, DirectoryIterator, EmptyIterator, File_Iterator, FilesystemIterator, FilterIterator, Generator, GlobIterator, HttpMessage, HttpRequestPool, Imagick, ImagickPixelIterator, InfiniteIterator, Issue523, IteratorIterator, League\Csv\MapIterator, League\Csv\Stream, LimitIterator, MongoCommandCursor, MongoCursor, MongoGridFSCursor, MultipleIterator, Nette\Iterators\CachingIterator, Nette\Iterators\Mapper, NoRewindIterator, PHPUnit\Framework\TestSuiteIterator, PHPUnit\Runner\Filter\ExcludeGroupFilterIterator, PHPUnit\Runner\Filter\GroupFilterIterator, PHPUnit\Runner\Filter\IncludeGroupFilterIterator, PHPUnit\Runner\Filter\NameFilterIterator, PHP_Token_Stream, ParentIterator, Phar, PharData, PharIo\Manifest\AuthorCollectionIterator, PharIo\Manifest\AuthorElementCollection, PharIo\Manifest\BundledComponentCollectionIterator, PharIo\Manifest\ComponentElementCollection, PharIo\Manifest\ElementCollection, PharIo\Manifest\ExtElementCollection, PharIo\Manifest\RequirementCollectionIterator, PhpCsFixer\Doctrine\Annotation\Tokens, PhpCsFixer\Runner\FileCachingLintingIterator, PhpCsFixer\Runner\FileFilterIterator, PhpCsFixer\Runner\FileLintingIterator, PhpCsFixer\Tokenizer\Tokens, RecursiveArrayIterator, RecursiveCachingIterator, RecursiveCallbackFilterIterator, RecursiveDirectoryIterator, RecursiveFilterIterator, RecursiveIteratorIterator, RecursiveRegexIterator, RecursiveTreeIterator, RegexIterator, SQLiteResult, SebastianBergmann\CodeCoverage\Node\Iterator, SimpleXMLIterator, SplDoublyLinkedList, SplFileObject, SplFixedArray, SplHeap, SplMaxHeap, SplMinHeap, SplObjectStorage, SplPriorityQueue, SplQueue, SplStack, SplTempFileObject, Symfony\Component\Finder\Iterator\CustomFilterIterator, Symfony\Component\Finder\Iterator\DateRangeFilterIterator, Symfony\Component\Finder\Iterator\DepthRangeFilterIterator, Symfony\Component\Finder\Iterator\ExcludeDirectoryFilterIterator, Symfony\Component\Finder\Iterator\FileTypeFilterIterator, Symfony\Component\Finder\Iterator\FilecontentFilterIterator, Symfony\Component\Finder\Iterator\FilenameFilterIterator, Symfony\Component\Finder\Iterator\MultiplePcreFilterIterator, Symfony\Component\Finder\Iterator\PathFilterIterator, Symfony\Component\Finder\Iterator\RecursiveDirectoryIterator, Symfony\Component\Finder\Iterator\SizeRangeFilterIterator, Symfony\Component\Finder\Tests\Iterator\InnerNameIterator, Symfony\Component\Finder\Tests\Iterator\InnerSizeIterator, Symfony\Component\Finder\Tests\Iterator\InnerTypeIterator, Symfony\Component\Finder\Tests\Iterator\Iterator, Symfony\Component\Finder\Tests\Iterator\MockFileListIterator, Symfony\Component\Finder\Tests\Iterator\TestMultiplePcreFilterIterator, TestIterator, TestIterator2, TheSeer\Tokenizer\TokenCollection.

        $columns = array_keys($sample_data);
        $fields = [];
        foreach ($columns as $column) {
            $column_name = strtolower(iconv('UTF-8', 'ASCII//TRANSLIT', $column));
            $column_name = preg_replace('/[ ]+/', ' ', $column_name);
            $column_name = str_replace(' ', '_', $column_name);
            $data = trim($sample_data[$column]);

            $is_int = filter_var($data, FILTER_VALIDATE_INT);
            if ($is_int !== false) {
                if ($is_int < 2147483647) {
                    $fields[] = '`'.$column_name.'` INT NULL';
                } else {
                    $fields[] = '`'.$column_name.'` BIGINT NULL';
                }

                continue;
            }

            $is_float = filter_var($data, FILTER_VALIDATE_FLOAT);
            if ($is_float !== false) {
                if ($is_float < 2147483647) {
                    $fields[] = '`'.$column_name.'` FLOAT(10,24) NULL';
                } else {
                    $fields[] = '`'.$column_name.'` DOUBLE(16,53) NULL';
                }

                continue;
            }

            if (strlen($data) < 255) {
                $fields[] = '`'.$column_name.'` VARCHAR(255) NULL';
            } else {
                $fields[] = '`'.$column_name.'` LONGTEXT NULL';
            }
        }

        $fields = implode(','.PHP_EOL, $fields);
        return $fields;
    }
}