mauretto78 / db-importer

src/QueryBuilder/AbstractQueryBuilder.php

<?php
/**
 * This file is part of the DbImporter package.
 *
 * (c) Mauro Cassani<https://github.com/mauretto78>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace DbImporter\QueryBuilder;

use DbImporter\QueryBuilder\Contracts\QueryBuilderInterface;
use Doctrine\Common\Collections\ArrayCollection;

abstract class AbstractQueryBuilder implements QueryBuilderInterface
{
    /**
     * @var string
     */
    protected $table;

    /**
     * @var bool
     */
    protected $debug;

    /**
     * @var array
     */
    protected $mapping;

    /**
     * @var ArrayCollection
     */
    protected $data;

    /**
     * MySqlQueryBuilderTest constructor.
     * @param $table
     * @param $debug
     * @param array $mapping
     * @param array $data
     */
    public function __construct(
        $table,
        array $mapping,
        array $data,
        $debug
    ) {
        $this->table = $table;
        $this->mapping = $mapping;
        $this->data = $data;

It seems like $data of type array is incompatible with the declared type Doctrine\Common\Collections\ArrayCollection of property $data.

        $this->debug = $debug;
    }

    /**
     * @param $index
     * @param $array
     * @return string
     */
    protected function appendComma($index, $array)
    {
        if ($index < (count($array))) {
            return  ', ';
        }
    }

    /**
     * @param $mode
     * @return array
     */
    protected function getQueriesBody($mode, $limit)
    {
        if ($mode == 'multiple') {
            return $this->getMultipleInsertQueriesBody($limit);
        }

        return $this->getSingleInsertQueriesBody();
    }

    /**
     * @return array
     */
    protected function getMultipleInsertQueriesBody($limit)
    {
        $sql = [];
        $data = array_chunk($this->data, $limit, true);

$this->data of type Doctrine\Common\Collections\ArrayCollection is incompatible with the type array expected by parameter $input of array_chunk().

        foreach ($data as $array) {
            $count = count($array);
            $string = '';

            for ($c = 1; $c <= $count; $c++) {
                $string .= '('.$this->getItemPlaceholders($c).')';
                $string .= $this->appendComma($c, $array);
            }

            $sql[] = $string;
        }

        return $sql;
    }

    /**
     * @return array
     */
    protected function getSingleInsertQueriesBody()
    {
        $sql = [];
        $count = count($this->data);

        for ($c = 1; $c <= $count; $c++) {
            $sql[] = '('.$this->getItemPlaceholders().')';
        }

        return $sql;
    }

    /**
     * @param $index
     * @return string
     */
    private function getItemPlaceholders($index = null)
    {
        $sql = '';
        $c = 1;
        $values = array_values($this->mapping);

        foreach ($values as $map) {
            $sql .= ($index) ? ':'.$map.'_'.$index : ':'.$map;
            $sql .= $this->appendComma($c, $values);
            $c++;
        }

        return $sql;
    }
}