Borobudur\Cqrs\ReadModel\Storage\Pdo\Parser\DefaultParser

Complexity

Total Complexity

21

Size/Duplication

Total Lines	107
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	3
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	setQuote()	0	4	1
A	comparison()	0	7	1
A	normalizeGroupValue()	0	4	1
B	transformComparison()	0	14	5
B	normalizeValue()	0	20	9
A	normalizeCollectionValue()	0	16	4

<?php
/*
 * This file is part of the Borobudur-Cqrs package.
 *
 * (c) Hexacodelabs <http://hexacodelabs.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Borobudur\Cqrs\ReadModel\Storage\Pdo\Parser;

use Borobudur\Cqrs\Collection;
use Borobudur\Cqrs\ReadModel\Storage\Pdo\PdoFinder;

/**
 * @author      Iqbal Maulana <iq.bluejack@gmail.com>
 * @created     8/18/15
 */
class DefaultParser implements ParserInterface
{
    /**
     * @var string
     */
    protected $quote;

    /**
     * {@inheritdoc}
     */
    public function setQuote($quote)
    {
        $this->quote = $quote;
    }

    /**
     * {@inheritdoc}
     */
    public function comparison($field, $comparison, $value)
    {
        return
            $this->quote . $field . $this->quote . ' ' .
            $this->transformComparison($comparison, $value) . ' ' .
            $this->normalizeValue($value);
    }

    /**
     * {@inheritdoc}
     */
    public function normalizeGroupValue($value)
    {
        return sprintf('(%s)', $this->normalizeCollectionValue($value));
    }

    /**
     * @param string $comparison
     * @param mixed  $value
     *
     * @return string
     */
    protected function transformComparison($comparison, $value)
    {
        if (null === $value) {
            switch ($comparison) {
                case "=":
                    return "IS";
                case "!=":
                case "<>":
                    return "IS NOT";
            }
        }

        return $comparison;
    }

    /**
     * Normalize value.
     *
     * @param mixed $value
     *
     * @return array|float|int|string
     */
    protected function normalizeValue($value)
    {
        if (null === $value) {
            $value = "NULL";
        } elseif (is_array($value)) {
            foreach ($value as $index => $val) {
                $value[$index] = $this->normalizeValue($val);
            }
        } elseif (is_string($value)) {
            $value = sprintf('\'%s\'', addslashes($value));
        } elseif (is_int($value)) {
            $value = (int) $value;
        } elseif (is_float($value)) {
            $value = (float) $value;
        } elseif (is_bool($value)) {
            $value = $value === true ? 'true' : 'false';
        }

        return $value;
    }

    /**
     * Normalize collection value.
     *
     * @param mixed $value
     *
     * @return array|string
     */
    protected function normalizeCollectionValue($value)
    {
        if ($value instanceof PdoFinder) {
            return (string) $value;
        }

        if ($value instanceof Collection) {
            $value = $value->toArray();
        }

        if (is_array($value)) {
            return implode(', ', $this->normalizeValue($value));
        }

        return $value;
    }
}