TableBuilder::columnsSql() - Code Metrics - Inspection of "Migration feature" - softberg/quantum-php-core - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#65)

by Arman

created 2022-05-19 09:55 UTC

TableBuilder::columnsSql() B

↳ Parent: TableBuilder

Complexity

Conditions	9
Paths	2

Size

Total Lines	35
Code Lines	18

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	9
eloc	18
c	0
b	0
f	0
nc	2
nop	0
dl	0
loc	35
rs	8.0555

<?php

/**
 * Quantum PHP Framework
 *
 * An open source software development framework for PHP
 *
 * @package Quantum
 * @author Arman Ag. <[email protected]>
 * @copyright Copyright (c) 2018 Softberg LLC (https://softberg.org)
 * @link http://quantum.softberg.org/
 * @since 2.7.0
 */

namespace Quantum\Libraries\Database\Schema;

/**
 * Trait TableBuilder
 * @package Quantum\Libraries\Database
 */
trait TableBuilder
{

    /**
     * Generates create table statement
     * @return string
     */
    protected function createTableSql()
    {
        $columnsSql = $this->columnsSql();
        $indexesSql = $this->indexesSql();
        $sql = '';

        if ($columnsSql) {
            $sql = 'CREATE TABLE `' . $this->name . '` (';
            $sql .= $columnsSql;
            $sql .= ($indexesSql ? ', ' . $indexesSql : '');
            $sql .= ');';
        }

        return $sql;
    }

    /**
     * Generates alter table statement
     * @return string
     */
    protected function alterTableSql(): string
    {
        $columnsSql = $this->columnsSql();
        $indexesSql = $this->indexesSql();
        $dropIndexesSql = $this->dropIndexesSql();
        $sql = '';

        if ($columnsSql || $indexesSql || $dropIndexesSql) {
            $sql = 'ALTER TABLE `' . $this->name . '` ';
            $sql .= $columnsSql;
            $sql .= (($columnsSql && $indexesSql) ? ', ' . $indexesSql : $indexesSql);
            $sql .= ((($columnsSql || $indexesSql) && $dropIndexesSql) ? ', ' . $dropIndexesSql : $dropIndexesSql);
            $sql .= ';';
        }

        return $sql;
    }

    /**
     * Prepares rename table statement
     * @return string
     */
    protected function renameTableSql(): string
    {
        return 'RENAME TABLE `' . $this->name . '` TO `' . $this->newName . '`;';
    }

    /**
     * Prepares drop table statement
     * @return string
     */
    protected function dropTableSql(): string
    {
        return 'DROP TABLE `' . $this->name . '`';
    }

    /**
     * Prepares columns statements for table
     * @return string
     */
    protected function columnsSql(): string
    {
        $sql = '';

        if ($this->columns) {
            $columns = [];

            foreach ($this->columns as $entry) {
                $columnString = '';

                if ($entry['action'] != Column::ADD_INDEX && $entry['action'] != Column::DROP_INDEX) {
                    $columnString .= ($entry['action'] ? $entry['action'] . ' COLUMN ' : '');
                    $columnString .= $this->composeColumn($entry['column'], $entry['action']);
                }

                if ($entry['column']->get('indexKey')) {
                    $this->indexKeys[$entry['column']->get('indexKey')][] = [

                        'columnName' => $entry['column']->get('name'),
                        'indexName' => $entry['column']->get('indexName'),
                    ];
                }

                if ($entry['column']->get('indexDrop')) {
                    $this->droppedIndexKeys[] = $entry['column']->get('indexDrop');

                }

                if ($columnString) {
                    array_push($columns, $columnString);
                }
            }

            $sql = implode(', ', $columns);
        }

        return $sql;
    }

    /**
     * Composes the column 
     * @param Column $column
     * @param string $action
     * @return string
     */
    protected function composeColumn(Column $column, string $action = null): string
    {
        return
                $this->columnAttrSql($column->get(Column::NAME), '`', '`') .
                $this->columnAttrSql($column->get(Column::NEW_NAME), ' TO `', '`') .
                $this->columnAttrSql($column->get(Column::TYPE), ' ') .
                $this->columnAttrSql($column->get(Column::CONSTRAINT), '(', ')') .
                $this->columnAttrSql($column->get(Column::ATTRIBUTE), ' ') .
                $this->columnAttrSql($column->get(Column::NULLABLE, $action), ' ',) .
                $this->columnAttrSql($column->get(Column::DEFAULT), ' DEFAULT ' . ($column->defaultQuoted() ? '\'' : ''), ($column->defaultQuoted() ? '\'' : '')) .
                $this->columnAttrSql($column->get(Column::COMMENT), ' COMMENT \'', '\'') .
                $this->columnAttrSql($column->get(Column::AFTER), ' AFTER `', '`') .
                $this->columnAttrSql($column->get(Column::AUTO_INCREMENT), ' ');
    }

    /**
     * Prepares column attributes
     * @param string|null $definition
     * @param string $before
     * @param string $after
     * @return string
     */
    protected function columnAttrSql(?string $definition, string $before = '', string $after = ''): string
    {
        $sql = '';

        if (!is_null($definition)) {
            $sql .= $before . $definition . $after;
        }

        return $sql;
    }

    /**
     * Prepares statement for primary key
     * @return string
     */
    protected function primaryKeysSql(): string
    {
        $sql = '';

        if (isset($this->indexKeys['primary'])) {
            $sql .= ($this->action == self::ALTER ? 'ADD ' : '');


            $sql .= 'PRIMARY KEY (';

            foreach ($this->indexKeys['primary'] as $key => $primaryKey) {
                $sql .= '`' . $primaryKey['columnName'] . '`';
                $sql .= (array_key_last($this->indexKeys['primary']) != $key ? ', ' : '');
            }

            $sql .= ')';
        }

        return $sql;
    }

    /**
     * Prepares statement for index keys
     * @param string $type
     * @return string
     */
    protected function indexKeysSql(string $type): string
    {
        $sql = '';

        if (isset($this->indexKeys[$type])) {
            $indexes = [];

            foreach ($this->indexKeys[$type] as $key => $indexKey) {
                $indexString = '';

                $indexString .= ($this->action == self::ALTER ? 'ADD ' : '');

                $indexString .= strtoupper($type);
                $indexString .= ($indexKey['indexName'] ? ' `' . $indexKey['indexName'] . '`' : '');
                $indexString .= ' (`' . $indexKey['columnName'] . '`)';

                array_push($indexes, $indexString);
            }

            $sql = implode(', ', $indexes);
        }

        return $sql;
    }

    /**
     * Builds a complete statement for index keys
     * @return string
     */
    protected function indexesSql(): string
    {
        return $this->primaryKeysSql() .
                $this->indexKeysSql(Key::INDEX) .
                $this->indexKeysSql(Key::UNIQUE) .
                $this->indexKeysSql(Key::FULLTEXT) .
                $this->indexKeysSql(Key::SPATIAL);
    }

    /**
     * Builds a statement for drop indexes
     * @return string
     */
    protected function dropIndexesSql()
    {
        $sql = '';

        if (!empty($this->droppedIndexKeys)) {
            $indexes = [];

            foreach ($this->droppedIndexKeys as $index) {
                $indexes[] = 'DROP INDEX `' . $index . '`';
            }

            $sql .= implode(', ', $indexes);
        }

        return $sql;
    }

}


1			<?php
2
3			/**
4			* Quantum PHP Framework
5			*
6			* An open source software development framework for PHP
7			*
8			* @package Quantum
9			* @author Arman Ag. <[email protected]>
10			* @copyright Copyright (c) 2018 Softberg LLC (https://softberg.org)
11			* @link http://quantum.softberg.org/
12			* @since 2.7.0
13			*/
14
15			namespace Quantum\Libraries\Database\Schema;
16
17			/**
18			* Trait TableBuilder
19			* @package Quantum\Libraries\Database
20			*/
21			trait TableBuilder
22			{
23
24			/**
25			* Generates create table statement
26			* @return string
27			*/
28			protected function createTableSql()
29			{
30			$columnsSql = $this->columnsSql();
31			$indexesSql = $this->indexesSql();
32			$sql = '';
33
34			if ($columnsSql) {
35			$sql = 'CREATE TABLE `' . $this->name . '` (';
36			$sql .= $columnsSql;
37			$sql .= ($indexesSql ? ', ' . $indexesSql : '');
38			$sql .= ');';
39			}
40
41			return $sql;
42			}
43
44			/**
45			* Generates alter table statement
46			* @return string
47			*/
48			protected function alterTableSql(): string
49			{
50			$columnsSql = $this->columnsSql();
51			$indexesSql = $this->indexesSql();
52			$dropIndexesSql = $this->dropIndexesSql();
53			$sql = '';
54
55			if ($columnsSql \|\| $indexesSql \|\| $dropIndexesSql) {
56			$sql = 'ALTER TABLE `' . $this->name . '` ';
57			$sql .= $columnsSql;
58			$sql .= (($columnsSql && $indexesSql) ? ', ' . $indexesSql : $indexesSql);
59			$sql .= ((($columnsSql \|\| $indexesSql) && $dropIndexesSql) ? ', ' . $dropIndexesSql : $dropIndexesSql);
60			$sql .= ';';
61			}
62
63			return $sql;
64			}
65
66			/**
67			* Prepares rename table statement
68			* @return string
69			*/
70			protected function renameTableSql(): string
71			{
72			return 'RENAME TABLE `' . $this->name . '` TO `' . $this->newName . '`;';
73			}
74
75			/**
76			* Prepares drop table statement
77			* @return string
78			*/
79			protected function dropTableSql(): string
80			{
81			return 'DROP TABLE `' . $this->name . '`';
82			}
83
84			/**
85			* Prepares columns statements for table
86			* @return string
87			*/
88			protected function columnsSql(): string
89			{
90			$sql = '';
91
92			if ($this->columns) {
93			$columns = [];
94
95			foreach ($this->columns as $entry) {
96			$columnString = '';
97
98			if ($entry['action'] != Column::ADD_INDEX && $entry['action'] != Column::DROP_INDEX) {
99			$columnString .= ($entry['action'] ? $entry['action'] . ' COLUMN ' : '');
100			$columnString .= $this->composeColumn($entry['column'], $entry['action']);
101			}
102
103			if ($entry['column']->get('indexKey')) {
104			$this->indexKeys[$entry['column']->get('indexKey')][] = [
			0 ignored issues – show Bug Best Practice introduced 2022-05-17 08:57 UTC by Report Bug Copy Issue Report The property `indexKeys` does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly. Loading history...
105			'columnName' => $entry['column']->get('name'),
106			'indexName' => $entry['column']->get('indexName'),
107			];
108			}
109
110			if ($entry['column']->get('indexDrop')) {
111			$this->droppedIndexKeys[] = $entry['column']->get('indexDrop');
			0 ignored issues – show Bug Best Practice introduced 2022-05-17 08:57 UTC by Report Bug Copy Issue Report The property `droppedIndexKeys` does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly. Loading history...
112			}
113
114			if ($columnString) {
115			array_push($columns, $columnString);
116			}
117			}
118
119			$sql = implode(', ', $columns);
120			}
121
122			return $sql;
123			}
124
125			/**
126			* Composes the column
127			* @param Column $column
128			* @param string $action
129			* @return string
130			*/
131			protected function composeColumn(Column $column, string $action = null): string
132			{
133			return
134			$this->columnAttrSql($column->get(Column::NAME), '`', '`') .
135			$this->columnAttrSql($column->get(Column::NEW_NAME), ' TO `', '`') .
136			$this->columnAttrSql($column->get(Column::TYPE), ' ') .
137			$this->columnAttrSql($column->get(Column::CONSTRAINT), '(', ')') .
138			$this->columnAttrSql($column->get(Column::ATTRIBUTE), ' ') .
139			$this->columnAttrSql($column->get(Column::NULLABLE, $action), ' ',) .
140			$this->columnAttrSql($column->get(Column::DEFAULT), ' DEFAULT ' . ($column->defaultQuoted() ? '\'' : ''), ($column->defaultQuoted() ? '\'' : '')) .
141			$this->columnAttrSql($column->get(Column::COMMENT), ' COMMENT \'', '\'') .
142			$this->columnAttrSql($column->get(Column::AFTER), ' AFTER `', '`') .
143			$this->columnAttrSql($column->get(Column::AUTO_INCREMENT), ' ');
144			}
145
146			/**
147			* Prepares column attributes
148			* @param string\|null $definition
149			* @param string $before
150			* @param string $after
151			* @return string
152			*/
153			protected function columnAttrSql(?string $definition, string $before = '', string $after = ''): string
154			{
155			$sql = '';
156
157			if (!is_null($definition)) {
158			$sql .= $before . $definition . $after;
159			}
160
161			return $sql;
162			}
163
164			/**
165			* Prepares statement for primary key
166			* @return string
167			*/
168			protected function primaryKeysSql(): string
169			{
170			$sql = '';
171
172			if (isset($this->indexKeys['primary'])) {
173			$sql .= ($this->action == self::ALTER ? 'ADD ' : '');
			0 ignored issues – show Bug introduced 2022-05-17 08:57 UTC by Report Bug Copy Issue Report The constant `Quantum\Libraries\Databa...ema\TableBuilder::ALTER` was not found. Maybe you did not declare it correctly or list all dependencies? Loading history...
174
175			$sql .= 'PRIMARY KEY (';
176
177			foreach ($this->indexKeys['primary'] as $key => $primaryKey) {
178			$sql .= '`' . $primaryKey['columnName'] . '`';
179			$sql .= (array_key_last($this->indexKeys['primary']) != $key ? ', ' : '');
180			}
181
182			$sql .= ')';
183			}
184
185			return $sql;
186			}
187
188			/**
189			* Prepares statement for index keys
190			* @param string $type
191			* @return string
192			*/
193			protected function indexKeysSql(string $type): string
194			{
195			$sql = '';
196
197			if (isset($this->indexKeys[$type])) {
198			$indexes = [];
199
200			foreach ($this->indexKeys[$type] as $key => $indexKey) {
201			$indexString = '';
202
203			$indexString .= ($this->action == self::ALTER ? 'ADD ' : '');
			0 ignored issues – show Bug introduced 2022-05-17 08:57 UTC by Report Bug Copy Issue Report The constant `Quantum\Libraries\Databa...ema\TableBuilder::ALTER` was not found. Maybe you did not declare it correctly or list all dependencies? Loading history...
204			$indexString .= strtoupper($type);
205			$indexString .= ($indexKey['indexName'] ? ' `' . $indexKey['indexName'] . '`' : '');
206			$indexString .= ' (`' . $indexKey['columnName'] . '`)';
207
208			array_push($indexes, $indexString);
209			}
210
211			$sql = implode(', ', $indexes);
212			}
213
214			return $sql;
215			}
216
217			/**
218			* Builds a complete statement for index keys
219			* @return string
220			*/
221			protected function indexesSql(): string
222			{
223			return $this->primaryKeysSql() .
224			$this->indexKeysSql(Key::INDEX) .
225			$this->indexKeysSql(Key::UNIQUE) .
226			$this->indexKeysSql(Key::FULLTEXT) .
227			$this->indexKeysSql(Key::SPATIAL);
228			}
229
230			/**
231			* Builds a statement for drop indexes
232			* @return string
233			*/
234			protected function dropIndexesSql()
235			{
236			$sql = '';
237
238			if (!empty($this->droppedIndexKeys)) {
239			$indexes = [];
240
241			foreach ($this->droppedIndexKeys as $index) {
242			$indexes[] = 'DROP INDEX `' . $index . '`';
243			}
244
245			$sql .= implode(', ', $indexes);
246			}
247
248			return $sql;
249			}
250
251			}
252

softberg / quantum-php-core

Pull Request — master (#65)

TableBuilder::columnsSql() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like