gin0115 / pixie-wpdb

src/QueryBuilder/WPDBAdapter.php

Indentation +711 added lines, -711 removed lines

@@ -17,715 +17,715 @@
 
 class WPDBAdapter
 {
-    /**
-     * @var string
-     */
-    protected $sanitizer = '';
-
-    /**
-     * @var \Pixie\Connection
-     */
-    protected $connection;
-
-    /**
-     * @var \Viocon\Container
-     */
-    protected $container;
-
-    public function __construct(Connection $connection)
-    {
-        $this->connection = $connection;
-        $this->container  = $this->connection->getContainer();
-    }
-
-    /**
-     * Build select query string and bindings
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     *
-     * @throws Exception
-     *
-     * @return array{sql:string,bindings:mixed[]}
-     */
-    public function select(array $statements): array
-    {
-        if (!array_key_exists('tables', $statements)) {
-            throw new Exception('No table specified.', 3);
-        } elseif (!array_key_exists('selects', $statements)) {
-            $statements['selects'][] = '*';
-        }
-
-        // From
-        $tables = $this->arrayStr($statements['tables'], ', ');
-        // Select
-        $selects = $this->arrayStr($statements['selects'], ', ');
-
-        // Wheres
-        list($whereCriteria, $whereBindings) = $this->buildCriteriaWithType($statements, 'wheres', 'WHERE');
-
-        // Group bys
-        $groupBys = '';
-        if (isset($statements['groupBys']) && $groupBys = $this->arrayStr($statements['groupBys'], ', ')) {
-            $groupBys = 'GROUP BY ' . $groupBys;
-        }
-
-        // Order bys
-        $orderBys = '';
-        if (isset($statements['orderBys']) && is_array($statements['orderBys'])) {
-            foreach ($statements['orderBys'] as $orderBy) {
-                $field = $this->wrapSanitizer($orderBy['field']);
-                if ($field instanceof Closure) {
-                    continue;
-                }
-                $orderBys .= $field . ' ' . $orderBy['type'] . ', ';
-            }
-
-            if ($orderBys = trim($orderBys, ', ')) {
-                $orderBys = 'ORDER BY ' . $orderBys;
-            }
-        }
-
-        // Limit and offset
-        $limit  = isset($statements['limit']) ? 'LIMIT ' . (int) $statements['limit'] : '';
-        $offset = isset($statements['offset']) ? 'OFFSET ' . (int) $statements['offset'] : '';
-
-        // Having
-        list($havingCriteria, $havingBindings) = $this->buildCriteriaWithType($statements, 'havings', 'HAVING');
-
-        // Joins
-        $joinString = $this->buildJoin($statements);
-
-        /** @var string[] */
-        $sqlArray = [
-            'SELECT' . (isset($statements['distinct']) ? ' DISTINCT' : ''),
-            $selects,
-            'FROM',
-            $tables,
-            $joinString,
-            $whereCriteria,
-            $groupBys,
-            $havingCriteria,
-            $orderBys,
-            $limit,
-            $offset,
-        ];
-
-        $sql = $this->concatenateQuery($sqlArray);
-
-        $bindings = array_merge(
-            $whereBindings,
-            $havingBindings
-        );
-
-        return compact('sql', 'bindings');
-    }
-
-    /**
-     * Build just criteria part of the query
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     * @param bool $bindValues
-     *
-     * @return array{sql:string[]|string, bindings:array<mixed>}
-     */
-    public function criteriaOnly(array $statements, bool $bindValues = true): array
-    {
-        $sql = $bindings = [];
-        if (!isset($statements['criteria'])) {
-            return compact('sql', 'bindings');
-        }
-
-        list($sql, $bindings) = $this->buildCriteria($statements['criteria'], $bindValues);
-
-        return compact('sql', 'bindings');
-    }
-
-    /**
-     * Build a generic insert/ignore/replace query
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     * @param array<string, mixed> $data
-     * @param string $type
-     *
-     * @return array{sql:string, bindings:mixed[]}
-     *
-     * @throws Exception
-     */
-    private function doInsert(array $statements, array $data, string $type): array
-    {
-        if (!isset($statements['tables'])) {
-            throw new Exception('No table specified', 3);
-        }
-
-        $table = end($statements['tables']);
-
-        $bindings = $keys = $values = [];
-
-        foreach ($data as $key => $value) {
-            $keys[] = $key;
-
-            // Handle value as bindings
-            $isBindings = $value instanceof Binding;
-            // If this is a raw binding, extract the Raw and replace value.
-            if ($isBindings && $value->isRaw()) {
-                $value = $value->getValue();
-            }
-
-            if ($value instanceof Raw) {
-                $values[] = $this->parseRaw($value);
-            } elseif ($isBindings) {
-                $values[]   =  $value->getType();
-                $bindings[] = $value->getValue();
-            } else {
-                $values[]   =  $this->inferType($value);
-                $bindings[] = $value;
-            }
-        }
-
-        $sqlArray = [
-        $type . ' INTO',
-        $this->wrapSanitizer($table),
-        '(' . $this->arrayStr($keys, ',') . ')',
-        'VALUES',
-        '(' . $this->arrayStr($values, ',') . ')',
-        ];
-
-        if (isset($statements['onduplicate'])) {
-            if (count($statements['onduplicate']) < 1) {
-                throw new Exception('No data given.', 4);
-            }
-            list($updateStatement, $updateBindings) = $this->getUpdateStatement($statements['onduplicate']);
-            $sqlArray[]                             = 'ON DUPLICATE KEY UPDATE ' . $updateStatement;
-            $bindings                               = array_merge($bindings, $updateBindings);
-        }
-
-        $sql = $this->concatenateQuery($this->stringifyValues($sqlArray));
-
-        return compact('sql', 'bindings');
-    }
-
-    /**
-     * Attempts to stringify an array of values.
-     *
-     * @param array<string|int, string|Closure> $values
-     *
-     * @return string[]
-     */
-    protected function stringifyValues(array $values): array
-    {
-        return array_filter(array_map([$this, 'stringifyValue'], $values));
-    }
-
-    /**
-     * Attempts to stringify a single of values.
-     *
-     * @param string|Closure|Raw $value
-     *
-     * @return string|null
-     */
-    protected function stringifyValue($value): ?string
-    {
-        if ($value instanceof Closure) {
-            $value = $value();
-
-            return is_string($value) ? $value : null;
-        }
-
-        if ($value instanceof Raw) {
-            return $this->parseRaw($value);
-        }
-
-        return $value;
-    }
-
-    /**
-     * Build Insert query
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     * @param array<string, mixed> $data $data
-     *
-     * @return array{sql:string, bindings:mixed[]}
-     *
-     * @throws Exception
-     */
-    public function insert($statements, array $data)
-    {
-        return $this->doInsert($statements, $data, 'INSERT');
-    }
-
-    /**
-     * Build Insert Ignore query
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     * @param array<string, mixed> $data $data
-     *
-     * @return array{sql:string, bindings:mixed[]}
-     *
-     * @throws Exception
-     */
-    public function insertIgnore($statements, array $data)
-    {
-        return $this->doInsert($statements, $data, 'INSERT IGNORE');
-    }
-
-    /**
-     * Build Insert Ignore query
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     * @param array<string, mixed> $data $data
-     *
-     * @return array{sql:string, bindings:mixed[]}
-     *
-     * @throws Exception
-     */
-    public function replace($statements, array $data)
-    {
-        return $this->doInsert($statements, $data, 'REPLACE');
-    }
-
-    /**
-     * Build fields assignment part of SET ... or ON DUBLICATE KEY UPDATE ... statements
-     *
-     * @param array<string, mixed> $data
-     *
-     * @return array{0:string,1:mixed[]}
-     */
-    private function getUpdateStatement(array $data): array
-    {
-        $bindings  = [];
-        $statement = '';
-
-        foreach ($data as $key => $value) {
-            $isBindings = $value instanceof Binding;
-            // If this is a raw binding, extract the Raw and replace value.
-            if ($isBindings && $value->isRaw()) {
-                $value = $value->getValue();
-            }
-
-            if ($value instanceof Raw) {
-                $statement .= $this->stringifyValue($this->wrapSanitizer($key)) . '=' . $value . ',';
-            } elseif ($isBindings) {
-                $statement .= $this->stringifyValue($this->wrapSanitizer($key)) . sprintf('=%s,', $value->getType());
-                $bindings[] = $value->getValue();
-            } else {
-                $statement .= $this->stringifyValue($this->wrapSanitizer($key)) . sprintf('=%s,', $this->inferType($value));
-                $bindings[] = $value;
-            }
-        }
-
-        $statement = trim($statement, ',');
-
-        return [$statement, $bindings];
-    }
-
-    /**
-     * Build update query
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     * @param array<string, mixed> $data
-     *
-     * @return array{sql:string, bindings:mixed[]}
-     *
-     * @throws Exception
-     */
-    public function update($statements, array $data)
-    {
-        if (!isset($statements['tables'])) {
-            throw new Exception('No table specified', 3);
-        } elseif (count($data) < 1) {
-            throw new Exception('No data given.', 4);
-        }
-
-        $table = end($statements['tables']);
-
-        // Update statement
-        list($updateStatement, $bindings) = $this->getUpdateStatement($data);
-
-        // Wheres
-        list($whereCriteria, $whereBindings) = $this->buildCriteriaWithType($statements, 'wheres', 'WHERE');
-
-        // Limit
-        $limit = isset($statements['limit']) ? 'LIMIT ' . $statements['limit'] : '';
-
-        $sqlArray = [
-            'UPDATE',
-            $this->wrapSanitizer($table),
-            'SET ' . $updateStatement,
-            $whereCriteria,
-            $limit,
-        ];
-
-        $sql = $this->concatenateQuery($this->stringifyValues($sqlArray));
-
-        $bindings = array_merge($bindings, $whereBindings);
-
-        return compact('sql', 'bindings');
-    }
-
-    /**
-     * Build delete query
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     *
-     * @return array{sql:string, bindings:mixed[]}
-     *
-     * @throws Exception
-     */
-    public function delete($statements)
-    {
-        if (!isset($statements['tables'])) {
-            throw new Exception('No table specified', 3);
-        }
-
-        $table = end($statements['tables']);
-        // Ensure table name is a string
-        $table = $this->stringifyValue($this->wrapSanitizer($table));
-        if (null === $table) {
-            throw new Exception('Table must be a valid string.', 5);
-        }
-
-        // Wheres
-        list($whereCriteria, $whereBindings) = $this->buildCriteriaWithType($statements, 'wheres', 'WHERE');
-
-        // Limit
-        $limit = isset($statements['limit']) ? 'LIMIT ' . $statements['limit'] : '';
-
-        $sqlArray = ['DELETE FROM', $table, $whereCriteria];
-        $sql      = $this->concatenateQuery($sqlArray);
-        $bindings = $whereBindings;
-
-        return compact('sql', 'bindings');
-    }
-
-    /**
-     * Array concatenating method, like implode.
-     * But it does wrap sanitizer and trims last glue
-     *
-     * @param array<string|int, string> $pieces
-     * @param string $glue
-     *
-     * @return string
-     */
-    protected function arrayStr(array $pieces, string $glue): string
-    {
-        $str = '';
-        foreach ($pieces as $key => $piece) {
-            if (!is_int($key)) {
-                $piece = $key . ' AS ' . $piece;
-            }
-
-            $str .= $piece . $glue;
-        }
-
-        return trim($str, $glue);
-    }
-
-    /**
-     * Join different part of queries with a space.
-     *
-     * @param array<string|int, string> $pieces
-     *
-     * @return string
-     */
-    protected function concatenateQuery(array $pieces): string
-    {
-        $str = '';
-        foreach ($pieces as $piece) {
-            $str = trim($str) . ' ' . trim($piece);
-        }
-
-        return trim($str);
-    }
-
-    /**
-     * Gets the type of a value, either from a binding or infered
-     *
-     * @param mixed $value
-     * @return string
-     */
-    public function getType($value): string
-    {
-        return $value instanceof Binding && $value->getType() !== null
-            ? $value->getType() : $this->inferType($value) ;
-    }
-
-    /**
-     * Get the value from a possible Bindings object.
-     *
-     * @param mixed $value
-     * @return mixed
-     */
-    public function getValue($value)
-    {
-        return $value instanceof Binding ? $value->getValue() : $value;
-    }
-
-    /**
-     * Attempts to parse a raw query, if bindings are defined then they will be bound first.
-     *
-     * @param Raw $raw
-     * @requires string
-     */
-    public function parseRaw(Raw $raw): string
-    {
-        $bindings = $raw->getBindings();
-        return 0 === count($bindings)
-            ? (string) $raw
-            : $this->interpolateQuery($raw->getValue(), $bindings);
-    }
-
-    /**
-     * Interpolates a query
-     *
-     * @param string $query
-     * @param array<mixed> $bindings
-     * @return string
-     */
-    public function interpolateQuery(string $query, array $bindings = []): string
-    {
-        if (0 === count($bindings)) {
-            return $query;
-        }
-
-
-        $bindings = array_map([$this, 'getValue'], $bindings);
-        $query = $this->connection->getDbInstance()->prepare($query, $bindings) ;
-        return is_string($query) ? $query : '';
-    }
-
-    /**
-     * Build generic criteria string and bindings from statements, like "a = b and c = ?"
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     * @param bool $bindValues
-     *
-     * @return array{0:string,1:string[]}
-     */
-    protected function buildCriteria(array $statements, bool $bindValues = true): array
-    {
-        $criteria = '';
-        $bindings = [];
-        foreach ($statements as $statement) {
-            $key   = $statement['key'];
-            $value = $statement['value'];
-
-            // If the value is a Raw Binding, cast to raw
-            if ($value instanceof Binding && Binding::RAW === $value->getType()) {
-                /** @var Raw */
-                $value = $value->getValue();
-            }
-
-            if (is_null($value) && $key instanceof Closure) {
-                // We have a closure, a nested criteria
-
-                // Build a new NestedCriteria class, keep it by reference so any changes made
-                // in the closure should reflect here
-                $nestedCriteria = $this->container->build(NestedCriteria::class, [$this->connection]);
-
-                $nestedCriteria = &$nestedCriteria;
-                // Call the closure with our new nestedCriteria object
-                $key($nestedCriteria);
-                // Get the criteria only query from the nestedCriteria object
-                $queryObject = $nestedCriteria->getQuery('criteriaOnly', true);
-                // Merge the bindings we get from nestedCriteria object
-                $bindings = array_merge($bindings, $queryObject->getBindings());
-                // Append the sql we get from the nestedCriteria object
-                $criteria .= $statement['joiner'] . ' (' . $queryObject->getSql() . ') ';
-            } elseif (is_array($value)) {
-                // where_in or between like query
-                $criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'];
-
-                switch ($statement['operator']) {
-                    case 'BETWEEN':
-                        $bindings = array_merge($bindings, $statement['value']);
-                        $criteria .= sprintf(
-                            ' %s AND %s ',
-                            $this->getType($value[0]),
-                            $this->getType($value[1])
-                        );
-
-                        // Maybe cast the values bindings.
-                        $value[0] = $this->getValue($value[0]);
-                        $value[1] = $this->getValue($value[1]);
-
-                        // Parse any raws.
-                        $value = array_map(function ($value) {
-                            return $value instanceof Raw
-                                ? $this->parseRaw($value)
-                                : $value;
-                        }, $value);
-                        break;
-                    default:
-                        $valuePlaceholder = '';
-                        foreach ($statement['value'] as $subValue) {
-                            // Get its value.
-                            if ($this->getValue($subValue) instanceof Raw) {
-                                /** @var Raw $subValue */
-                                $subValue = $this->getValue($subValue);
-                                $valuePlaceholder .= sprintf('%s, ', $this->parseRaw($subValue));
-                                continue;
-                            }
-
-
-                            // Add in format placeholders.
-                            $valuePlaceholder .= sprintf('%s, ', $this->getType($subValue)); // glynn
-                            $bindings[] = $this->getValue($subValue);
-                        }
-
-                        $valuePlaceholder = trim($valuePlaceholder, ', ');
-                        $criteria .= ' (' . $valuePlaceholder . ') ';
-                        break;
-                }
-            } elseif ($value instanceof Raw) {
-                $value = $this->parseRaw($value);
-                $criteria .= "{$statement['joiner']} {$key} {$statement['operator']} $value ";
-            } else {
-                // Usual where like criteria
-                if (!$bindValues) {
-                    // Specially for joins
-                    // We are not binding values, lets sanitize then
-                    $value = $this->stringifyValue($this->wrapSanitizer($value)) ?? '';
-                    $criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'] . ' ' . $value . ' ';
-                } elseif ($statement['key'] instanceof Raw) {
-                    $criteria .= $statement['joiner'] . ' ' . $key . ' ';
-                    $bindings = array_merge($bindings, $statement['key']->getBindings());
-                } else {
-                    // For wheres
-                    $bindings[] = $this->getValue($value);
-
-                    $criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'] . ' '
-                    . $this->getType($value) . ' ';
-                }
-            }
-        }
-
-        // Clear all white spaces, and, or from beginning and white spaces from ending
-        $criteria = preg_replace('/^(\s?AND ?|\s?OR ?)|\s$/i', '', $criteria);
-
-        return [$criteria ?? '', $bindings];
-    }
-
-    /**
-     * Asserts the types place holder based on its value
-     *
-     * @param mixed $value
-     *
-     * @return string
-     */
-    public function inferType($value): string
-    {
-        switch (true) {
-            case is_string($value):
-                return '%s';
-            case \is_int($value):
-            case is_bool($value):
-                return '%d';
-            case is_float($value):
-                return '%f';
-            default:
-                return '';
-        }
-    }
-
-    /**
-     * Wrap values with adapter's sanitizer like, '`'
-     *
-     * @param string|Raw|Closure $value
-     *
-     * @return string|Closure
-     */
-    public function wrapSanitizer($value)
-    {
-        // Its a raw query, just cast as string, object has __toString()
-        if ($value instanceof Raw) {
-            return $this->parseRaw($value);
-        } elseif ($value instanceof Closure) {
-            return $value;
-        }
-
-        // Separate our table and fields which are joined with a ".",
-        // like my_table.id
-        $valueArr = explode('.', $value, 2);
-
-        foreach ($valueArr as $key => $subValue) {
-            // Don't wrap if we have *, which is not a usual field
-            $valueArr[$key] = '*' == trim($subValue) ? $subValue : $this->sanitizer . $subValue . $this->sanitizer;
-        }
-
-        // Join these back with "." and return
-        return implode('.', $valueArr);
-    }
-
-    /**
-     * Build criteria string and binding with various types added, like WHERE and Having
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     * @param string $key
-     * @param string $type
-     * @param bool $bindValues
-     *
-     * @return array{0:string, 1:string[]}
-     */
-    protected function buildCriteriaWithType(array $statements, string $key, string $type, bool $bindValues = true)
-    {
-        $criteria = '';
-        $bindings = [];
-
-        if (isset($statements[$key])) {
-            // Get the generic/adapter agnostic criteria string from parent
-            list($criteria, $bindings) = $this->buildCriteria($statements[$key], $bindValues);
-
-            if ($criteria) {
-                $criteria = $type . ' ' . $criteria;
-            }
-        }
-
-        // Remove any multiple whitespace.
-        $criteria = (string) preg_replace('!\s+!', ' ', $criteria);
-
-        return [$criteria, $bindings];
-    }
-
-    /**
-     * Build join string
-     *
-     * @param array<string|Closure, mixed|mixed[]> $statements
-     *
-     * @return string
-     */
-    protected function buildJoin(array $statements): string
-    {
-        $sql = '';
-
-        if (!array_key_exists('joins', $statements) || !is_array($statements['joins'])) {
-            return $sql;
-        }
-
-        foreach ($statements['joins'] as $joinArr) {
-            if (is_array($joinArr['table'])) {
-                $mainTable  = $this->stringifyValue($this->wrapSanitizer($joinArr['table'][0]));
-                $aliasTable = $this->stringifyValue($this->wrapSanitizer($joinArr['table'][1]));
-                $table      = $mainTable . ' AS ' . $aliasTable;
-            } else {
-                $table = $joinArr['table'] instanceof Raw
-                    ? $this->parseRaw($joinArr['table'])
-                    : $this->wrapSanitizer($joinArr['table']);
-            }
-            $joinBuilder = $joinArr['joinBuilder'];
-
-            /** @var string[] */
-            $sqlArr = [
-                $sql,
-                strtoupper($joinArr['type']),
-                'JOIN',
-                $table,
-                'ON',
-                $joinBuilder->getQuery('criteriaOnly', false)->getSql(),
-            ];
-
-            $sql = $this->concatenateQuery($sqlArr);
-        }
-
-        return $sql;
-    }
+	/**
+	 * @var string
+	 */
+	protected $sanitizer = '';
+
+	/**
+	 * @var \Pixie\Connection
+	 */
+	protected $connection;
+
+	/**
+	 * @var \Viocon\Container
+	 */
+	protected $container;
+
+	public function __construct(Connection $connection)
+	{
+		$this->connection = $connection;
+		$this->container  = $this->connection->getContainer();
+	}
+
+	/**
+	 * Build select query string and bindings
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 *
+	 * @throws Exception
+	 *
+	 * @return array{sql:string,bindings:mixed[]}
+	 */
+	public function select(array $statements): array
+	{
+		if (!array_key_exists('tables', $statements)) {
+			throw new Exception('No table specified.', 3);
+		} elseif (!array_key_exists('selects', $statements)) {
+			$statements['selects'][] = '*';
+		}
+
+		// From
+		$tables = $this->arrayStr($statements['tables'], ', ');
+		// Select
+		$selects = $this->arrayStr($statements['selects'], ', ');
+
+		// Wheres
+		list($whereCriteria, $whereBindings) = $this->buildCriteriaWithType($statements, 'wheres', 'WHERE');
+
+		// Group bys
+		$groupBys = '';
+		if (isset($statements['groupBys']) && $groupBys = $this->arrayStr($statements['groupBys'], ', ')) {
+			$groupBys = 'GROUP BY ' . $groupBys;
+		}
+
+		// Order bys
+		$orderBys = '';
+		if (isset($statements['orderBys']) && is_array($statements['orderBys'])) {
+			foreach ($statements['orderBys'] as $orderBy) {
+				$field = $this->wrapSanitizer($orderBy['field']);
+				if ($field instanceof Closure) {
+					continue;
+				}
+				$orderBys .= $field . ' ' . $orderBy['type'] . ', ';
+			}
+
+			if ($orderBys = trim($orderBys, ', ')) {
+				$orderBys = 'ORDER BY ' . $orderBys;
+			}
+		}
+
+		// Limit and offset
+		$limit  = isset($statements['limit']) ? 'LIMIT ' . (int) $statements['limit'] : '';
+		$offset = isset($statements['offset']) ? 'OFFSET ' . (int) $statements['offset'] : '';
+
+		// Having
+		list($havingCriteria, $havingBindings) = $this->buildCriteriaWithType($statements, 'havings', 'HAVING');
+
+		// Joins
+		$joinString = $this->buildJoin($statements);
+
+		/** @var string[] */
+		$sqlArray = [
+			'SELECT' . (isset($statements['distinct']) ? ' DISTINCT' : ''),
+			$selects,
+			'FROM',
+			$tables,
+			$joinString,
+			$whereCriteria,
+			$groupBys,
+			$havingCriteria,
+			$orderBys,
+			$limit,
+			$offset,
+		];
+
+		$sql = $this->concatenateQuery($sqlArray);
+
+		$bindings = array_merge(
+			$whereBindings,
+			$havingBindings
+		);
+
+		return compact('sql', 'bindings');
+	}
+
+	/**
+	 * Build just criteria part of the query
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 * @param bool $bindValues
+	 *
+	 * @return array{sql:string[]|string, bindings:array<mixed>}
+	 */
+	public function criteriaOnly(array $statements, bool $bindValues = true): array
+	{
+		$sql = $bindings = [];
+		if (!isset($statements['criteria'])) {
+			return compact('sql', 'bindings');
+		}
+
+		list($sql, $bindings) = $this->buildCriteria($statements['criteria'], $bindValues);
+
+		return compact('sql', 'bindings');
+	}
+
+	/**
+	 * Build a generic insert/ignore/replace query
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 * @param array<string, mixed> $data
+	 * @param string $type
+	 *
+	 * @return array{sql:string, bindings:mixed[]}
+	 *
+	 * @throws Exception
+	 */
+	private function doInsert(array $statements, array $data, string $type): array
+	{
+		if (!isset($statements['tables'])) {
+			throw new Exception('No table specified', 3);
+		}
+
+		$table = end($statements['tables']);
+
+		$bindings = $keys = $values = [];
+
+		foreach ($data as $key => $value) {
+			$keys[] = $key;
+
+			// Handle value as bindings
+			$isBindings = $value instanceof Binding;
+			// If this is a raw binding, extract the Raw and replace value.
+			if ($isBindings && $value->isRaw()) {
+				$value = $value->getValue();
+			}
+
+			if ($value instanceof Raw) {
+				$values[] = $this->parseRaw($value);
+			} elseif ($isBindings) {
+				$values[]   =  $value->getType();
+				$bindings[] = $value->getValue();
+			} else {
+				$values[]   =  $this->inferType($value);
+				$bindings[] = $value;
+			}
+		}
+
+		$sqlArray = [
+		$type . ' INTO',
+		$this->wrapSanitizer($table),
+		'(' . $this->arrayStr($keys, ',') . ')',
+		'VALUES',
+		'(' . $this->arrayStr($values, ',') . ')',
+		];
+
+		if (isset($statements['onduplicate'])) {
+			if (count($statements['onduplicate']) < 1) {
+				throw new Exception('No data given.', 4);
+			}
+			list($updateStatement, $updateBindings) = $this->getUpdateStatement($statements['onduplicate']);
+			$sqlArray[]                             = 'ON DUPLICATE KEY UPDATE ' . $updateStatement;
+			$bindings                               = array_merge($bindings, $updateBindings);
+		}
+
+		$sql = $this->concatenateQuery($this->stringifyValues($sqlArray));
+
+		return compact('sql', 'bindings');
+	}
+
+	/**
+	 * Attempts to stringify an array of values.
+	 *
+	 * @param array<string|int, string|Closure> $values
+	 *
+	 * @return string[]
+	 */
+	protected function stringifyValues(array $values): array
+	{
+		return array_filter(array_map([$this, 'stringifyValue'], $values));
+	}
+
+	/**
+	 * Attempts to stringify a single of values.
+	 *
+	 * @param string|Closure|Raw $value
+	 *
+	 * @return string|null
+	 */
+	protected function stringifyValue($value): ?string
+	{
+		if ($value instanceof Closure) {
+			$value = $value();
+
+			return is_string($value) ? $value : null;
+		}
+
+		if ($value instanceof Raw) {
+			return $this->parseRaw($value);
+		}
+
+		return $value;
+	}
+
+	/**
+	 * Build Insert query
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 * @param array<string, mixed> $data $data
+	 *
+	 * @return array{sql:string, bindings:mixed[]}
+	 *
+	 * @throws Exception
+	 */
+	public function insert($statements, array $data)
+	{
+		return $this->doInsert($statements, $data, 'INSERT');
+	}
+
+	/**
+	 * Build Insert Ignore query
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 * @param array<string, mixed> $data $data
+	 *
+	 * @return array{sql:string, bindings:mixed[]}
+	 *
+	 * @throws Exception
+	 */
+	public function insertIgnore($statements, array $data)
+	{
+		return $this->doInsert($statements, $data, 'INSERT IGNORE');
+	}
+
+	/**
+	 * Build Insert Ignore query
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 * @param array<string, mixed> $data $data
+	 *
+	 * @return array{sql:string, bindings:mixed[]}
+	 *
+	 * @throws Exception
+	 */
+	public function replace($statements, array $data)
+	{
+		return $this->doInsert($statements, $data, 'REPLACE');
+	}
+
+	/**
+	 * Build fields assignment part of SET ... or ON DUBLICATE KEY UPDATE ... statements
+	 *
+	 * @param array<string, mixed> $data
+	 *
+	 * @return array{0:string,1:mixed[]}
+	 */
+	private function getUpdateStatement(array $data): array
+	{
+		$bindings  = [];
+		$statement = '';
+
+		foreach ($data as $key => $value) {
+			$isBindings = $value instanceof Binding;
+			// If this is a raw binding, extract the Raw and replace value.
+			if ($isBindings && $value->isRaw()) {
+				$value = $value->getValue();
+			}
+
+			if ($value instanceof Raw) {
+				$statement .= $this->stringifyValue($this->wrapSanitizer($key)) . '=' . $value . ',';
+			} elseif ($isBindings) {
+				$statement .= $this->stringifyValue($this->wrapSanitizer($key)) . sprintf('=%s,', $value->getType());
+				$bindings[] = $value->getValue();
+			} else {
+				$statement .= $this->stringifyValue($this->wrapSanitizer($key)) . sprintf('=%s,', $this->inferType($value));
+				$bindings[] = $value;
+			}
+		}
+
+		$statement = trim($statement, ',');
+
+		return [$statement, $bindings];
+	}
+
+	/**
+	 * Build update query
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 * @param array<string, mixed> $data
+	 *
+	 * @return array{sql:string, bindings:mixed[]}
+	 *
+	 * @throws Exception
+	 */
+	public function update($statements, array $data)
+	{
+		if (!isset($statements['tables'])) {
+			throw new Exception('No table specified', 3);
+		} elseif (count($data) < 1) {
+			throw new Exception('No data given.', 4);
+		}
+
+		$table = end($statements['tables']);
+
+		// Update statement
+		list($updateStatement, $bindings) = $this->getUpdateStatement($data);
+
+		// Wheres
+		list($whereCriteria, $whereBindings) = $this->buildCriteriaWithType($statements, 'wheres', 'WHERE');
+
+		// Limit
+		$limit = isset($statements['limit']) ? 'LIMIT ' . $statements['limit'] : '';
+
+		$sqlArray = [
+			'UPDATE',
+			$this->wrapSanitizer($table),
+			'SET ' . $updateStatement,
+			$whereCriteria,
+			$limit,
+		];
+
+		$sql = $this->concatenateQuery($this->stringifyValues($sqlArray));
+
+		$bindings = array_merge($bindings, $whereBindings);
+
+		return compact('sql', 'bindings');
+	}
+
+	/**
+	 * Build delete query
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 *
+	 * @return array{sql:string, bindings:mixed[]}
+	 *
+	 * @throws Exception
+	 */
+	public function delete($statements)
+	{
+		if (!isset($statements['tables'])) {
+			throw new Exception('No table specified', 3);
+		}
+
+		$table = end($statements['tables']);
+		// Ensure table name is a string
+		$table = $this->stringifyValue($this->wrapSanitizer($table));
+		if (null === $table) {
+			throw new Exception('Table must be a valid string.', 5);
+		}
+
+		// Wheres
+		list($whereCriteria, $whereBindings) = $this->buildCriteriaWithType($statements, 'wheres', 'WHERE');
+
+		// Limit
+		$limit = isset($statements['limit']) ? 'LIMIT ' . $statements['limit'] : '';
+
+		$sqlArray = ['DELETE FROM', $table, $whereCriteria];
+		$sql      = $this->concatenateQuery($sqlArray);
+		$bindings = $whereBindings;
+
+		return compact('sql', 'bindings');
+	}
+
+	/**
+	 * Array concatenating method, like implode.
+	 * But it does wrap sanitizer and trims last glue
+	 *
+	 * @param array<string|int, string> $pieces
+	 * @param string $glue
+	 *
+	 * @return string
+	 */
+	protected function arrayStr(array $pieces, string $glue): string
+	{
+		$str = '';
+		foreach ($pieces as $key => $piece) {
+			if (!is_int($key)) {
+				$piece = $key . ' AS ' . $piece;
+			}
+
+			$str .= $piece . $glue;
+		}
+
+		return trim($str, $glue);
+	}
+
+	/**
+	 * Join different part of queries with a space.
+	 *
+	 * @param array<string|int, string> $pieces
+	 *
+	 * @return string
+	 */
+	protected function concatenateQuery(array $pieces): string
+	{
+		$str = '';
+		foreach ($pieces as $piece) {
+			$str = trim($str) . ' ' . trim($piece);
+		}
+
+		return trim($str);
+	}
+
+	/**
+	 * Gets the type of a value, either from a binding or infered
+	 *
+	 * @param mixed $value
+	 * @return string
+	 */
+	public function getType($value): string
+	{
+		return $value instanceof Binding && $value->getType() !== null
+			? $value->getType() : $this->inferType($value) ;
+	}
+
+	/**
+	 * Get the value from a possible Bindings object.
+	 *
+	 * @param mixed $value
+	 * @return mixed
+	 */
+	public function getValue($value)
+	{
+		return $value instanceof Binding ? $value->getValue() : $value;
+	}
+
+	/**
+	 * Attempts to parse a raw query, if bindings are defined then they will be bound first.
+	 *
+	 * @param Raw $raw
+	 * @requires string
+	 */
+	public function parseRaw(Raw $raw): string
+	{
+		$bindings = $raw->getBindings();
+		return 0 === count($bindings)
+			? (string) $raw
+			: $this->interpolateQuery($raw->getValue(), $bindings);
+	}
+
+	/**
+	 * Interpolates a query
+	 *
+	 * @param string $query
+	 * @param array<mixed> $bindings
+	 * @return string
+	 */
+	public function interpolateQuery(string $query, array $bindings = []): string
+	{
+		if (0 === count($bindings)) {
+			return $query;
+		}
+
+
+		$bindings = array_map([$this, 'getValue'], $bindings);
+		$query = $this->connection->getDbInstance()->prepare($query, $bindings) ;
+		return is_string($query) ? $query : '';
+	}
+
+	/**
+	 * Build generic criteria string and bindings from statements, like "a = b and c = ?"
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 * @param bool $bindValues
+	 *
+	 * @return array{0:string,1:string[]}
+	 */
+	protected function buildCriteria(array $statements, bool $bindValues = true): array
+	{
+		$criteria = '';
+		$bindings = [];
+		foreach ($statements as $statement) {
+			$key   = $statement['key'];
+			$value = $statement['value'];
+
+			// If the value is a Raw Binding, cast to raw
+			if ($value instanceof Binding && Binding::RAW === $value->getType()) {
+				/** @var Raw */
+				$value = $value->getValue();
+			}
+
+			if (is_null($value) && $key instanceof Closure) {
+				// We have a closure, a nested criteria
+
+				// Build a new NestedCriteria class, keep it by reference so any changes made
+				// in the closure should reflect here
+				$nestedCriteria = $this->container->build(NestedCriteria::class, [$this->connection]);
+
+				$nestedCriteria = &$nestedCriteria;
+				// Call the closure with our new nestedCriteria object
+				$key($nestedCriteria);
+				// Get the criteria only query from the nestedCriteria object
+				$queryObject = $nestedCriteria->getQuery('criteriaOnly', true);
+				// Merge the bindings we get from nestedCriteria object
+				$bindings = array_merge($bindings, $queryObject->getBindings());
+				// Append the sql we get from the nestedCriteria object
+				$criteria .= $statement['joiner'] . ' (' . $queryObject->getSql() . ') ';
+			} elseif (is_array($value)) {
+				// where_in or between like query
+				$criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'];
+
+				switch ($statement['operator']) {
+					case 'BETWEEN':
+						$bindings = array_merge($bindings, $statement['value']);
+						$criteria .= sprintf(
+							' %s AND %s ',
+							$this->getType($value[0]),
+							$this->getType($value[1])
+						);
+
+						// Maybe cast the values bindings.
+						$value[0] = $this->getValue($value[0]);
+						$value[1] = $this->getValue($value[1]);
+
+						// Parse any raws.
+						$value = array_map(function ($value) {
+							return $value instanceof Raw
+								? $this->parseRaw($value)
+								: $value;
+						}, $value);
+						break;
+					default:
+						$valuePlaceholder = '';
+						foreach ($statement['value'] as $subValue) {
+							// Get its value.
+							if ($this->getValue($subValue) instanceof Raw) {
+								/** @var Raw $subValue */
+								$subValue = $this->getValue($subValue);
+								$valuePlaceholder .= sprintf('%s, ', $this->parseRaw($subValue));
+								continue;
+							}
+
+
+							// Add in format placeholders.
+							$valuePlaceholder .= sprintf('%s, ', $this->getType($subValue)); // glynn
+							$bindings[] = $this->getValue($subValue);
+						}
+
+						$valuePlaceholder = trim($valuePlaceholder, ', ');
+						$criteria .= ' (' . $valuePlaceholder . ') ';
+						break;
+				}
+			} elseif ($value instanceof Raw) {
+				$value = $this->parseRaw($value);
+				$criteria .= "{$statement['joiner']} {$key} {$statement['operator']} $value ";
+			} else {
+				// Usual where like criteria
+				if (!$bindValues) {
+					// Specially for joins
+					// We are not binding values, lets sanitize then
+					$value = $this->stringifyValue($this->wrapSanitizer($value)) ?? '';
+					$criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'] . ' ' . $value . ' ';
+				} elseif ($statement['key'] instanceof Raw) {
+					$criteria .= $statement['joiner'] . ' ' . $key . ' ';
+					$bindings = array_merge($bindings, $statement['key']->getBindings());
+				} else {
+					// For wheres
+					$bindings[] = $this->getValue($value);
+
+					$criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'] . ' '
+					. $this->getType($value) . ' ';
+				}
+			}
+		}
+
+		// Clear all white spaces, and, or from beginning and white spaces from ending
+		$criteria = preg_replace('/^(\s?AND ?|\s?OR ?)|\s$/i', '', $criteria);
+
+		return [$criteria ?? '', $bindings];
+	}
+
+	/**
+	 * Asserts the types place holder based on its value
+	 *
+	 * @param mixed $value
+	 *
+	 * @return string
+	 */
+	public function inferType($value): string
+	{
+		switch (true) {
+			case is_string($value):
+				return '%s';
+			case \is_int($value):
+			case is_bool($value):
+				return '%d';
+			case is_float($value):
+				return '%f';
+			default:
+				return '';
+		}
+	}
+
+	/**
+	 * Wrap values with adapter's sanitizer like, '`'
+	 *
+	 * @param string|Raw|Closure $value
+	 *
+	 * @return string|Closure
+	 */
+	public function wrapSanitizer($value)
+	{
+		// Its a raw query, just cast as string, object has __toString()
+		if ($value instanceof Raw) {
+			return $this->parseRaw($value);
+		} elseif ($value instanceof Closure) {
+			return $value;
+		}
+
+		// Separate our table and fields which are joined with a ".",
+		// like my_table.id
+		$valueArr = explode('.', $value, 2);
+
+		foreach ($valueArr as $key => $subValue) {
+			// Don't wrap if we have *, which is not a usual field
+			$valueArr[$key] = '*' == trim($subValue) ? $subValue : $this->sanitizer . $subValue . $this->sanitizer;
+		}
+
+		// Join these back with "." and return
+		return implode('.', $valueArr);
+	}
+
+	/**
+	 * Build criteria string and binding with various types added, like WHERE and Having
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 * @param string $key
+	 * @param string $type
+	 * @param bool $bindValues
+	 *
+	 * @return array{0:string, 1:string[]}
+	 */
+	protected function buildCriteriaWithType(array $statements, string $key, string $type, bool $bindValues = true)
+	{
+		$criteria = '';
+		$bindings = [];
+
+		if (isset($statements[$key])) {
+			// Get the generic/adapter agnostic criteria string from parent
+			list($criteria, $bindings) = $this->buildCriteria($statements[$key], $bindValues);
+
+			if ($criteria) {
+				$criteria = $type . ' ' . $criteria;
+			}
+		}
+
+		// Remove any multiple whitespace.
+		$criteria = (string) preg_replace('!\s+!', ' ', $criteria);
+
+		return [$criteria, $bindings];
+	}
+
+	/**
+	 * Build join string
+	 *
+	 * @param array<string|Closure, mixed|mixed[]> $statements
+	 *
+	 * @return string
+	 */
+	protected function buildJoin(array $statements): string
+	{
+		$sql = '';
+
+		if (!array_key_exists('joins', $statements) || !is_array($statements['joins'])) {
+			return $sql;
+		}
+
+		foreach ($statements['joins'] as $joinArr) {
+			if (is_array($joinArr['table'])) {
+				$mainTable  = $this->stringifyValue($this->wrapSanitizer($joinArr['table'][0]));
+				$aliasTable = $this->stringifyValue($this->wrapSanitizer($joinArr['table'][1]));
+				$table      = $mainTable . ' AS ' . $aliasTable;
+			} else {
+				$table = $joinArr['table'] instanceof Raw
+					? $this->parseRaw($joinArr['table'])
+					: $this->wrapSanitizer($joinArr['table']);
+			}
+			$joinBuilder = $joinArr['joinBuilder'];
+
+			/** @var string[] */
+			$sqlArr = [
+				$sql,
+				strtoupper($joinArr['type']),
+				'JOIN',
+				$table,
+				'ON',
+				$joinBuilder->getQuery('criteriaOnly', false)->getSql(),
+			];
+
+			$sql = $this->concatenateQuery($sqlArr);
+		}
+
+		return $sql;
+	}
 }

Spacing +43 added lines, -43 removed lines

@@ -49,9 +49,9 @@ 
      */
     public function select(array $statements): array
     {
-        if (!array_key_exists('tables', $statements)) {
+        if ( ! array_key_exists('tables', $statements)) {
             throw new Exception('No table specified.', 3);
-        } elseif (!array_key_exists('selects', $statements)) {
+        } elseif ( ! array_key_exists('selects', $statements)) {
             $statements['selects'][] = '*';
         }
 
@@ -66,7 +66,7 @@ 
         // Group bys
         $groupBys = '';
         if (isset($statements['groupBys']) && $groupBys = $this->arrayStr($statements['groupBys'], ', ')) {
-            $groupBys = 'GROUP BY ' . $groupBys;
+            $groupBys = 'GROUP BY '.$groupBys;
         }
 
         // Order bys
@@ -77,17 +77,17 @@ 
                 if ($field instanceof Closure) {
                     continue;
                 }
-                $orderBys .= $field . ' ' . $orderBy['type'] . ', ';
+                $orderBys .= $field.' '.$orderBy['type'].', ';
             }
 
             if ($orderBys = trim($orderBys, ', ')) {
-                $orderBys = 'ORDER BY ' . $orderBys;
+                $orderBys = 'ORDER BY '.$orderBys;
             }
         }
 
         // Limit and offset
-        $limit  = isset($statements['limit']) ? 'LIMIT ' . (int) $statements['limit'] : '';
-        $offset = isset($statements['offset']) ? 'OFFSET ' . (int) $statements['offset'] : '';
+        $limit  = isset($statements['limit']) ? 'LIMIT '.(int) $statements['limit'] : '';
+        $offset = isset($statements['offset']) ? 'OFFSET '.(int) $statements['offset'] : '';
 
         // Having
         list($havingCriteria, $havingBindings) = $this->buildCriteriaWithType($statements, 'havings', 'HAVING');
@@ -97,7 +97,7 @@ 
 
         /** @var string[] */
         $sqlArray = [
-            'SELECT' . (isset($statements['distinct']) ? ' DISTINCT' : ''),
+            'SELECT'.(isset($statements['distinct']) ? ' DISTINCT' : ''),
             $selects,
             'FROM',
             $tables,
@@ -131,7 +131,7 @@ 
     public function criteriaOnly(array $statements, bool $bindValues = true): array
     {
         $sql = $bindings = [];
-        if (!isset($statements['criteria'])) {
+        if ( ! isset($statements['criteria'])) {
             return compact('sql', 'bindings');
         }
 
@@ -153,7 +153,7 @@ 
      */
     private function doInsert(array $statements, array $data, string $type): array
     {
-        if (!isset($statements['tables'])) {
+        if ( ! isset($statements['tables'])) {
             throw new Exception('No table specified', 3);
         }
 
@@ -174,20 +174,20 @@ 
             if ($value instanceof Raw) {
                 $values[] = $this->parseRaw($value);
             } elseif ($isBindings) {
-                $values[]   =  $value->getType();
+                $values[]   = $value->getType();
                 $bindings[] = $value->getValue();
             } else {
-                $values[]   =  $this->inferType($value);
+                $values[]   = $this->inferType($value);
                 $bindings[] = $value;
             }
         }
 
         $sqlArray = [
-        $type . ' INTO',
+        $type.' INTO',
         $this->wrapSanitizer($table),
-        '(' . $this->arrayStr($keys, ',') . ')',
+        '('.$this->arrayStr($keys, ',').')',
         'VALUES',
-        '(' . $this->arrayStr($values, ',') . ')',
+        '('.$this->arrayStr($values, ',').')',
         ];
 
         if (isset($statements['onduplicate'])) {
@@ -195,7 +195,7 @@ 
                 throw new Exception('No data given.', 4);
             }
             list($updateStatement, $updateBindings) = $this->getUpdateStatement($statements['onduplicate']);
-            $sqlArray[]                             = 'ON DUPLICATE KEY UPDATE ' . $updateStatement;
+            $sqlArray[]                             = 'ON DUPLICATE KEY UPDATE '.$updateStatement;
             $bindings                               = array_merge($bindings, $updateBindings);
         }
 
@@ -303,12 +303,12 @@ 
             }
 
             if ($value instanceof Raw) {
-                $statement .= $this->stringifyValue($this->wrapSanitizer($key)) . '=' . $value . ',';
+                $statement .= $this->stringifyValue($this->wrapSanitizer($key)).'='.$value.',';
             } elseif ($isBindings) {
-                $statement .= $this->stringifyValue($this->wrapSanitizer($key)) . sprintf('=%s,', $value->getType());
+                $statement .= $this->stringifyValue($this->wrapSanitizer($key)).sprintf('=%s,', $value->getType());
                 $bindings[] = $value->getValue();
             } else {
-                $statement .= $this->stringifyValue($this->wrapSanitizer($key)) . sprintf('=%s,', $this->inferType($value));
+                $statement .= $this->stringifyValue($this->wrapSanitizer($key)).sprintf('=%s,', $this->inferType($value));
                 $bindings[] = $value;
             }
         }
@@ -330,7 +330,7 @@ 
      */
     public function update($statements, array $data)
     {
-        if (!isset($statements['tables'])) {
+        if ( ! isset($statements['tables'])) {
             throw new Exception('No table specified', 3);
         } elseif (count($data) < 1) {
             throw new Exception('No data given.', 4);
@@ -345,12 +345,12 @@ 
         list($whereCriteria, $whereBindings) = $this->buildCriteriaWithType($statements, 'wheres', 'WHERE');
 
         // Limit
-        $limit = isset($statements['limit']) ? 'LIMIT ' . $statements['limit'] : '';
+        $limit = isset($statements['limit']) ? 'LIMIT '.$statements['limit'] : '';
 
         $sqlArray = [
             'UPDATE',
             $this->wrapSanitizer($table),
-            'SET ' . $updateStatement,
+            'SET '.$updateStatement,
             $whereCriteria,
             $limit,
         ];
@@ -373,7 +373,7 @@ 
      */
     public function delete($statements)
     {
-        if (!isset($statements['tables'])) {
+        if ( ! isset($statements['tables'])) {
             throw new Exception('No table specified', 3);
         }
 
@@ -388,7 +388,7 @@ 
         list($whereCriteria, $whereBindings) = $this->buildCriteriaWithType($statements, 'wheres', 'WHERE');
 
         // Limit
-        $limit = isset($statements['limit']) ? 'LIMIT ' . $statements['limit'] : '';
+        $limit = isset($statements['limit']) ? 'LIMIT '.$statements['limit'] : '';
 
         $sqlArray = ['DELETE FROM', $table, $whereCriteria];
         $sql      = $this->concatenateQuery($sqlArray);
@@ -410,11 +410,11 @@ 
     {
         $str = '';
         foreach ($pieces as $key => $piece) {
-            if (!is_int($key)) {
-                $piece = $key . ' AS ' . $piece;
+            if ( ! is_int($key)) {
+                $piece = $key.' AS '.$piece;
             }
 
-            $str .= $piece . $glue;
+            $str .= $piece.$glue;
         }
 
         return trim($str, $glue);
@@ -431,7 +431,7 @@ 
     {
         $str = '';
         foreach ($pieces as $piece) {
-            $str = trim($str) . ' ' . trim($piece);
+            $str = trim($str).' '.trim($piece);
         }
 
         return trim($str);
@@ -446,7 +446,7 @@ 
     public function getType($value): string
     {
         return $value instanceof Binding && $value->getType() !== null
-            ? $value->getType() : $this->inferType($value) ;
+            ? $value->getType() : $this->inferType($value);
     }
 
     /**
@@ -489,7 +489,7 @@ 
 
 
         $bindings = array_map([$this, 'getValue'], $bindings);
-        $query = $this->connection->getDbInstance()->prepare($query, $bindings) ;
+        $query = $this->connection->getDbInstance()->prepare($query, $bindings);
         return is_string($query) ? $query : '';
     }
 
@@ -530,10 +530,10 @@ 
                 // Merge the bindings we get from nestedCriteria object
                 $bindings = array_merge($bindings, $queryObject->getBindings());
                 // Append the sql we get from the nestedCriteria object
-                $criteria .= $statement['joiner'] . ' (' . $queryObject->getSql() . ') ';
+                $criteria .= $statement['joiner'].' ('.$queryObject->getSql().') ';
             } elseif (is_array($value)) {
                 // where_in or between like query
-                $criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'];
+                $criteria .= $statement['joiner'].' '.$key.' '.$statement['operator'];
 
                 switch ($statement['operator']) {
                     case 'BETWEEN':
@@ -549,7 +549,7 @@ 
                         $value[1] = $this->getValue($value[1]);
 
                         // Parse any raws.
-                        $value = array_map(function ($value) {
+                        $value = array_map(function($value) {
                             return $value instanceof Raw
                                 ? $this->parseRaw($value)
                                 : $value;
@@ -573,7 +573,7 @@ 
                         }
 
                         $valuePlaceholder = trim($valuePlaceholder, ', ');
-                        $criteria .= ' (' . $valuePlaceholder . ') ';
+                        $criteria .= ' ('.$valuePlaceholder.') ';
                         break;
                 }
             } elseif ($value instanceof Raw) {
@@ -581,20 +581,20 @@ 
                 $criteria .= "{$statement['joiner']} {$key} {$statement['operator']} $value ";
             } else {
                 // Usual where like criteria
-                if (!$bindValues) {
+                if ( ! $bindValues) {
                     // Specially for joins
                     // We are not binding values, lets sanitize then
                     $value = $this->stringifyValue($this->wrapSanitizer($value)) ?? '';
-                    $criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'] . ' ' . $value . ' ';
+                    $criteria .= $statement['joiner'].' '.$key.' '.$statement['operator'].' '.$value.' ';
                 } elseif ($statement['key'] instanceof Raw) {
-                    $criteria .= $statement['joiner'] . ' ' . $key . ' ';
+                    $criteria .= $statement['joiner'].' '.$key.' ';
                     $bindings = array_merge($bindings, $statement['key']->getBindings());
                 } else {
                     // For wheres
                     $bindings[] = $this->getValue($value);
 
-                    $criteria .= $statement['joiner'] . ' ' . $key . ' ' . $statement['operator'] . ' '
-                    . $this->getType($value) . ' ';
+                    $criteria .= $statement['joiner'].' '.$key.' '.$statement['operator'].' '
+                    . $this->getType($value).' ';
                 }
             }
         }
@@ -649,7 +649,7 @@ 
 
         foreach ($valueArr as $key => $subValue) {
             // Don't wrap if we have *, which is not a usual field
-            $valueArr[$key] = '*' == trim($subValue) ? $subValue : $this->sanitizer . $subValue . $this->sanitizer;
+            $valueArr[$key] = '*' == trim($subValue) ? $subValue : $this->sanitizer.$subValue.$this->sanitizer;
         }
 
         // Join these back with "." and return
@@ -676,7 +676,7 @@ 
             list($criteria, $bindings) = $this->buildCriteria($statements[$key], $bindValues);
 
             if ($criteria) {
-                $criteria = $type . ' ' . $criteria;
+                $criteria = $type.' '.$criteria;
             }
         }
 
@@ -697,7 +697,7 @@ 
     {
         $sql = '';
 
-        if (!array_key_exists('joins', $statements) || !is_array($statements['joins'])) {
+        if ( ! array_key_exists('joins', $statements) || ! is_array($statements['joins'])) {
             return $sql;
         }
 
@@ -705,7 +705,7 @@ 
             if (is_array($joinArr['table'])) {
                 $mainTable  = $this->stringifyValue($this->wrapSanitizer($joinArr['table'][0]));
                 $aliasTable = $this->stringifyValue($this->wrapSanitizer($joinArr['table'][1]));
-                $table      = $mainTable . ' AS ' . $aliasTable;
+                $table      = $mainTable.' AS '.$aliasTable;
             } else {
                 $table = $joinArr['table'] instanceof Raw
                     ? $this->parseRaw($joinArr['table'])

src/QueryBuilder/TablePrefixer.php

Indentation +63 added lines, -63 removed lines

@@ -9,77 +9,77 @@
 
 trait TablePrefixer
 {
-    /**
-         * Add table prefix (if given) on given string.
-         *
-         * @param array<string|int, string|int|float|bool|Raw|Closure>|string|int|float|bool|Raw|Closure     $values
-         * @param bool $tableFieldMix If we have mixes of field and table names with a "."
-         *
-         * @return mixed|mixed[]
-         */
-    public function addTablePrefix($values, bool $tableFieldMix = true)
-    {
-        if (is_null($this->getTablePrefix())) {
-            return $values;
-        }
+	/**
+	 * Add table prefix (if given) on given string.
+	 *
+	 * @param array<string|int, string|int|float|bool|Raw|Closure>|string|int|float|bool|Raw|Closure     $values
+	 * @param bool $tableFieldMix If we have mixes of field and table names with a "."
+	 *
+	 * @return mixed|mixed[]
+	 */
+	public function addTablePrefix($values, bool $tableFieldMix = true)
+	{
+		if (is_null($this->getTablePrefix())) {
+			return $values;
+		}
 
-        // $value will be an array and we will add prefix to all table names
+		// $value will be an array and we will add prefix to all table names
 
-        // If supplied value is not an array then make it one
-        $single = false;
-        if (!is_array($values)) {
-            $values = [$values];
-            // We had single value, so should return a single value
-            $single = true;
-        }
+		// If supplied value is not an array then make it one
+		$single = false;
+		if (!is_array($values)) {
+			$values = [$values];
+			// We had single value, so should return a single value
+			$single = true;
+		}
 
-        $return = [];
+		$return = [];
 
-        foreach ($values as $key => $value) {
-            // It's a raw query, just add it to our return array and continue next
-            if ($value instanceof Raw || $value instanceof Closure) {
-                $return[$key] = $value;
-                continue;
-            }
+		foreach ($values as $key => $value) {
+			// It's a raw query, just add it to our return array and continue next
+			if ($value instanceof Raw || $value instanceof Closure) {
+				$return[$key] = $value;
+				continue;
+			}
 
-            // If key is not integer, it is likely a alias mapping,
-            // so we need to change prefix target
-            $target = &$value;
-            if (!is_int($key)) {
-                $target = &$key;
-            }
+			// If key is not integer, it is likely a alias mapping,
+			// so we need to change prefix target
+			$target = &$value;
+			if (!is_int($key)) {
+				$target = &$key;
+			}
 
-            // Do prefix if the target is an expression or function.
-            if (
-                !$tableFieldMix
-                || (
-                    is_string($target) // Must be a string
-                    && (bool) preg_match('/^[A-Za-z0-9_.]+$/', $target) // Can only contain letters, numbers, underscore and full stops
-                    && 1 === \substr_count($target, '.') // Contains a single full stop ONLY.
-                )
-            ) {
-                $target = $this->getTablePrefix() . $target;
-            }
+			// Do prefix if the target is an expression or function.
+			if (
+				!$tableFieldMix
+				|| (
+					is_string($target) // Must be a string
+					&& (bool) preg_match('/^[A-Za-z0-9_.]+$/', $target) // Can only contain letters, numbers, underscore and full stops
+					&& 1 === \substr_count($target, '.') // Contains a single full stop ONLY.
+				)
+			) {
+				$target = $this->getTablePrefix() . $target;
+			}
 
-            $return[$key] = $value;
-        }
+			$return[$key] = $value;
+		}
 
-        // If we had single value then we should return a single value (end value of the array)
-        return true === $single ? end($return) : $return;
-    }
+		// If we had single value then we should return a single value (end value of the array)
+		return true === $single ? end($return) : $return;
+	}
 
-    /**
-     * Returns the table prefix if defined in connection
-     *
-     * @return string|null
-     */
-    protected function getTablePrefix(): ?string
-    {
-        $adapterConfig = $this->getConnection()->getAdapterConfig();
-        return isset($adapterConfig[Connection::PREFIX])
-            ? $adapterConfig[Connection::PREFIX]
-            : null;
-    }
+	/**
+	 * Returns the table prefix if defined in connection
+	 *
+	 * @return string|null
+	 */
+	protected function getTablePrefix(): ?string
+	{
+		$adapterConfig = $this->getConnection()->getAdapterConfig();
+		return isset($adapterConfig[Connection::PREFIX])
+			? $adapterConfig[Connection::PREFIX]
+			: null;
+	}
 
-    abstract public function getConnection(): Connection;
+	abstract public function getConnection(): Connection;
 }

Spacing +4 added lines, -4 removed lines

@@ -27,7 +27,7 @@ 
 
         // If supplied value is not an array then make it one
         $single = false;
-        if (!is_array($values)) {
+        if ( ! is_array($values)) {
             $values = [$values];
             // We had single value, so should return a single value
             $single = true;
@@ -45,20 +45,20 @@ 
             // If key is not integer, it is likely a alias mapping,
             // so we need to change prefix target
             $target = &$value;
-            if (!is_int($key)) {
+            if ( ! is_int($key)) {
                 $target = &$key;
             }
 
             // Do prefix if the target is an expression or function.
             if (
-                !$tableFieldMix
+                ! $tableFieldMix
                 || (
                     is_string($target) // Must be a string
                     && (bool) preg_match('/^[A-Za-z0-9_.]+$/', $target) // Can only contain letters, numbers, underscore and full stops
                     && 1 === \substr_count($target, '.') // Contains a single full stop ONLY.
                 )
             ) {
-                $target = $this->getTablePrefix() . $target;
+                $target = $this->getTablePrefix().$target;
             }
 
             $return[$key] = $value;

src/JSON/JsonSelector.php

Indentation +39 added lines, -39 removed lines

@@ -4,47 +4,47 @@
 
 class JsonSelector
 {
-    /**
-     * The table column
-     *
-     * @var string
-     */
-    protected $column;
+	/**
+	 * The table column
+	 *
+	 * @var string
+	 */
+	protected $column;
 
-    /**
-     * JSON Nodes
-     *
-     * @var string[]
-     */
-    protected $nodes;
+	/**
+	 * JSON Nodes
+	 *
+	 * @var string[]
+	 */
+	protected $nodes;
 
-    /**
-     * @param string $column
-     * @param string[] $nodes
-     */
-    public function __construct(string $column, array $nodes)
-    {
-        $this->column = $column;
-        $this->nodes = $nodes;
-    }
+	/**
+	 * @param string $column
+	 * @param string[] $nodes
+	 */
+	public function __construct(string $column, array $nodes)
+	{
+		$this->column = $column;
+		$this->nodes = $nodes;
+	}
 
-    /**
-     * Get the table column
-     *
-     * @return string
-     */
-    public function getColumn(): string
-    {
-        return $this->column;
-    }
+	/**
+	 * Get the table column
+	 *
+	 * @return string
+	 */
+	public function getColumn(): string
+	{
+		return $this->column;
+	}
 
-    /**
-     * Get jSON Nodes
-     *
-     * @return string[]
-     */
-    public function getNodes(): array
-    {
-        return $this->nodes;
-    }
+	/**
+	 * Get jSON Nodes
+	 *
+	 * @return string[]
+	 */
+	public function getNodes(): array
+	{
+		return $this->nodes;
+	}
 }

src/JSON/JsonHandler.php

Indentation +54 added lines, -54 removed lines

@@ -6,65 +6,65 @@
 
 class JsonHandler
 {
-    /** @var Connection */
-    protected $connection;
+	/** @var Connection */
+	protected $connection;
 
-    /** @var JsonSelectorHandler */
-    protected $jsonSelectorHandler;
+	/** @var JsonSelectorHandler */
+	protected $jsonSelectorHandler;
 
-    /** @var JsonExpressionFactory */
-    protected $jsonExpressionFactory;
+	/** @var JsonExpressionFactory */
+	protected $jsonExpressionFactory;
 
-    public function __construct(Connection $connection)
-    {
-        $this->connection = $connection;
-        $this->jsonSelectorHandler = new JsonSelectorHandler($connection);
-        $this->jsonExpressionFactory = new JsonExpressionFactory($connection);
-    }
+	public function __construct(Connection $connection)
+	{
+		$this->connection = $connection;
+		$this->jsonSelectorHandler = new JsonSelectorHandler($connection);
+		$this->jsonExpressionFactory = new JsonExpressionFactory($connection);
+	}
 
-    /**
-     * Returns the JSON Selector Handler
-     *
-     * @return JsonSelectorHandler
-     */
-    public function jsonSelectorHandler(): JsonSelectorHandler
-    {
-        return $this->jsonSelectorHandler;
-    }
+	/**
+	 * Returns the JSON Selector Handler
+	 *
+	 * @return JsonSelectorHandler
+	 */
+	public function jsonSelectorHandler(): JsonSelectorHandler
+	{
+		return $this->jsonSelectorHandler;
+	}
 
-    /**
-     * Returns the JSON Expression library
-     *
-     * @return JsonExpressionFactory
-     */
-    public function jsonExpressionFactory(): JsonExpressionFactory
-    {
-        return $this->jsonExpressionFactory;
-    }
+	/**
+	 * Returns the JSON Expression library
+	 *
+	 * @return JsonExpressionFactory
+	 */
+	public function jsonExpressionFactory(): JsonExpressionFactory
+	{
+		return $this->jsonExpressionFactory;
+	}
 
-    /**
-     * Parses a JSON selector and returns as an Extract and Unquote expression.
-     *
-     * @param string $selector
-     * @return string
-     */
-    public function extractAndUnquoteFromJsonSelector(string $selector): string
-    {
-        $selector = $this->jsonSelectorHandler()->toJsonSelector($selector);
-        return $this->jsonExpressionFactory()->extractAndUnquote(
-            $selector->getColumn(),
-            $selector->getNodes()
-        );
-    }
+	/**
+	 * Parses a JSON selector and returns as an Extract and Unquote expression.
+	 *
+	 * @param string $selector
+	 * @return string
+	 */
+	public function extractAndUnquoteFromJsonSelector(string $selector): string
+	{
+		$selector = $this->jsonSelectorHandler()->toJsonSelector($selector);
+		return $this->jsonExpressionFactory()->extractAndUnquote(
+			$selector->getColumn(),
+			$selector->getNodes()
+		);
+	}
 
-    /**
-     * Checks if the passed values is a valid JSON Selector
-     *
-     * @param mixed $expression
-     * @return bool
-     */
-    public function isJsonSelector($expression): bool
-    {
-        return $this->jsonSelectorHandler()->isJsonSelector($expression);
-    }
+	/**
+	 * Checks if the passed values is a valid JSON Selector
+	 *
+	 * @param mixed $expression
+	 * @return bool
+	 */
+	public function isJsonSelector($expression): bool
+	{
+		return $this->jsonSelectorHandler()->isJsonSelector($expression);
+	}
 }

static-loader-creator.php

Indentation +224 added lines, -224 removed lines

@@ -25,161 +25,161 @@ 
 
 class StaticLoaderCreator
 {
-    /** @var string[] Array of file names */
-    protected array $files = [];
-
-    /** @var array<int, array{class:string|null, ns:string|null, interface:string|null, trait:string|null, file:string}> Classes */
-    protected array $classes = [];
-
-    /** @var string Path to the SRC directory. */
-    protected $routePath;
-
-    public function __construct()
-    {
-        $this->routePath = __DIR__ . DIRECTORY_SEPARATOR . 'src';
-    }
-
-    /**
-     * Static initialiser
-     *
-     * @return void
-     */
-    public static function run(): void
-    {
-        $instance = new self();
-        $instance->getFiles();
-        $instance->getClassNames();
-        $instance->writeLoader();
-    }
-
-    /**
-     * Get all filenames excluding the loader.
-     *
-     * @return void
-     */
-    public function getFiles(): void
-    {
-        $rii = new RecursiveIteratorIterator(
-            new RecursiveDirectoryIterator($this->routePath)
-        );
-
-        foreach ($rii as $file) {
-            if ($file->isDir() || $file->getPathname() === $this->routePath . DIRECTORY_SEPARATOR . 'loader.php') {
-                continue;
-            }
-
-            $this->files[] = $file->getPathname();
-        }
-    }
-
-    /**
-     * Compiles the list of classnames with file paths.
-     *
-     * @return void
-     */
-    public function getClassNames(): void
-    {
-        foreach ($this->files as $file) {
-            $classData['class'] = $this->getObjectTypeFromFile($file, T_CLASS);
-            $classData['trait'] = $this->getObjectTypeFromFile($file, T_TRAIT);
-            $classData['interface'] = $this->getObjectTypeFromFile($file, T_INTERFACE);
-            $classData['ns'] = $this->getNamespace($file);
-            $classData['file'] = str_replace($this->routePath, '', $file);
-            $this->classes[] = $classData;
-        }
-
-        // Set all classes to be required last, allow traits to load first.
-        uasort($this->classes, function ($file1, $file2) {
-            return is_null($file1['class']) ? -1 : 1;
-        });
-    }
-
-    /**
-     * Gets the namespace from a file.
-     *
-     * @see https://stackoverflow.com/questions/7153000/get-class-name-from-file/44654073
-     * @param string $file
-     * @return string|null
-     * @throws \Exception If file not found or empty.
-     */
-    public function getNamespace(string $file): ?string
-    {
-        $src = file_get_contents($file);
-
-        if (false === $src) {
-            throw new \Exception("Could not read contents of {$file}", 1);
-        }
-
-        $tokens = token_get_all($src);
-        $count = count($tokens);
-        $i = 0;
-        $namespace = '';
-        $namespace_ok = false;
-        while ($i < $count) {
-            $token = $tokens[$i];
-            if (is_array($token) && $token[0] === T_NAMESPACE) {
-                // Found namespace declaration
-                while (++$i < $count) {
-                    if ($tokens[$i] === ';') {
-                        $namespace_ok = true;
-                        $namespace = trim($namespace);
-                        break;
-                    }
-                    $namespace .= is_array($tokens[$i]) ? $tokens[$i][1] : $tokens[$i];
-                }
-                break;
-            }
-            $i++;
-        }
-        if (!$namespace_ok) {
-            return null;
-        } else {
-            return $namespace;
-        }
-    }
-
-    /**
-     * get the class name form file path using token
-     *
-     * @see https://stackoverflow.com/questions/7153000/get-class-name-from-file/44654073
-     * @param string $file
-     * @param int $type
-     * @return string|null
-     */
-    protected function getObjectTypeFromFile(string $file, int $type = T_CLASS): ?string
-    {
-        $src = file_get_contents($file);
-
-        if (false === $src) {
-            throw new \Exception("Could not read contents of {$file}", 1);
-        }
-
-        $classes = array();
-        $tokens = token_get_all($src);
-        $count = count($tokens);
-        for ($i = 2; $i < $count; $i++) {
-            if (
-                $tokens[$i - 2][0] == $type
-                && $tokens[$i - 1][0] == T_WHITESPACE
-                && $tokens[$i][0] == T_STRING
-            ) {
-                $class_name = $tokens[$i][1];
-                $classes[] = $class_name;
-            }
-        }
-
-        return array_key_exists(0, $classes) ? $classes[0] : null;
-    }
-
-    /**
-     * Writes the loader.php file.
-     *
-     * @return void
-     */
-    public function writeLoader(): void
-    {
-        $newLine = PHP_EOL;
-        $header = "<?php{$newLine}{$newLine}{$newLine}
+	/** @var string[] Array of file names */
+	protected array $files = [];
+
+	/** @var array<int, array{class:string|null, ns:string|null, interface:string|null, trait:string|null, file:string}> Classes */
+	protected array $classes = [];
+
+	/** @var string Path to the SRC directory. */
+	protected $routePath;
+
+	public function __construct()
+	{
+		$this->routePath = __DIR__ . DIRECTORY_SEPARATOR . 'src';
+	}
+
+	/**
+	 * Static initialiser
+	 *
+	 * @return void
+	 */
+	public static function run(): void
+	{
+		$instance = new self();
+		$instance->getFiles();
+		$instance->getClassNames();
+		$instance->writeLoader();
+	}
+
+	/**
+	 * Get all filenames excluding the loader.
+	 *
+	 * @return void
+	 */
+	public function getFiles(): void
+	{
+		$rii = new RecursiveIteratorIterator(
+			new RecursiveDirectoryIterator($this->routePath)
+		);
+
+		foreach ($rii as $file) {
+			if ($file->isDir() || $file->getPathname() === $this->routePath . DIRECTORY_SEPARATOR . 'loader.php') {
+				continue;
+			}
+
+			$this->files[] = $file->getPathname();
+		}
+	}
+
+	/**
+	 * Compiles the list of classnames with file paths.
+	 *
+	 * @return void
+	 */
+	public function getClassNames(): void
+	{
+		foreach ($this->files as $file) {
+			$classData['class'] = $this->getObjectTypeFromFile($file, T_CLASS);
+			$classData['trait'] = $this->getObjectTypeFromFile($file, T_TRAIT);
+			$classData['interface'] = $this->getObjectTypeFromFile($file, T_INTERFACE);
+			$classData['ns'] = $this->getNamespace($file);
+			$classData['file'] = str_replace($this->routePath, '', $file);
+			$this->classes[] = $classData;
+		}
+
+		// Set all classes to be required last, allow traits to load first.
+		uasort($this->classes, function ($file1, $file2) {
+			return is_null($file1['class']) ? -1 : 1;
+		});
+	}
+
+	/**
+	 * Gets the namespace from a file.
+	 *
+	 * @see https://stackoverflow.com/questions/7153000/get-class-name-from-file/44654073
+	 * @param string $file
+	 * @return string|null
+	 * @throws \Exception If file not found or empty.
+	 */
+	public function getNamespace(string $file): ?string
+	{
+		$src = file_get_contents($file);
+
+		if (false === $src) {
+			throw new \Exception("Could not read contents of {$file}", 1);
+		}
+
+		$tokens = token_get_all($src);
+		$count = count($tokens);
+		$i = 0;
+		$namespace = '';
+		$namespace_ok = false;
+		while ($i < $count) {
+			$token = $tokens[$i];
+			if (is_array($token) && $token[0] === T_NAMESPACE) {
+				// Found namespace declaration
+				while (++$i < $count) {
+					if ($tokens[$i] === ';') {
+						$namespace_ok = true;
+						$namespace = trim($namespace);
+						break;
+					}
+					$namespace .= is_array($tokens[$i]) ? $tokens[$i][1] : $tokens[$i];
+				}
+				break;
+			}
+			$i++;
+		}
+		if (!$namespace_ok) {
+			return null;
+		} else {
+			return $namespace;
+		}
+	}
+
+	/**
+	 * get the class name form file path using token
+	 *
+	 * @see https://stackoverflow.com/questions/7153000/get-class-name-from-file/44654073
+	 * @param string $file
+	 * @param int $type
+	 * @return string|null
+	 */
+	protected function getObjectTypeFromFile(string $file, int $type = T_CLASS): ?string
+	{
+		$src = file_get_contents($file);
+
+		if (false === $src) {
+			throw new \Exception("Could not read contents of {$file}", 1);
+		}
+
+		$classes = array();
+		$tokens = token_get_all($src);
+		$count = count($tokens);
+		for ($i = 2; $i < $count; $i++) {
+			if (
+				$tokens[$i - 2][0] == $type
+				&& $tokens[$i - 1][0] == T_WHITESPACE
+				&& $tokens[$i][0] == T_STRING
+			) {
+				$class_name = $tokens[$i][1];
+				$classes[] = $class_name;
+			}
+		}
+
+		return array_key_exists(0, $classes) ? $classes[0] : null;
+	}
+
+	/**
+	 * Writes the loader.php file.
+	 *
+	 * @return void
+	 */
+	public function writeLoader(): void
+	{
+		$newLine = PHP_EOL;
+		$header = "<?php{$newLine}{$newLine}{$newLine}
 /**
  * Pixie WPDB Static Loader
  *
@@ -205,77 +205,77 @@ 
 
 // Generated code start...";
 
-        $contents = array_map(function ($file, $class) {
-             return sprintf(
-                 "if (!%s(%s::class)) {
+		$contents = array_map(function ($file, $class) {
+			 return sprintf(
+				 "if (!%s(%s::class)) {
     require_once __DIR__ . '%s';
 }",
-                 $this->getMethodFromToken($class),
-                 $this->getFullTokenName($class),
-                 $class['file']
-             );
-        }, array_keys($this->classes), $this->classes);
-
-        $footer = sprintf("// CREATED ON %s", date('D jS F Y', time()));
-
-        $file = __DIR__ . DIRECTORY_SEPARATOR . 'src' . DIRECTORY_SEPARATOR . 'loader.php';
-        touch($file);
-
-        file_put_contents(
-            $file,
-            join(PHP_EOL, [
-                $header,
-                join(PHP_EOL, $contents),
-                $footer, ''
-            ])
-        );
-    }
-
-    /**
-     * Gets the *_exists() method based on the token type.
-     *
-     * @param array{class:string|null, ns:string|null, interface:string|null, trait:string|null, file:string} $token
-     * @return string
-     */
-    public function getMethodFromToken(array $token): string
-    {
-        switch (true) {
-            case ! is_null($token['trait']):
-                return 'trait_exists';
-
-            case ! is_null($token['interface']):
-                return 'interface_exists';
-
-            default:
-                return 'class_exists';
-        }
-    }
-
-    /**
-     * Returns the full (namespaced) token name
-     *
-     * @param array{class:string|null, ns:string|null, interface:string|null, trait:string|null, file:string} $token
-     * @return string
-     */
-    public function getFullTokenName(array $token): string
-    {
-        switch (true) {
-            case ! array_key_exists('ns', $token):
-                return '';
-
-            case ! is_null($token['trait']):
-                return $token['ns'] . '\\' . $token['trait'];
-
-            case ! is_null($token['interface']):
-                return $token['ns'] . '\\' . $token['interface'];
-
-            case ! is_null($token['class']):
-                return $token['ns'] . '\\' . $token['class'];
-
-            default:
-                return '';
-        }
-    }
+				 $this->getMethodFromToken($class),
+				 $this->getFullTokenName($class),
+				 $class['file']
+			 );
+		}, array_keys($this->classes), $this->classes);
+
+		$footer = sprintf("// CREATED ON %s", date('D jS F Y', time()));
+
+		$file = __DIR__ . DIRECTORY_SEPARATOR . 'src' . DIRECTORY_SEPARATOR . 'loader.php';
+		touch($file);
+
+		file_put_contents(
+			$file,
+			join(PHP_EOL, [
+				$header,
+				join(PHP_EOL, $contents),
+				$footer, ''
+			])
+		);
+	}
+
+	/**
+	 * Gets the *_exists() method based on the token type.
+	 *
+	 * @param array{class:string|null, ns:string|null, interface:string|null, trait:string|null, file:string} $token
+	 * @return string
+	 */
+	public function getMethodFromToken(array $token): string
+	{
+		switch (true) {
+			case ! is_null($token['trait']):
+				return 'trait_exists';
+
+			case ! is_null($token['interface']):
+				return 'interface_exists';
+
+			default:
+				return 'class_exists';
+		}
+	}
+
+	/**
+	 * Returns the full (namespaced) token name
+	 *
+	 * @param array{class:string|null, ns:string|null, interface:string|null, trait:string|null, file:string} $token
+	 * @return string
+	 */
+	public function getFullTokenName(array $token): string
+	{
+		switch (true) {
+			case ! array_key_exists('ns', $token):
+				return '';
+
+			case ! is_null($token['trait']):
+				return $token['ns'] . '\\' . $token['trait'];
+
+			case ! is_null($token['interface']):
+				return $token['ns'] . '\\' . $token['interface'];
+
+			case ! is_null($token['class']):
+				return $token['ns'] . '\\' . $token['class'];
+
+			default:
+				return '';
+		}
+	}
 }
 
 StaticLoaderCreator::run();

Spacing +9 added lines, -9 removed lines

@@ -36,7 +36,7 @@ 
 
     public function __construct()
     {
-        $this->routePath = __DIR__ . DIRECTORY_SEPARATOR . 'src';
+        $this->routePath = __DIR__.DIRECTORY_SEPARATOR.'src';
     }
 
     /**
@@ -64,7 +64,7 @@ 
         );
 
         foreach ($rii as $file) {
-            if ($file->isDir() || $file->getPathname() === $this->routePath . DIRECTORY_SEPARATOR . 'loader.php') {
+            if ($file->isDir() || $file->getPathname() === $this->routePath.DIRECTORY_SEPARATOR.'loader.php') {
                 continue;
             }
 
@@ -89,7 +89,7 @@ 
         }
 
         // Set all classes to be required last, allow traits to load first.
-        uasort($this->classes, function ($file1, $file2) {
+        uasort($this->classes, function($file1, $file2) {
             return is_null($file1['class']) ? -1 : 1;
         });
     }
@@ -131,7 +131,7 @@ 
             }
             $i++;
         }
-        if (!$namespace_ok) {
+        if ( ! $namespace_ok) {
             return null;
         } else {
             return $namespace;
@@ -205,7 +205,7 @@ 
 
 // Generated code start...";
 
-        $contents = array_map(function ($file, $class) {
+        $contents = array_map(function($file, $class) {
              return sprintf(
                  "if (!%s(%s::class)) {
     require_once __DIR__ . '%s';
@@ -218,7 +218,7 @@ 
 
         $footer = sprintf("// CREATED ON %s", date('D jS F Y', time()));
 
-        $file = __DIR__ . DIRECTORY_SEPARATOR . 'src' . DIRECTORY_SEPARATOR . 'loader.php';
+        $file = __DIR__.DIRECTORY_SEPARATOR.'src'.DIRECTORY_SEPARATOR.'loader.php';
         touch($file);
 
         file_put_contents(
@@ -264,13 +264,13 @@ 
                 return '';
 
             case ! is_null($token['trait']):
-                return $token['ns'] . '\\' . $token['trait'];
+                return $token['ns'].'\\'.$token['trait'];
 
             case ! is_null($token['interface']):
-                return $token['ns'] . '\\' . $token['interface'];
+                return $token['ns'].'\\'.$token['interface'];
 
             case ! is_null($token['class']):
-                return $token['ns'] . '\\' . $token['class'];
+                return $token['ns'].'\\'.$token['class'];
 
             default:
                 return '';

src/QueryBuilder/JsonQueryBuilder.php

Indentation +444 added lines, -444 removed lines

@@ -4,448 +4,448 @@
 
 class JsonQueryBuilder extends QueryBuilderHandler
 {
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
-    * @param mixed|null $value
-    * @return static
-    */
-    public function whereJson($column, $nodes, $operator = null, $value = null): self
-    {
-        // If two params are given then assume operator is =
-        if (3 === func_num_args()) {
-            $value    = $operator;
-            $operator = '=';
-        }
-
-        return $this->whereJsonHandler($column, $nodes, $operator, $value, 'AND');
-    }
-
-    /**
-     * @param string|Raw $column The database column which holds the JSON value
-     * @param string|Raw|string[] $nodes The json key/index to search
-     * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
-     * @param mixed|null $value
-     * @return static
-     */
-    public function whereNotJson($column, $nodes, $operator = null, $value = null): self
-    {
-        // If two params are given then assume operator is =
-        if (3 === func_num_args()) {
-            $value    = $operator;
-            $operator = '=';
-        }
-
-        return $this->whereJsonHandler($column, $nodes, $operator, $value, 'AND NOT');
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
-    * @param mixed|null $value
-    * @return static
-    */
-    public function orWhereJson($column, $nodes, $operator = null, $value = null): self
-    {
-        // If two params are given then assume operator is =
-        if (3 === func_num_args()) {
-            $value    = $operator;
-            $operator = '=';
-        }
-
-        return $this->whereJsonHandler($column, $nodes, $operator, $value, 'OR');
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
-    * @param mixed|null $value
-    * @return static
-    */
-    public function orWhereNotJson($column, $nodes, $operator = null, $value = null): self
-    {
-        // If two params are given then assume operator is =
-        if (3 === func_num_args()) {
-            $value    = $operator;
-            $operator = '=';
-        }
-
-        return $this->whereJsonHandler($column, $nodes, $operator, $value, 'OR NOT');
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param mixed[] $values
-    * @return static
-    */
-    public function whereInJson($column, $nodes, $values): self
-    {
-        return $this->whereJsonHandler($column, $nodes, 'IN', $values, 'AND');
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param mixed[] $values
-    * @return static
-    */
-    public function whereNotInJson($column, $nodes, $values): self
-    {
-        return $this->whereJsonHandler($column, $nodes, 'NOT IN', $values, 'AND');
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param mixed[] $values
-    * @return static
-    */
-    public function orWhereInJson($column, $nodes, $values): self
-    {
-        return $this->whereJsonHandler($column, $nodes, 'IN', $values, 'OR');
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param mixed[] $values
-    * @return static
-    */
-    public function orWhereNotInJson($column, $nodes, $values): self
-    {
-        return $this->whereJsonHandler($column, $nodes, 'NOT IN', $values, 'OR');
-    }
-
-    /**
-     * @param string|Raw $column
-    * @param string|Raw|string[] $nodes The json key/index to search
-     * @param mixed $valueFrom
-     * @param mixed $valueTo
-     *
-     * @return static
-     */
-    public function whereBetweenJson($column, $nodes, $valueFrom, $valueTo): self
-    {
-        return $this->whereJsonHandler($column, $nodes, 'BETWEEN', [$valueFrom, $valueTo], 'AND');
-    }
-
-    /**
-     * @param string|Raw $column
-    * @param string|Raw|string[] $nodes The json key/index to search
-     * @param mixed $valueFrom
-     * @param mixed $valueTo
-     *
-     * @return static
-     */
-    public function orWhereBetweenJson($column, $nodes, $valueFrom, $valueTo): self
-    {
-        return $this->whereJsonHandler($column, $nodes, 'BETWEEN', [$valueFrom, $valueTo], 'OR');
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
-    * @param mixed|null $value
-    * @return static
-    */
-    public function whereDayJson($column, $nodes, $operator = null, $value = null): self
-    {
-        // If two params are given then assume operator is =
-        if (3 === func_num_args()) {
-            $value    = $operator;
-            $operator = '=';
-        }
-        return $this->whereFunctionCallJsonHandler($column, $nodes, 'DAY', $operator, $value);
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
-    * @param mixed|null $value
-    * @return static
-    */
-    public function whereMonthJson($column, $nodes, $operator = null, $value = null): self
-    {
-        // If two params are given then assume operator is =
-        if (3 === func_num_args()) {
-            $value    = $operator;
-            $operator = '=';
-        }
-        return $this->whereFunctionCallJsonHandler($column, $nodes, 'MONTH', $operator, $value);
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
-    * @param mixed|null $value
-    * @return static
-    */
-    public function whereYearJson($column, $nodes, $operator = null, $value = null): self
-    {
-        // If two params are given then assume operator is =
-        if (3 === func_num_args()) {
-            $value    = $operator;
-            $operator = '=';
-        }
-        return $this->whereFunctionCallJsonHandler($column, $nodes, 'YEAR', $operator, $value);
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
-    * @param mixed|null $value
-    * @return static
-    */
-    public function whereDateJson($column, $nodes, $operator = null, $value = null): self
-    {
-        // If two params are given then assume operator is =
-        if (3 === func_num_args()) {
-            $value    = $operator;
-            $operator = '=';
-        }
-        return $this->whereFunctionCallJsonHandler($column, $nodes, 'DATE', $operator, $value);
-    }
-
-    /**
-     * Maps a function call for a JSON where condition
-     *
-     * @param string|Raw $column
-     * @param string|Raw|string[] $nodes
-     * @param string $function
-     * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
-     * @param mixed|null $value
-     * @return static
-     */
-    protected function whereFunctionCallJsonHandler($column, $nodes, $function, $operator, $value): self
-    {
-        // Handle potential raw values.
-        if ($column instanceof Raw) {
-            $column = $this->adapterInstance->parseRaw($column);
-        }
-        if ($nodes instanceof Raw) {
-            $nodes = $this->adapterInstance->parseRaw($nodes);
-        }
-
-        return $this->whereFunctionCallHandler(
-            $this->jsonHandler->jsonExpressionFactory()->extractAndUnquote($column, $nodes),
-            $function,
-            $operator,
-            $value
-        );
-    }
-
-    /**
-    * @param string|Raw $column The database column which holds the JSON value
-    * @param string|Raw|string[] $nodes The json key/index to search
-    * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
-    * @param mixed|null $value
-    * @param string $joiner
-    * @return static
-    */
-    protected function whereJsonHandler($column, $nodes, $operator = null, $value = null, string $joiner = 'AND'): self
-    {
-        // Handle potential raw values.
-        if ($column instanceof Raw) {
-            $column = $this->adapterInstance->parseRaw($column);
-        }
-        if ($nodes instanceof Raw) {
-            $nodes = $this->adapterInstance->parseRaw($nodes);
-        }
-
-        return $this->whereHandler(
-            $this->jsonHandler->jsonExpressionFactory()->extractAndUnquote($column, $nodes),
-            $operator,
-            $value,
-            $joiner
-        );
-    }
-
-    /**
-     * @param string|Raw $table
-     * @param string|Raw $leftColumn
-     * @param string|Raw|string[]|null $leftNodes The json key/index to search
-     * @param string $operator
-     * @param string|Raw $rightColumn
-     * @param string|Raw|string[]|null $rightNodes
-     * @param string $type
-     *
-     * @return static
-     */
-    public function joinJson(
-        $table,
-        $leftColumn,
-        $leftNodes,
-        string $operator,
-        $rightColumn,
-        $rightNodes,
-        $type = 'inner'
-    ): self {
-        // Convert key if json
-        if (null !== $rightNodes) {
-            $rightColumn = $this->jsonHandler->jsonExpressionFactory()->extractAndUnquote($rightColumn, $rightNodes);
-        }
-
-        // Convert key if json
-        if (null !== $leftNodes) {
-            $leftColumn = $this->jsonHandler->jsonExpressionFactory()->extractAndUnquote($leftColumn, $leftNodes);
-        }
-
-        return $this->join($table, $leftColumn, $operator, $rightColumn, $type);
-    }
-
-    /**
-     * @param string|Raw $table
-     * @param string|Raw $leftColumn
-     * @param string|Raw|string[]|null $leftNodes The json key/index to search
-     * @param string $operator
-     * @param string|Raw $rightColumn
-     * @param string|Raw|string[]|null $rightNodes
-     *
-     * @return static
-     */
-    public function leftJoinJson(
-        $table,
-        $leftColumn,
-        $leftNodes,
-        string $operator,
-        $rightColumn,
-        $rightNodes
-    ): self {
-        return $this->joinJson(
-            $table,
-            $leftColumn,
-            $leftNodes,
-            $operator,
-            $rightColumn,
-            $rightNodes,
-            'left'
-        );
-    }
-
-    /**
-     * @param string|Raw $table
-     * @param string|Raw $leftColumn
-     * @param string|Raw|string[]|null $leftNodes The json key/index to search
-     * @param string $operator
-     * @param string|Raw $rightColumn
-     * @param string|Raw|string[]|null $rightNodes
-     *
-     * @return static
-     */
-    public function rightJoinJson(
-        $table,
-        $leftColumn,
-        $leftNodes,
-        string $operator,
-        $rightColumn,
-        $rightNodes
-    ): self {
-        return $this->joinJson(
-            $table,
-            $leftColumn,
-            $leftNodes,
-            $operator,
-            $rightColumn,
-            $rightNodes,
-            'right'
-        );
-    }
-
-    /**
-     * @param string|Raw $table
-     * @param string|Raw $leftColumn
-     * @param string|Raw|string[]|null $leftNodes The json key/index to search
-     * @param string $operator
-     * @param string|Raw $rightColumn
-     * @param string|Raw|string[]|null $rightNodes
-     *
-     * @return static
-     */
-    public function outerJoinJson(
-        $table,
-        $leftColumn,
-        $leftNodes,
-        string $operator,
-        $rightColumn,
-        $rightNodes
-    ): self {
-        return $this->joinJson(
-            $table,
-            $leftColumn,
-            $leftNodes,
-            $operator,
-            $rightColumn,
-            $rightNodes,
-            'FULL OUTER'
-        );
-    }
-
-    /**
-     * @param string|Raw $table
-     * @param string|Raw $leftColumn
-     * @param string|Raw|string[]|null $leftNodes The json key/index to search
-     * @param string $operator
-     * @param string|Raw $rightColumn
-     * @param string|Raw|string[]|null $rightNodes
-     *
-     * @return static
-     */
-    public function crossJoinJson(
-        $table,
-        $leftColumn,
-        $leftNodes,
-        string $operator,
-        $rightColumn,
-        $rightNodes
-    ): self {
-        return $this->joinJson(
-            $table,
-            $leftColumn,
-            $leftNodes,
-            $operator,
-            $rightColumn,
-            $rightNodes,
-            'cross'
-        );
-    }
-
-
-
-    // JSON
-
-    /**
-     * @param string|Raw $column The database column which holds the JSON value
-     * @param string|Raw|string[] $nodes The json key/index to search
-     * @param string|null $alias The alias used to define the value in results, if not defined will use json_{$nodes}
-     * @return static
-     */
-    public function selectJson($column, $nodes, ?string $alias = null): self
-    {
-        // Handle potential raw values.
-        if ($column instanceof Raw) {
-            $column = $this->adapterInstance->parseRaw($column);
-        }
-        if ($nodes instanceof Raw) {
-            $nodes = $this->adapterInstance->parseRaw($nodes);
-        }
-
-        // If deeply nested jsonKey.
-        if (is_array($nodes)) {
-            $nodes = \implode('.', $nodes);
-        }
-
-        // Add any possible prefixes to the key
-        $column = $this->addTablePrefix($column, true);
-
-        $alias = null === $alias ? "json_{$nodes}" : $alias;
-        return  $this->select(new Raw("JSON_UNQUOTE(JSON_EXTRACT({$column}, \"$.{$nodes}\")) as {$alias}"));
-    }
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
+	 * @param mixed|null $value
+	 * @return static
+	 */
+	public function whereJson($column, $nodes, $operator = null, $value = null): self
+	{
+		// If two params are given then assume operator is =
+		if (3 === func_num_args()) {
+			$value    = $operator;
+			$operator = '=';
+		}
+
+		return $this->whereJsonHandler($column, $nodes, $operator, $value, 'AND');
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
+	 * @param mixed|null $value
+	 * @return static
+	 */
+	public function whereNotJson($column, $nodes, $operator = null, $value = null): self
+	{
+		// If two params are given then assume operator is =
+		if (3 === func_num_args()) {
+			$value    = $operator;
+			$operator = '=';
+		}
+
+		return $this->whereJsonHandler($column, $nodes, $operator, $value, 'AND NOT');
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
+	 * @param mixed|null $value
+	 * @return static
+	 */
+	public function orWhereJson($column, $nodes, $operator = null, $value = null): self
+	{
+		// If two params are given then assume operator is =
+		if (3 === func_num_args()) {
+			$value    = $operator;
+			$operator = '=';
+		}
+
+		return $this->whereJsonHandler($column, $nodes, $operator, $value, 'OR');
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
+	 * @param mixed|null $value
+	 * @return static
+	 */
+	public function orWhereNotJson($column, $nodes, $operator = null, $value = null): self
+	{
+		// If two params are given then assume operator is =
+		if (3 === func_num_args()) {
+			$value    = $operator;
+			$operator = '=';
+		}
+
+		return $this->whereJsonHandler($column, $nodes, $operator, $value, 'OR NOT');
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param mixed[] $values
+	 * @return static
+	 */
+	public function whereInJson($column, $nodes, $values): self
+	{
+		return $this->whereJsonHandler($column, $nodes, 'IN', $values, 'AND');
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param mixed[] $values
+	 * @return static
+	 */
+	public function whereNotInJson($column, $nodes, $values): self
+	{
+		return $this->whereJsonHandler($column, $nodes, 'NOT IN', $values, 'AND');
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param mixed[] $values
+	 * @return static
+	 */
+	public function orWhereInJson($column, $nodes, $values): self
+	{
+		return $this->whereJsonHandler($column, $nodes, 'IN', $values, 'OR');
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param mixed[] $values
+	 * @return static
+	 */
+	public function orWhereNotInJson($column, $nodes, $values): self
+	{
+		return $this->whereJsonHandler($column, $nodes, 'NOT IN', $values, 'OR');
+	}
+
+	/**
+	 * @param string|Raw $column
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param mixed $valueFrom
+	 * @param mixed $valueTo
+	 *
+	 * @return static
+	 */
+	public function whereBetweenJson($column, $nodes, $valueFrom, $valueTo): self
+	{
+		return $this->whereJsonHandler($column, $nodes, 'BETWEEN', [$valueFrom, $valueTo], 'AND');
+	}
+
+	/**
+	 * @param string|Raw $column
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param mixed $valueFrom
+	 * @param mixed $valueTo
+	 *
+	 * @return static
+	 */
+	public function orWhereBetweenJson($column, $nodes, $valueFrom, $valueTo): self
+	{
+		return $this->whereJsonHandler($column, $nodes, 'BETWEEN', [$valueFrom, $valueTo], 'OR');
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
+	 * @param mixed|null $value
+	 * @return static
+	 */
+	public function whereDayJson($column, $nodes, $operator = null, $value = null): self
+	{
+		// If two params are given then assume operator is =
+		if (3 === func_num_args()) {
+			$value    = $operator;
+			$operator = '=';
+		}
+		return $this->whereFunctionCallJsonHandler($column, $nodes, 'DAY', $operator, $value);
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
+	 * @param mixed|null $value
+	 * @return static
+	 */
+	public function whereMonthJson($column, $nodes, $operator = null, $value = null): self
+	{
+		// If two params are given then assume operator is =
+		if (3 === func_num_args()) {
+			$value    = $operator;
+			$operator = '=';
+		}
+		return $this->whereFunctionCallJsonHandler($column, $nodes, 'MONTH', $operator, $value);
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
+	 * @param mixed|null $value
+	 * @return static
+	 */
+	public function whereYearJson($column, $nodes, $operator = null, $value = null): self
+	{
+		// If two params are given then assume operator is =
+		if (3 === func_num_args()) {
+			$value    = $operator;
+			$operator = '=';
+		}
+		return $this->whereFunctionCallJsonHandler($column, $nodes, 'YEAR', $operator, $value);
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
+	 * @param mixed|null $value
+	 * @return static
+	 */
+	public function whereDateJson($column, $nodes, $operator = null, $value = null): self
+	{
+		// If two params are given then assume operator is =
+		if (3 === func_num_args()) {
+			$value    = $operator;
+			$operator = '=';
+		}
+		return $this->whereFunctionCallJsonHandler($column, $nodes, 'DATE', $operator, $value);
+	}
+
+	/**
+	 * Maps a function call for a JSON where condition
+	 *
+	 * @param string|Raw $column
+	 * @param string|Raw|string[] $nodes
+	 * @param string $function
+	 * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
+	 * @param mixed|null $value
+	 * @return static
+	 */
+	protected function whereFunctionCallJsonHandler($column, $nodes, $function, $operator, $value): self
+	{
+		// Handle potential raw values.
+		if ($column instanceof Raw) {
+			$column = $this->adapterInstance->parseRaw($column);
+		}
+		if ($nodes instanceof Raw) {
+			$nodes = $this->adapterInstance->parseRaw($nodes);
+		}
+
+		return $this->whereFunctionCallHandler(
+			$this->jsonHandler->jsonExpressionFactory()->extractAndUnquote($column, $nodes),
+			$function,
+			$operator,
+			$value
+		);
+	}
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param string|mixed|null $operator Can be used as value, if 3rd arg not passed
+	 * @param mixed|null $value
+	 * @param string $joiner
+	 * @return static
+	 */
+	protected function whereJsonHandler($column, $nodes, $operator = null, $value = null, string $joiner = 'AND'): self
+	{
+		// Handle potential raw values.
+		if ($column instanceof Raw) {
+			$column = $this->adapterInstance->parseRaw($column);
+		}
+		if ($nodes instanceof Raw) {
+			$nodes = $this->adapterInstance->parseRaw($nodes);
+		}
+
+		return $this->whereHandler(
+			$this->jsonHandler->jsonExpressionFactory()->extractAndUnquote($column, $nodes),
+			$operator,
+			$value,
+			$joiner
+		);
+	}
+
+	/**
+	 * @param string|Raw $table
+	 * @param string|Raw $leftColumn
+	 * @param string|Raw|string[]|null $leftNodes The json key/index to search
+	 * @param string $operator
+	 * @param string|Raw $rightColumn
+	 * @param string|Raw|string[]|null $rightNodes
+	 * @param string $type
+	 *
+	 * @return static
+	 */
+	public function joinJson(
+		$table,
+		$leftColumn,
+		$leftNodes,
+		string $operator,
+		$rightColumn,
+		$rightNodes,
+		$type = 'inner'
+	): self {
+		// Convert key if json
+		if (null !== $rightNodes) {
+			$rightColumn = $this->jsonHandler->jsonExpressionFactory()->extractAndUnquote($rightColumn, $rightNodes);
+		}
+
+		// Convert key if json
+		if (null !== $leftNodes) {
+			$leftColumn = $this->jsonHandler->jsonExpressionFactory()->extractAndUnquote($leftColumn, $leftNodes);
+		}
+
+		return $this->join($table, $leftColumn, $operator, $rightColumn, $type);
+	}
+
+	/**
+	 * @param string|Raw $table
+	 * @param string|Raw $leftColumn
+	 * @param string|Raw|string[]|null $leftNodes The json key/index to search
+	 * @param string $operator
+	 * @param string|Raw $rightColumn
+	 * @param string|Raw|string[]|null $rightNodes
+	 *
+	 * @return static
+	 */
+	public function leftJoinJson(
+		$table,
+		$leftColumn,
+		$leftNodes,
+		string $operator,
+		$rightColumn,
+		$rightNodes
+	): self {
+		return $this->joinJson(
+			$table,
+			$leftColumn,
+			$leftNodes,
+			$operator,
+			$rightColumn,
+			$rightNodes,
+			'left'
+		);
+	}
+
+	/**
+	 * @param string|Raw $table
+	 * @param string|Raw $leftColumn
+	 * @param string|Raw|string[]|null $leftNodes The json key/index to search
+	 * @param string $operator
+	 * @param string|Raw $rightColumn
+	 * @param string|Raw|string[]|null $rightNodes
+	 *
+	 * @return static
+	 */
+	public function rightJoinJson(
+		$table,
+		$leftColumn,
+		$leftNodes,
+		string $operator,
+		$rightColumn,
+		$rightNodes
+	): self {
+		return $this->joinJson(
+			$table,
+			$leftColumn,
+			$leftNodes,
+			$operator,
+			$rightColumn,
+			$rightNodes,
+			'right'
+		);
+	}
+
+	/**
+	 * @param string|Raw $table
+	 * @param string|Raw $leftColumn
+	 * @param string|Raw|string[]|null $leftNodes The json key/index to search
+	 * @param string $operator
+	 * @param string|Raw $rightColumn
+	 * @param string|Raw|string[]|null $rightNodes
+	 *
+	 * @return static
+	 */
+	public function outerJoinJson(
+		$table,
+		$leftColumn,
+		$leftNodes,
+		string $operator,
+		$rightColumn,
+		$rightNodes
+	): self {
+		return $this->joinJson(
+			$table,
+			$leftColumn,
+			$leftNodes,
+			$operator,
+			$rightColumn,
+			$rightNodes,
+			'FULL OUTER'
+		);
+	}
+
+	/**
+	 * @param string|Raw $table
+	 * @param string|Raw $leftColumn
+	 * @param string|Raw|string[]|null $leftNodes The json key/index to search
+	 * @param string $operator
+	 * @param string|Raw $rightColumn
+	 * @param string|Raw|string[]|null $rightNodes
+	 *
+	 * @return static
+	 */
+	public function crossJoinJson(
+		$table,
+		$leftColumn,
+		$leftNodes,
+		string $operator,
+		$rightColumn,
+		$rightNodes
+	): self {
+		return $this->joinJson(
+			$table,
+			$leftColumn,
+			$leftNodes,
+			$operator,
+			$rightColumn,
+			$rightNodes,
+			'cross'
+		);
+	}
+
+
+
+	// JSON
+
+	/**
+	 * @param string|Raw $column The database column which holds the JSON value
+	 * @param string|Raw|string[] $nodes The json key/index to search
+	 * @param string|null $alias The alias used to define the value in results, if not defined will use json_{$nodes}
+	 * @return static
+	 */
+	public function selectJson($column, $nodes, ?string $alias = null): self
+	{
+		// Handle potential raw values.
+		if ($column instanceof Raw) {
+			$column = $this->adapterInstance->parseRaw($column);
+		}
+		if ($nodes instanceof Raw) {
+			$nodes = $this->adapterInstance->parseRaw($nodes);
+		}
+
+		// If deeply nested jsonKey.
+		if (is_array($nodes)) {
+			$nodes = \implode('.', $nodes);
+		}
+
+		// Add any possible prefixes to the key
+		$column = $this->addTablePrefix($column, true);
+
+		$alias = null === $alias ? "json_{$nodes}" : $alias;
+		return  $this->select(new Raw("JSON_UNQUOTE(JSON_EXTRACT({$column}, \"$.{$nodes}\")) as {$alias}"));
+	}
 }

src/JSON/JsonSelectorHandler.php

Indentation +70 added lines, -70 removed lines

@@ -9,84 +9,84 @@
 
 class JsonSelectorHandler implements HasConnection
 {
-    use TablePrefixer;
+	use TablePrefixer;
 
-    /** @var Connection */
-    protected $connection;
+	/** @var Connection */
+	protected $connection;
 
-    public function __construct(Connection $connection)
-    {
-        $this->connection = $connection;
-    }
+	public function __construct(Connection $connection)
+	{
+		$this->connection = $connection;
+	}
 
-    /**
-     * Returns the current connection instance.
-     *
-     * @return connection
-     */
-    public function getConnection(): Connection
-    {
-        return $this->connection;
-    }
+	/**
+	 * Returns the current connection instance.
+	 *
+	 * @return connection
+	 */
+	public function getConnection(): Connection
+	{
+		return $this->connection;
+	}
 
-    /**
-     * Checks if the passed expression is for JSON
-     * this->denotes->json
-     *
-     * @param string $expression
-     * @return bool
-     */
-    public function isJsonSelector($expression): bool
-    {
-        return is_string($expression)
-        && 2 <= count(array_diff(explode('->', $expression), array("")));
-    }
+	/**
+	 * Checks if the passed expression is for JSON
+	 * this->denotes->json
+	 *
+	 * @param string $expression
+	 * @return bool
+	 */
+	public function isJsonSelector($expression): bool
+	{
+		return is_string($expression)
+		&& 2 <= count(array_diff(explode('->', $expression), array("")));
+	}
 
-    /**
-    * Gets the column name form a potential array
-    *
-    * @param string $expression
-    * @return string
-    * @throws Exception If invalid JSON Selector string passed.
-    */
-    public function getColumn(string $expression): string
-    {
-        return $this->toJsonSelector($expression)->getColumn();
-    }
+	/**
+	 * Gets the column name form a potential array
+	 *
+	 * @param string $expression
+	 * @return string
+	 * @throws Exception If invalid JSON Selector string passed.
+	 */
+	public function getColumn(string $expression): string
+	{
+		return $this->toJsonSelector($expression)->getColumn();
+	}
 
-    /**
-     * Gets all JSON object keys while removing the column name.
-     *
-     * @param string $expression
-     * @return string[]
-     * @throws Exception If invalid JSON Selector string passed.
-     */
-    public function getNodes(string $expression): array
-    {
-        return $this->toJsonSelector($expression)->getNodes();
-    }
+	/**
+	 * Gets all JSON object keys while removing the column name.
+	 *
+	 * @param string $expression
+	 * @return string[]
+	 * @throws Exception If invalid JSON Selector string passed.
+	 */
+	public function getNodes(string $expression): array
+	{
+		return $this->toJsonSelector($expression)->getNodes();
+	}
 
-    /**
-     * Casts a valid JSON selector to a JsonSelector object.
-     *
-     * @param string $expression
-     * @return JsonSelector
-     * @throws Exception If invalid JSON Selector string passed.
-     */
-    public function toJsonSelector(string $expression): JsonSelector
-    {
-        if (! $this->isJsonSelector($expression)) {
-            throw new Exception('JSON expression must contain at least 2 values, the table column and at least 1 node.', 1);
-        }
+	/**
+	 * Casts a valid JSON selector to a JsonSelector object.
+	 *
+	 * @param string $expression
+	 * @return JsonSelector
+	 * @throws Exception If invalid JSON Selector string passed.
+	 */
+	public function toJsonSelector(string $expression): JsonSelector
+	{
+		if (! $this->isJsonSelector($expression)) {
+			throw new Exception('JSON expression must contain at least 2 values, the table column and at least 1 node.', 1);
+		}
 
-        /** @var string[] Check done above. */
-        $parts = array_diff(explode('->', $expression), array(""));
+		/** @var string[] Check done above. */
+		$parts = array_diff(explode('->', $expression), array(""));
 
-        /** @var string */
-        $column = array_shift($parts);
-        /** @var string[] */
-        $nodes = $parts;
+		/** @var string */
+		$column = array_shift($parts);
+		/** @var string[] */
+		$nodes = $parts;
 
-        return new JsonSelector($column, $nodes);
-    }
+		return new JsonSelector($column, $nodes);
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -75,7 +75,7 @@
      */
     public function toJsonSelector(string $expression): JsonSelector
     {
-        if (! $this->isJsonSelector($expression)) {
+        if ( ! $this->isJsonSelector($expression)) {
             throw new Exception('JSON expression must contain at least 2 values, the table column and at least 1 node.', 1);
         }
 

src/JSON/JsonExpressionFactory.php

Indentation +51 added lines, -51 removed lines

@@ -9,65 +9,65 @@
 
 class JsonExpressionFactory
 {
-    use TablePrefixer;
+	use TablePrefixer;
 
-    /** @var Connection */
-    protected $connection;
+	/** @var Connection */
+	protected $connection;
 
-    public function __construct(Connection $connection)
-    {
-        $this->connection = $connection;
-    }
+	public function __construct(Connection $connection)
+	{
+		$this->connection = $connection;
+	}
 
-    /**
-     * Returns the current connection instance.
-     *
-     * @return connection
-     */
-    public function getConnection(): Connection
-    {
-        return $this->connection;
-    }
+	/**
+	 * Returns the current connection instance.
+	 *
+	 * @return connection
+	 */
+	public function getConnection(): Connection
+	{
+		return $this->connection;
+	}
 
-    /**
-     * Normalises the values passed as nodes
-     *
-     * @param mixed $nodes
-     * @return string
-     */
-    protected function normaliseNodes($nodes): string
-    {
-        // If its not an array, cast.
-        if (!is_array($nodes)) {
-            $nodes = [$nodes];
-        }
+	/**
+	 * Normalises the values passed as nodes
+	 *
+	 * @param mixed $nodes
+	 * @return string
+	 */
+	protected function normaliseNodes($nodes): string
+	{
+		// If its not an array, cast.
+		if (!is_array($nodes)) {
+			$nodes = [$nodes];
+		}
 
-        // Remove all none string.
-        $nodes = array_filter($nodes, function ($node): bool {
-            return is_string($node);
-        });
+		// Remove all none string.
+		$nodes = array_filter($nodes, function ($node): bool {
+			return is_string($node);
+		});
 
-        // If we have no nodes, throw.
-        if (count($nodes) === 0) {
-            throw new Exception("Only strings values may be passed as nodes.");
-        }
+		// If we have no nodes, throw.
+		if (count($nodes) === 0) {
+			throw new Exception("Only strings values may be passed as nodes.");
+		}
 
-        return \implode('.', $nodes);
-    }
+		return \implode('.', $nodes);
+	}
 
-    /**
-     * @param string          $column  The database column which holds the JSON value
-     * @param string|string[] $nodes   The json key/index to search
-     * @return \Pixie\QueryBuilder\Raw
-     */
-    public function extractAndUnquote(string $column, $nodes): Raw
-    {
-        // Normalise nodes.
-        $nodes = $this->normaliseNodes($nodes);
+	/**
+	 * @param string          $column  The database column which holds the JSON value
+	 * @param string|string[] $nodes   The json key/index to search
+	 * @return \Pixie\QueryBuilder\Raw
+	 */
+	public function extractAndUnquote(string $column, $nodes): Raw
+	{
+		// Normalise nodes.
+		$nodes = $this->normaliseNodes($nodes);
 
-        // Add any possible prefixes to the key
-        $column = $this->addTablePrefix($column, true);
+		// Add any possible prefixes to the key
+		$column = $this->addTablePrefix($column, true);
 
-        return new Raw("JSON_UNQUOTE(JSON_EXTRACT({$column}, \"$.{$nodes}\"))");
-    }
+		return new Raw("JSON_UNQUOTE(JSON_EXTRACT({$column}, \"$.{$nodes}\"))");
+	}
 }

Spacing +2 added lines, -2 removed lines

@@ -38,12 +38,12 @@
     protected function normaliseNodes($nodes): string
     {
         // If its not an array, cast.
-        if (!is_array($nodes)) {
+        if ( ! is_array($nodes)) {
             $nodes = [$nodes];
         }
 
         // Remove all none string.
-        $nodes = array_filter($nodes, function ($node): bool {
+        $nodes = array_filter($nodes, function($node): bool {
             return is_string($node);
         });
 

src/Event.php

Indentation +9 added lines, -9 removed lines

@@ -27,13 +27,13 @@
 
 class Event
 {
-    /** Events */
-    public const BEFORE_SELECT = 'before-select';
-    public const AFTER_SELECT = 'after-select';
-    public const BEFORE_INSERT = 'before-insert';
-    public const AFTER_INSERT = 'after-insert';
-    public const BEFORE_UPDATE = 'before-update';
-    public const AFTER_UPDATE = 'after-update';
-    public const BEFORE_DELETE = 'before-delete';
-    public const AFTER_DELETE = 'after-delete';
+	/** Events */
+	public const BEFORE_SELECT = 'before-select';
+	public const AFTER_SELECT = 'after-select';
+	public const BEFORE_INSERT = 'before-insert';
+	public const AFTER_INSERT = 'after-insert';
+	public const BEFORE_UPDATE = 'before-update';
+	public const AFTER_UPDATE = 'after-update';
+	public const BEFORE_DELETE = 'before-delete';
+	public const AFTER_DELETE = 'after-delete';
 }