BfwSql\Queries\Insert

Complexity

Total Complexity

14

Size/Duplication

Total Lines	152
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	getQuoting()	0	4	1
A	defineQueriesParts()	0	15	1
A	obtainGenerateOrder()	0	21	1
A	generateValues()	0	27	5
A	generateSelect()	0	9	2
A	generateOnDuplicate()	0	15	3

<?php

namespace BfwSql\Queries;

/**
 * Class to write INSERT INTO queries
 * 
 * @package bfw-sql
 * @author Vermeulen Maxime <bulton.fr@gmail.com>
 * @version 2.0
 */
class Insert extends AbstractQuery
{
    /**
     * @var \BfwSql\Helpers\Quoting $quoting The quoting system
     */
    protected $quoting;
    
    /**
     * Constructor
     * 
     * @param \BfwSql\SqlConnect $sqlConnect Instance of SGBD connexion
     * @param string $quoteStatus (default: QUOTE_ALL) Status to automatic
     *  quoted string value system.
     */
    public function __construct(
        \BfwSql\SqlConnect $sqlConnect,
        $quoteStatus = \BfwSql\Helpers\Quoting::QUOTE_ALL
    ) {
        parent::__construct($sqlConnect);
        
        $this->quoting = new \BfwSql\Helpers\Quoting(
            $quoteStatus,
            $this->sqlConnect
        );
    }
    
    /**
     * Getter accessor to property quoting
     * 
     * @return \BfwSql\Helpers\Quoting
     */
    public function getQuoting(): \BfwSql\Helpers\Quoting
    {
        return $this->quoting;
    }
    
    /**
     * {@inheritdoc}
     */
    protected function defineQueriesParts()
    {
        parent::defineQueriesParts();
        unset($this->queriesParts['where']);
        
        $parts     = &$this->queriesParts; //Yes, it's just to have < 80 chars
        $partTable = $parts['table'];
        $partTable->setColumnsWithValue(true);
        $partTable->createColumnInstance();
        
        $parts['into']        = $partTable;
        $parts['values']      = $partTable->getColumns();
        $parts['select']      = new Select($this->sqlConnect, 'object');
        $parts['onDuplicate'] = new Parts\ColumnValueList($this, $partTable);
    }
    
    /**
     * {@inheritdoc}
     */
    protected function obtainGenerateOrder(): array
    {
        return [
            'table'           => [
                'prefix'     => 'INSERT INTO',
                'canBeEmpty' => false
            ],
            'values'          => [
                'callback'      => [$this, 'generateValues'],
                'usePartPrefix' => false
            ],
            'select'          => [
                'callback'      => [$this, 'generateSelect'],
                'usePartPrefix' => false
            ],
            'onDuplicate' => [
                'prefix'   => 'ON DUPLICATE KEY UPDATE',
                'callback' => [$this, 'generateOnDuplicate']
            ]
        ];
    }
    
    /**
     * Callback used by assembleRequestPart method
     * Generate the sql query part who contains columns list and their values
     * 
     * @return string
     */
    protected function generateValues(): string
    {
        $listNames   = '';
        $listValues  = '';
        
        foreach ($this->queriesParts['values'] as $colIndex => $column) {
            
            if ($colIndex > 0) {
                $listNames  .= ',';
                $listValues .= ',';
            }
            
            $listNames  .= '`'.$column->getName().'`';
            $listValues .= $column->obtainValue();
        }
        
        if ($listNames === '') {
            return '';
        }
        
        $select = $this->queriesParts['select'];
        if ($select->getQueriesParts()['table']->getName() === '') {
            return '('.$listNames.') VALUES ('.$listValues.')';
        } else {
            return '('.$listNames.')';
        }
    }
    
    /**
     * Callback used by assembleRequestPart method
     * Generate the sql query for the SELECT part
     * 
     * @return string
     */
    protected function generateSelect(): string
    {
        $select = $this->queriesParts['select'];
        if ($select->getQueriesParts()['table']->getName() === '') {
            return '';
        }
        
        return $select->assemble();
    }
    
    /**
     * Callback used by assembleRequestPart method
     * Generate the sql query for the ON DUPLICATE KEY UPDATE part
     * 
     * @return string
     */
    protected function generateOnDuplicate(): string
    {
        $listColumns = $this->queriesParts['onDuplicate'];
        $sqlPart     = '';
        
        foreach ($listColumns as $colIndex => $column) {
            if ($colIndex > 0) {
                $sqlPart .= ',';
            }
            
            $sqlPart .= '`'.$column->getName().'`='.$column->obtainValue();
        }
        
        return $sqlPart;
    }
}