Bluz\Db\Query\Traits\From

Complexity

Total Complexity

12

Size/Duplication

Total Lines	235
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

95.12%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	from()	0	11	1
A	join()	0	4	1
A	innerJoin()	0	4	1
A	leftJoin()	0	4	1
A	rightJoin()	0	4	1
A	addJoin()	0	12	1
A	setFromQueryPart()	0	4	1
A	prepareFrom()	0	13	2
A	prepareJoins()	0	17	3

<?php
/**
 * Bluz Framework Component
 *
 * @copyright Bluz PHP Team
 * @link      https://github.com/bluzphp/framework
 */

declare(strict_types=1);

namespace Bluz\Db\Query\Traits;

use Bluz\Proxy\Db;

/**
 * From Trait
 *
 * Required for:
 *  - Select Builder
 *  - Delete Builder
 *
 * @package  Bluz\Db\Query\Traits
 * @author   Anton Shevchuk
 */
trait From
{
    /**
     * <code>
     * [
     *     'table' => 'users',
     *     'alias' => 'u'
     * ]
     * </code>
     *
     * @var array
     */
    protected $from = [];

    /**
     * <code>
     * [
     *     'u' => [
     *         'joinType' => 'inner',
     *         'joinTable' => $join,
     *         'joinAlias' => $alias,
     *         'joinCondition' => $condition
     * ]
     * </code>
     *
     * @var array[]
     */
    protected $join = [];

    /**
     * Set FROM
     *
     * Create and add a query root corresponding to the table identified by the
     * given alias, forming a cartesian product with any existing query roots
     *
     * <code>
     *     $sb = new SelectBuilder();
     *     $sb
     *         ->select('u.id')
     *         ->from('users', 'u')
     * </code>
     *
     * @param  string $from  The table
     * @param  string $alias The alias of the table
     *
     * @return $this
     */
    public function from(string $from, string $alias)
    {
        $this->aliases[] = $alias;

The property aliases does not exist. Did you maybe forget to declare it?

        $this->from[] = [
            'table' => $from,
            'alias' => $alias
        ];

        return $this;
    }

    /**
     * Creates and adds a join to the query
     *
     * Example
     * <code>
     *     $sb = new Select();
     *     $sb
     *         ->select('u.name')
     *         ->from('users', 'u')
     *         ->join('u', 'phone', 'p', 'p.is_primary = 1');
     * </code>
     *
     * @param  string $fromAlias The alias that points to a from clause
     * @param  string $join      The table name to join
     * @param  string $alias     The alias of the join table
     * @param  string $condition The condition for the join
     *
     * @return $this
     */
    public function join(string $fromAlias, string $join, string $alias, string $condition = null)
    {
        return $this->innerJoin($fromAlias, $join, $alias, $condition);
    }

    /**
     * Creates and adds a join to the query
     *
     * Example
     * <code>
     *     $sb = new Select();
     *     $sb
     *         ->select('u.name')
     *         ->from('users', 'u')
     *         ->innerJoin('u', 'phone', 'p', 'p.is_primary = 1');
     * </code>
     *
     * @param  string $fromAlias The alias that points to a from clause
     * @param  string $join      The table name to join
     * @param  string $alias     The alias of the join table
     * @param  string $condition The condition for the join
     *
     * @return $this
     */
    public function innerJoin(string $fromAlias, string $join, string $alias, string $condition = null)
    {
        return $this->addJoin('inner', $fromAlias, $join, $alias, $condition);
    }

    /**
     * Creates and adds a left join to the query.
     *
     * Example
     * <code>
     *     $sb = new Select();
     *     $sb
     *         ->select('u.name')
     *         ->from('users', 'u')
     *         ->leftJoin('u', 'phone', 'p', 'p.is_primary = 1');
     * </code>
     *
     * @param  string $fromAlias The alias that points to a from clause
     * @param  string $join      The table name to join
     * @param  string $alias     The alias of the join table
     * @param  string $condition The condition for the join
     *
     * @return $this
     */
    public function leftJoin(string $fromAlias, string $join, string $alias, string $condition = null)
    {
        return $this->addJoin('left', $fromAlias, $join, $alias, $condition);
    }

    /**
     * Creates and adds a right join to the query.
     *
     * Example
     * <code>
     *     $sb = new Select();
     *     $sb
     *         ->select('u.name')
     *         ->from('users', 'u')
     *         ->rightJoin('u', 'phone', 'p', 'p.is_primary = 1');
     * </code>
     *
     * @param  string $fromAlias The alias that points to a from clause
     * @param  string $join      The table name to join
     * @param  string $alias     The alias of the join table
     * @param  string $condition The condition for the join
     *
     * @return $this
     */
    public function rightJoin(string $fromAlias, string $join, string $alias, string $condition = null)
    {
        return $this->addJoin('right', $fromAlias, $join, $alias, $condition);
    }

    /**
     * addJoin()
     *
     * @param  string $type      The type of join
     * @param  string $fromAlias The alias that points to a from clause
     * @param  string $join      The table name to join
     * @param  string $alias     The alias of the join table
     * @param  string $condition The condition for the join
     *
     * @return $this
     */
    protected function addJoin(string $type, string $fromAlias, string $join, string $alias, string $condition = null)
    {
        $this->aliases[] = $alias;

        $this->join[$fromAlias][] = [
            'joinType' => $type,
            'joinTable' => $join,
            'joinAlias' => $alias,
            'joinCondition' => $condition
        ];
        return $this;
    }

    /**
     * setFromQueryPart
     *
     * @param  string $table
     *
     * @return self
     */
    protected function setFromQueryPart($table)
    {
        return $this->from($table, $table);
    }

    /**
     * Prepare From query part
     *
     * @return string
     */
    protected function prepareFrom() : string
    {
        $fromClauses = [];
        // Loop through all FROM clauses
        foreach ($this->from as $from) {
            $fromClause = Db::quoteIdentifier($from['table']) . ' AS ' . $from['alias']
                . $this->prepareJoins($from['alias']);

            $fromClauses[$from['alias']] = $fromClause;
        }

        return ' FROM ' . implode(', ', $fromClauses);
    }

    /**
     * Generate SQL string for JOINs
     *
     * @param  string $fromAlias The alias of the table
     *
     * @return string
     */
    protected function prepareJoins($fromAlias) : string
    {
        if (!isset($this->join[$fromAlias])) {
            return '';
        }

        $query = '';

        foreach ($this->join[$fromAlias] as $join) {
            $query .= ' ' . strtoupper($join['joinType'])
                . ' JOIN ' . Db::quoteIdentifier($join['joinTable']) . ' AS ' . $join['joinAlias']
                . ' ON ' . $join['joinCondition'];
            $query .= $this->prepareJoins($join['joinAlias']);
        }

        return $query;
    }
}