Graze\DataDb\Import\IteratorImporter

Complexity

Total Complexity

3

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	import()	0	9	2

<?php

namespace Graze\DataDb\Import;

use Graze\DataDb\Dialect\DialectInterface;
use Graze\DataDb\Helper\ChunkedIterator;
use Graze\DataDb\TableNodeInterface;
use Graze\DataFile\Helper\Builder\BuilderAwareInterface;
use Graze\DataFile\Helper\Builder\BuilderTrait;
use Traversable;

class IteratorImporter implements IteratorImporterInterface, BuilderAwareInterface
{
    use BuilderTrait;

    /** @var TableNodeInterface */
    private $table;
    /** @var int */
    private $batchSize;
    /** @var DialectInterface */
    private $dialect;

    /**
     * IteratorImporter constructor.
     *
     * @param TableNodeInterface $table
     * @param int                $batchSize
     */
    public function __construct(TableNodeInterface $table, $batchSize = 100)
    {
        $this->table = $table;
        $this->batchSize = $batchSize;
        $this->dialect = $table->getAdapter()->getDialect();
    }

    /**
     * @param Traversable $iterator
     *
     * @return TableNodeInterface
     */
    public function import(Traversable $iterator)
    {
        $chunkIterator = $this->getBuilder()->build(ChunkedIterator::class, $iterator, $this->batchSize);
        foreach ($chunkIterator as $rows) {
            list ($sql, $bind) = $this->dialect->getInsertSyntax($this->table, $rows);
            $this->table->getAdapter()->query($sql, $bind);
        }
        return $this->table;
    }
}