SQL::getAggregateFieldOptions() - Code Metrics - Divergence/framework - Measure and Improve Code Quality continuously with Scrutinizer

SQL::getAggregateFieldOptions() A
last analyzed 2024-09-11 11:06 UTC

↳ Parent: SQL

Complexity

Conditions	3
Paths	4

Size

Total Lines	10
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	3

Importance

Changes

Metric	Value
cc	3
eloc	6
c	0
b	0
f	0
nc	4
nop	2
dl	0
loc	10
ccs	6
cts	6
cp	1
crap	3
rs	10

<?php
/**
 * This file is part of the Divergence package.
 *
 * (c) Henry Paradiz <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Divergence\IO\Database;

use Exception;

/**
 * SQL.
 * @package Divergence
 * @author  Henry Paradiz <[email protected]>
 * @author  Chris Alfano <[email protected]>
 *
 */
class SQL
{
    protected static $aggregateFieldConfigs;

    /**
     * This is how MySQL escapes it's string under the hood.
     * Keep it. We don't need a database connection to escape strings.
     *
     * @param string $str String to escape.
     * @return string Escaped string.
     */
    public static function escape($str)
    {
        return str_replace(
            ["\\",  "\x00", "\n",  "\r",  "'",  '"', "\x1a"],
            ["\\\\","\\0","\\n", "\\r", "\'", '\"', "\\Z"],
            $str
        );
    }

    public static function compileFields($recordClass, $historyVariant = false)
    {
        $queryString = [];
        $fields = static::getAggregateFieldOptions($recordClass);

        foreach ($fields as $fieldId => $field) {
            if ($field['columnName'] == 'RevisionID') {
                continue;
            }

            $queryString[] = static::getFieldDefinition($recordClass, $fieldId, $historyVariant);

            if (!empty($field['primary'])) {
                if ($historyVariant) {
                    $queryString[] = 'KEY `'.$field['columnName'].'` (`'.$field['columnName'].'`)';
                } else {
                    $queryString[] = 'PRIMARY KEY (`'.$field['columnName'].'`)';
                }
            }

            if (!empty($field['unique']) && !$historyVariant) {
                $queryString[] = 'UNIQUE KEY `'.$field['columnName'].'` (`'.$field['columnName'].'`)';
            }

            if (!empty($field['index']) && !$historyVariant) {
                $queryString[] = 'KEY `'.$field['columnName'].'` (`'.$field['columnName'].'`)';
            }
        }

        return $queryString;
    }

    public static function getFullTextColumns($recordClass)
    {
        $fulltextColumns = [];
        $fields = static::getAggregateFieldOptions($recordClass);

        foreach ($fields as $fieldId => $field) {
            if ($field['columnName'] == 'RevisionID') {
                continue;
            }

            if (!empty($field['fulltext'])) {
                $fulltextColumns[] = $field['columnName'];
            }
        }

        return $fulltextColumns;
    }

    public static function getContextIndex($recordClass)
    {
        return 'KEY `CONTEXT` (`'.$recordClass::getColumnName('ContextClass').'`,`'.$recordClass::getColumnName('ContextID').'`)';
    }

    /**
     * Generates a MySQL create table query from a Divergence\Models\ActiveRecord class.
     *
     * @param string $recordClass Class name
     * @param boolean $historyVariant
     * @return string
     */
    public static function getCreateTable($recordClass, $historyVariant = false)
    {
        $indexes = $historyVariant ? [] : $recordClass::$indexes;

        $fulltextColumns = [];
        $queryString = [];


        // history table revisionID field
        if ($historyVariant) {
            $queryString[] = '`RevisionID` int(10) unsigned NOT NULL auto_increment';
            $queryString[] = 'PRIMARY KEY (`RevisionID`)';
        }

        $queryString = array_merge($queryString, static::compileFields($recordClass, $historyVariant));

        if (!$historyVariant) {
            // If ContextClass && ContextID are members of this model let's index them
            if ($recordClass::fieldExists('ContextClass') && $recordClass::fieldExists('ContextID')) {
                $queryString[] = static::getContextIndex($recordClass);
            }

            $fulltextColumns = static::getFullTextColumns($recordClass);
        }

        // compile indexes
        foreach ($indexes as $indexName => $index) {

            // translate field names
            foreach ($index['fields'] as &$indexField) {
                $indexField = $recordClass::getColumnName($indexField);
            }

            if (!empty($index['fulltext'])) {
                $fulltextColumns = array_unique(array_merge($fulltextColumns, $index['fields']));
                continue;
            }

            $queryString[] = sprintf(
                '%s KEY `%s` (`%s`)',
                !empty($index['unique']) ? 'UNIQUE' : '',
                $indexName,
                join('`,`', $index['fields'])
            );
        }

        if (!empty($fulltextColumns)) {
            $queryString[] = 'FULLTEXT KEY `FULLTEXT` (`'.join('`,`', $fulltextColumns).'`)';
        }


        $createSQL = sprintf(
            "CREATE TABLE IF NOT EXISTS `%s` (\n\t%s\n) ENGINE=MyISAM DEFAULT CHARSET=utf8;",
            $historyVariant ? $recordClass::getHistoryTable() : $recordClass::$tableName,

            join("\n\t,", $queryString)
        );

        // append history table SQL
        if (!$historyVariant && is_subclass_of($recordClass, 'VersionedRecord')) {
            $createSQL .= PHP_EOL.PHP_EOL.PHP_EOL.static::getCreateTable($recordClass, true);
        }
        return $createSQL;
    }

    public static function getSQLType($field)
    {
        switch ($field['type']) {
            case 'boolean':
                return 'boolean';
            case 'tinyint':
            case 'smallint':
            case 'mediumint':
            case 'bigint':
                return $field['type'].($field['unsigned'] ? ' unsigned' : '').($field['zerofill'] ? ' zerofill' : '');
            case 'uint':
                $field['unsigned'] = true;
                // no break
            case 'int':
            case 'integer':
                return 'int'.($field['unsigned'] ? ' unsigned' : '').(!empty($field['zerofill']) ? ' zerofill' : '');
            case 'decimal':
                return sprintf('decimal(%s,%s)', $field['precision'], $field['scale']);
            case 'float':
                return 'float';
            case 'double':
                return 'double';

            case 'password':
            case 'string':
            case 'varchar':
            case 'list':
                return sprintf(!$field['length'] || $field['type'] == 'varchar' ? 'varchar(%u)' : 'char(%u)', $field['length'] ? $field['length'] : 255);
            case 'clob':
            case 'serialized':
            case 'json':
                return 'text';
            case 'blob':
                return 'blob';
            case 'binary':
                return sprintf('binary(%s)', isset($field['length']) ? $field['length'] : 1);

            case 'timestamp':
                return 'timestamp';
            case 'datetime':
                return 'datetime';
            case 'time':
                return 'time';
            case 'date':
                return 'date';
            case 'year':
                return 'year';

            case 'enum':
                return sprintf('enum("%s")', join('","', array_map([static::class,'escape'], $field['values'])));

            case 'set':
                return sprintf('set("%s")', join('","', array_map([static::class,'escape'], $field['values'])));

            default:
                throw new Exception("getSQLType: unhandled type $field[type]");
        }
    }

    public static function getFieldDefinition($recordClass, $fieldName, $historyVariant = false)
    {
        $field = static::getAggregateFieldOptions($recordClass, $fieldName);
        $rootClass = $recordClass::$rootClass;

        // force notnull=false on non-rootclass fields
        if ($rootClass && !$rootClass::fieldExists($fieldName)) {
            $field['notnull'] = false;
        }

        // auto-prepend class type
        if ($field['columnName'] == 'Class' && $field['type'] == 'enum' && !in_array($rootClass, $field['values']) && !count($rootClass::getStaticSubClasses())) {
            array_unshift($field['values'], $rootClass);
        }

        $fieldDef = '`'.$field['columnName'].'`';
        $fieldDef .= ' '.static::getSQLType($field);

        if (!empty($field['charset'])) {
            $fieldDef .= " CHARACTER SET $field[charset]";
        }

        if (!empty($field['collate'])) {
            $fieldDef .= " COLLATE $field[collate]";
        }

        $fieldDef .= ' '.($field['notnull'] ? 'NOT NULL' : 'NULL');

        if ($field['autoincrement'] && !$historyVariant) {
            $fieldDef .= ' auto_increment';
        } elseif (($field['type'] == 'timestamp') && ($field['default'] == 'CURRENT_TIMESTAMP')) {
            $fieldDef .= ' default CURRENT_TIMESTAMP';
        } elseif (empty($field['notnull']) && ($field['default'] == null)) {
            $fieldDef .= ' default NULL';
        } elseif (isset($field['default'])) {
            if ($field['type'] == 'boolean') {
                $fieldDef .= ' default '.($field['default'] ? 1 : 0);
            } else {
                $fieldDef .= ' default "'.static::escape($field['default']).'"';
            }
        }

        return $fieldDef;
    }

    protected static function getAggregateFieldOptions($recordClass, $field = null)
    {
        if (!isset(static::$aggregateFieldConfigs[$recordClass])) {
            static::$aggregateFieldConfigs[$recordClass] = $recordClass::getClassFields();
        }

        if ($field) {
            return static::$aggregateFieldConfigs[$recordClass][$field];
        } else {
            return static::$aggregateFieldConfigs[$recordClass];
        }
    }
}


1		<?php
2		/**
3		* This file is part of the Divergence package.
4		*
5		* (c) Henry Paradiz <[email protected]>
6		*
7		* For the full copyright and license information, please view the LICENSE
8		* file that was distributed with this source code.
9		*/
10
11		namespace Divergence\IO\Database;
12
13		use Exception;
14
15		/**
16		* SQL.
17		* @package Divergence
18		* @author Henry Paradiz <[email protected]>
19		* @author Chris Alfano <[email protected]>
20		*
21		*/
22		class SQL
23		{
24		protected static $aggregateFieldConfigs;
25
26		/**
27		* This is how MySQL escapes it's string under the hood.
28		* Keep it. We don't need a database connection to escape strings.
29		*
30		* @param string $str String to escape.
31		* @return string Escaped string.
32		*/
33	5	public static function escape($str)
34		{
35	5	return str_replace(
36	5	["\\", "\x00", "\n", "\r", "'", '"', "\x1a"],
37	5	["\\\\","\\0","\\n", "\\r", "\'", '\"', "\\Z"],
38	5	$str
39	5	);
40		}
41
42	4	public static function compileFields($recordClass, $historyVariant = false)
43		{
44	4	$queryString = [];
45	4	$fields = static::getAggregateFieldOptions($recordClass);
46
47	4	foreach ($fields as $fieldId => $field) {
48	4	if ($field['columnName'] == 'RevisionID') {
49	3	continue;
50		}
51
52	4	$queryString[] = static::getFieldDefinition($recordClass, $fieldId, $historyVariant);
53
54	4	if (!empty($field['primary'])) {
55	4	if ($historyVariant) {
56	2	$queryString[] = 'KEY `'.$field['columnName'].'` (`'.$field['columnName'].'`)';
57		} else {
58	3	$queryString[] = 'PRIMARY KEY (`'.$field['columnName'].'`)';
59		}
60		}
61
62	4	if (!empty($field['unique']) && !$historyVariant) {
63		$queryString[] = 'UNIQUE KEY `'.$field['columnName'].'` (`'.$field['columnName'].'`)';
64		}
65
66	4	if (!empty($field['index']) && !$historyVariant) {
67		$queryString[] = 'KEY `'.$field['columnName'].'` (`'.$field['columnName'].'`)';
68		}
69		}
70
71	4	return $queryString;
72		}
73
74	3	public static function getFullTextColumns($recordClass)
75		{
76	3	$fulltextColumns = [];
77	3	$fields = static::getAggregateFieldOptions($recordClass);
78
79	3	foreach ($fields as $fieldId => $field) {
80	3	if ($field['columnName'] == 'RevisionID') {
81	2	continue;
82		}
83
84	3	if (!empty($field['fulltext'])) {
85		$fulltextColumns[] = $field['columnName'];
86		}
87		}
88
89	3	return $fulltextColumns;
90		}
91
92	3	public static function getContextIndex($recordClass)
93		{
94	3	return 'KEY `CONTEXT` (`'.$recordClass::getColumnName('ContextClass').'`,`'.$recordClass::getColumnName('ContextID').'`)';
95		}
96
97		/**
98		* Generates a MySQL create table query from a Divergence\Models\ActiveRecord class.
99		*
100		* @param string $recordClass Class name
101		* @param boolean $historyVariant
102		* @return string
103		*/
104	4	public static function getCreateTable($recordClass, $historyVariant = false)
105		{
106	4	$indexes = $historyVariant ? [] : $recordClass::$indexes;
		0 ignored issues – show Bug introduced 2018-06-01 01:35 UTC by Report Bug Copy Issue Report The property `indexes` does not exist on `string`. Loading history...
107	4	$fulltextColumns = [];
108	4	$queryString = [];
109
110
111		// history table revisionID field
112	4	if ($historyVariant) {
113	2	$queryString[] = '`RevisionID` int(10) unsigned NOT NULL auto_increment';
114	2	$queryString[] = 'PRIMARY KEY (`RevisionID`)';
115		}
116
117	4	$queryString = array_merge($queryString, static::compileFields($recordClass, $historyVariant));
118
119	4	if (!$historyVariant) {
120		// If ContextClass && ContextID are members of this model let's index them
121	3	if ($recordClass::fieldExists('ContextClass') && $recordClass::fieldExists('ContextID')) {
122	3	$queryString[] = static::getContextIndex($recordClass);
123		}
124
125	3	$fulltextColumns = static::getFullTextColumns($recordClass);
126		}
127
128		// compile indexes
129	4	foreach ($indexes as $indexName => $index) {
130
131		// translate field names
132	2	foreach ($index['fields'] as &$indexField) {
133	2	$indexField = $recordClass::getColumnName($indexField);
134		}
135
136	2	if (!empty($index['fulltext'])) {
137		$fulltextColumns = array_unique(array_merge($fulltextColumns, $index['fields']));
138		continue;
139		}
140
141	2	$queryString[] = sprintf(
142	2	'%s KEY `%s` (`%s`)',
143	2	!empty($index['unique']) ? 'UNIQUE' : '',
144	2	$indexName,
145	2	join('`,`', $index['fields'])
146	2	);
147		}
148
149	4	if (!empty($fulltextColumns)) {
150		$queryString[] = 'FULLTEXT KEY `FULLTEXT` (`'.join('`,`', $fulltextColumns).'`)';
151		}
152
153
154	4	$createSQL = sprintf(
155	4	"CREATE TABLE IF NOT EXISTS `%s` (\n\t%s\n) ENGINE=MyISAM DEFAULT CHARSET=utf8;",
156	4	$historyVariant ? $recordClass::getHistoryTable() : $recordClass::$tableName,
		0 ignored issues – show Bug introduced 2018-06-01 01:35 UTC by Report Bug Copy Issue Report The property `tableName` does not exist on `string`. Loading history...
157	4	join("\n\t,", $queryString)
158	4	);
159
160		// append history table SQL
161	4	if (!$historyVariant && is_subclass_of($recordClass, 'VersionedRecord')) {
162		$createSQL .= PHP_EOL.PHP_EOL.PHP_EOL.static::getCreateTable($recordClass, true);
163		}
164	4	return $createSQL;
165		}
166
167	4	public static function getSQLType($field)
168		{
169	4	switch ($field['type']) {
170	4	case 'boolean':
171	3	return 'boolean';
172	4	case 'tinyint':
173	4	case 'smallint':
174	4	case 'mediumint':
175	4	case 'bigint':
176		return $field['type'].($field['unsigned'] ? ' unsigned' : '').($field['zerofill'] ? ' zerofill' : '');
177	4	case 'uint':
178	3	$field['unsigned'] = true;
179		// no break
180	4	case 'int':
181	4	case 'integer':
182	4	return 'int'.($field['unsigned'] ? ' unsigned' : '').(!empty($field['zerofill']) ? ' zerofill' : '');
183	4	case 'decimal':
184	4	return sprintf('decimal(%s,%s)', $field['precision'], $field['scale']);
185	4	case 'float':
186	3	return 'float';
187	4	case 'double':
188		return 'double';
189
190	4	case 'password':
191	4	case 'string':
192	4	case 'varchar':
193	4	case 'list':
194	4	return sprintf(!$field['length'] \|\| $field['type'] == 'varchar' ? 'varchar(%u)' : 'char(%u)', $field['length'] ? $field['length'] : 255);
195	4	case 'clob':
196	4	case 'serialized':
197	4	case 'json':
198	3	return 'text';
199	4	case 'blob':
200		return 'blob';
201	4	case 'binary':
202		return sprintf('binary(%s)', isset($field['length']) ? $field['length'] : 1);
203
204	4	case 'timestamp':
205	4	return 'timestamp';
206	4	case 'datetime':
207		return 'datetime';
208	4	case 'time':
209		return 'time';
210	4	case 'date':
211	3	return 'date';
212	4	case 'year':
213		return 'year';
214
215	4	case 'enum':
216	4	return sprintf('enum("%s")', join('","', array_map([static::class,'escape'], $field['values'])));
217
218	3	case 'set':
219	3	return sprintf('set("%s")', join('","', array_map([static::class,'escape'], $field['values'])));
220
221		default:
222		throw new Exception("getSQLType: unhandled type $field[type]");
223		}
224		}
225
226	4	public static function getFieldDefinition($recordClass, $fieldName, $historyVariant = false)
227		{
228	4	$field = static::getAggregateFieldOptions($recordClass, $fieldName);
229	4	$rootClass = $recordClass::$rootClass;
230
231		// force notnull=false on non-rootclass fields
232	4	if ($rootClass && !$rootClass::fieldExists($fieldName)) {
233		$field['notnull'] = false;
234		}
235
236		// auto-prepend class type
237	4	if ($field['columnName'] == 'Class' && $field['type'] == 'enum' && !in_array($rootClass, $field['values']) && !count($rootClass::getStaticSubClasses())) {
238		array_unshift($field['values'], $rootClass);
239		}
240
241	4	$fieldDef = '`'.$field['columnName'].'`';
242	4	$fieldDef .= ' '.static::getSQLType($field);
243
244	4	if (!empty($field['charset'])) {
245		$fieldDef .= " CHARACTER SET $field[charset]";
246		}
247
248	4	if (!empty($field['collate'])) {
249		$fieldDef .= " COLLATE $field[collate]";
250		}
251
252	4	$fieldDef .= ' '.($field['notnull'] ? 'NOT NULL' : 'NULL');
253
254	4	if ($field['autoincrement'] && !$historyVariant) {
255	3	$fieldDef .= ' auto_increment';
256	4	} elseif (($field['type'] == 'timestamp') && ($field['default'] == 'CURRENT_TIMESTAMP')) {
257	4	$fieldDef .= ' default CURRENT_TIMESTAMP';
258	4	} elseif (empty($field['notnull']) && ($field['default'] == null)) {
259	4	$fieldDef .= ' default NULL';
260	4	} elseif (isset($field['default'])) {
261	3	if ($field['type'] == 'boolean') {
262	3	$fieldDef .= ' default '.($field['default'] ? 1 : 0);
263		} else {
264	3	$fieldDef .= ' default "'.static::escape($field['default']).'"';
265		}
266		}
267
268	4	return $fieldDef;
269		}
270
271	4	protected static function getAggregateFieldOptions($recordClass, $field = null)
272		{
273	4	if (!isset(static::$aggregateFieldConfigs[$recordClass])) {
274	2	static::$aggregateFieldConfigs[$recordClass] = $recordClass::getClassFields();
275		}
276
277	4	if ($field) {
278	4	return static::$aggregateFieldConfigs[$recordClass][$field];
279		} else {
280	4	return static::$aggregateFieldConfigs[$recordClass];
281		}
282		}
283		}
284

Divergence / framework

SQL::getAggregateFieldOptions() A last analyzed 2024-09-11 11:06 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

SQL::getAggregateFieldOptions() A
last analyzed 2024-09-11 11:06 UTC