Maphper\Lib\Sql\WhereBuilder

Complexity

Total Complexity

21

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getResult()	0	3	3
A	addConditional()	0	2	1
A	fixDuplicateArgs()	0	15	3
A	createSql()	0	15	3
A	convertDates()	0	6	3
A	getConditional()	0	6	3
A	sqlArrayToString()	0	5	3
A	__construct()	0	10	2

<?php
namespace Maphper\Lib\Sql;

class WhereBuilder {
    private $conditionals = [];

    public function __construct() {
        $defaultConditionals = [
            'Maphper\Lib\Sql\Between',
            'Maphper\Lib\Sql\In',
            'Maphper\Lib\Sql\NullConditional',
            'Maphper\Lib\Sql\Like',
            'Maphper\Lib\Sql\GeneralOperator'
        ];

        foreach ($defaultConditionals as $conditional) $this->addConditional(new $conditional);
    }

    public function addConditional(WhereConditional $conditional) {
        $this->conditionals[] = $conditional;
    }

	public function createSql($fields, $mode = \Maphper\Maphper::FIND_EXACT | \Maphper\Maphper::FIND_AND) {
		$args = [];
		$sql = [];

        foreach ($fields as $key => $value) {
            $value = $this->convertDates($value);

            if (is_object($value)) continue;
			$result = $this->getResult($key, $value, $mode);
            $result = $this->fixDuplicateArgs($args, $result);
            $sql = array_merge($sql, (array)$result['sql']);
            $args = array_merge($args, $result['args']);
        }

		return ['args' => $args, 'sql' => $this->sqlArrayToString($sql, $mode)];
	}

    // Returns result with duplicate issues removed
    private function fixDuplicateArgs($origArgs, $result) {
        $duplicates = array_intersect_key($result['args'], $origArgs); // Holds all keys in results already in the args
        if (count($duplicates) === 0) return $result;

        foreach ($duplicates as $argKey => $argVal) {
            $valHash = substr(md5($argVal), 0, 5);
            $newKey = $argKey . $valHash;

            // Replace occurences of duplicate key with key + hash as arg
            $result['sql'] = str_replace(':' . $argKey, ':' . $newKey, $result['sql']);
            unset($result['args'][$argKey]);
            $result['args'][$newKey] = $argVal;
        }

        return $result;
    }

    /*
     * Either get sql from a conditional or call createSql again because the mode needs to be changed
     */
    private function getResult($key, $value, $mode) {
        if (is_numeric($key) && is_array($value)) return $this->createSql($value, $key);
        return $this->getConditional($key, $value, $mode);
    }

    private function sqlArrayToString($sql, $mode) {
        if (\Maphper\Maphper::FIND_OR & $mode) $query = implode(' OR  ', $sql);
		else $query = implode(' AND ', $sql);
		if (!empty($query)) $query = '(' . $query . ')';
        return $query;
    }

    private function getConditional($key, $value, $mode) {
        foreach ($this->conditionals as $conditional) {
            if ($conditional->matches($key, $value, $mode))
                return $conditional->getSql($key, $value, $mode);
        }
        throw new \Exception("Invalid WHERE query");
    }

    private function convertDates($value) {
        if ($value instanceof \DateTimeInterface) {
            if ($value->format('H:i:s')  == '00:00:00') $value = $value->format('Y-m-d');
            else $value = $value->format('Y-m-d H:i:s');
        }
        return $value;
    }
}