QuickInsertRepository::buildExtra() - Code Metrics - Inspection of "update extensions" - ozo2003/HelperBundle - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Branch — master (c65ffc)

by Dāvis

created 2017-10-23 13:21 UTC

QuickInsertRepository::buildExtra() C

↳ Parent: QuickInsertRepository

Complexity

Conditions	8
Paths	16

Size

Total Lines	38
Code Lines	24

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	8
eloc	24
c	0
b	0
f	0
nc	16
nop	1
dl	0
loc	38
rs	5.3846

<?php

namespace Sludio\HelperBundle\Script\Repository;

class QuickInsertRepository
{
    private static $mock = [];
    private static $metadata = [];
    private static $tableName;

    public static $entityManager;
    public static $connection;

    public static function init($noFkCheck = false, $manager = null)
    {
        if (self::$connection) {
            return;
        }
        global $kernel;

        if ('AppCache' === get_class($kernel)) {
            $kernel = $kernel->getKernel();
        }
        $container = $kernel->getContainer();

        $manager = $manager ?: $container->getParameter('sludio_helper.entity.manager');
        self::$entityManager = $container->get('doctrine')->getManager($manager);
        self::$connection = self::$entityManager->getConnection();

        if (!$noFkCheck) {
            self::runSQL('SET FOREIGN_KEY_CHECKS = 0');
        }
    }

    public static function close($noFkCheck = false)
    {
        if (!$noFkCheck) {
            self::runSQL('SET FOREIGN_KEY_CHECKS = 1');
        }
    }

    public static function isEmpty($variable)
    {
        $result = true;

        if (is_array($variable) && count($variable) > 0) {
            foreach ($variable as $value) {
                $result = $result && self::isEmpty($value);
            }
        } else {
            $result = empty($variable);
        }

        return $result;
    }

    private static function extract($object)
    {
        self::init(false);
        $data = self::extractExt($object, self::$entityManager);

        self::$mock = $data['mock'];
        self::$tableName = $data['table'];
        self::$metadata[$data['table']] = $data['meta'];
    }

    public static function extractExt($object, $entityManager)
    {
        $metadata = $entityManager->getClassMetadata(get_class($object));

        $fields = $metadata->getFieldNames();
        $columns = $metadata->getColumnNames();
        $table = $metadata->getTableName();

        $result = [];
        foreach ($fields as $key => $field) {
            foreach ($columns as $key2 => $column) {
                if ($key === $key2) {
                    $result[$table][$field] = $column;
                }
            }
        }

        $data = [
            'mock' => $result,
            'table' => $table,
            'meta' => $metadata,
        ];

        return $data;
    }

    private static function buildExtra($extra)
    {
        $methods = [
            'GROUP BY',
            'HAVING',
            'ORDER BY',
        ];
        $sql = '';

        foreach ($methods as $method) {
            if (isset($extra[$method])) {
                $sql .= ' '.$method.' ';
                if (is_array($extra[$method])) {
                    foreach ($extra[$method] as $group) {
                        $sql .= $group.' ';
                    }
                } else {
                    $sql .= $extra[$method].' ';
                }
            }
        }

        if (isset($extra['LIMIT'])) {
            if (is_array($extra['LIMIT'])) {
                if (isset($extra['LIMIT'][1])) {
                    $offset = $extra['LIMIT'][0];
                    $limit = $extra['LIMIT'][1];
                } else {
                    $offset = 0;
                    $limit = $extra['LIMIT'][0];
                }
                $sql .= 'LIMIT '.$offset.', '.$limit;
            }
        }

        $sql = str_replace('  ', ' ', $sql);

        return $sql;
    }

    private static function buildWhere($tableName, $where)
    {
        $whereSql = '';
        if (is_array($where) && !empty($where)) {
            reset($where);
            $first = key($where);
            $path = ' WHERE ';
            foreach ($where as $key => $value) {
                if (!is_array($value) && isset(self::$mock[$tableName][$key])) {
                    $whereSql .= $path.self::$mock[$tableName][$key]." = ".(is_numeric($value) ? $value : "'".addslashes(trim($value))."'");
                } else {
                    if (is_array($value)) {
                        $whereSql .= $path.$value[0];
                    } else {
                        $whereSql .= $path.$key." = ".(is_numeric($value) ? $value : "'".addslashes(trim($value))."'");
                    }
                }
                if ($key === $first) {
                    $path = ' AND ';
                }
            }
        }

        return $whereSql;
    }

    private static function getTable(&$object, &$tableName, &$columns, &$type, $noFkCheck = true, $manager = null)
    {
        self::init($noFkCheck, $manager);
        if (is_object($object)) {
            self::extract($object);
            $tableName = self::$tableName;
            $columns = self::$mock[$tableName] ?: [];
            $type = 'object';
        } else {
            $tableName = $object['table_name'];
            unset($object['table_name']);
            $type = 'table';
            $columns = array_keys($object) ?: [];
        }
    }

    public static function findNextId($tableName)
    {
        $result = self::get(['table_name' => 'information_schema.tables'], true, [
            'table_name' => $tableName,
            ['table_schema = DATABASE()'],
        ], true, ['AUTO_INCREMENT'], null, []);

        if ($result) {
            return $result;
        }

        return 1;
    }

    public static function findNextIdExt($object, $entityManager = null)
    {
        self::init(true);
        $data = self::extractExt($object, $entityManager);

        return self::findNextId($data['table']);
    }

    public static function runSQL($sql, $noFkCheck = true, $manager = null)
    {
        $sql = trim(preg_replace('/\s+/', ' ', $sql));
        self::init($noFkCheck, $manager);
        $sth = self::$connection->prepare($sql);
        $sth->execute();

        self::close($noFkCheck);
        if (substr($sql, 0, 6) === "SELECT") {
            return $sth->fetchAll();
        }
    }

    public static function get($object, $one = false, $where = [], $noFkCheck = true, $fields = [], $manager = null, $extra = [])
    {
        self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);

        $select = (isset($extra['MODE']) ? 'SELECT '.$extra['MODE'] : 'SELECT').' ';
        $fields = $fields ?: ['id'];
        $sql = $select.(implode(', ', $fields)).' FROM '.$tableName.self::buildWhere($tableName, $where).self::buildExtra($extra);

        $result = self::runSQL($sql) ?: null;

        if ($result) {
            $field = null;
            if (count($fields) === 1 && $fields[0] !== '*') {
                $field = $fields[0];
            }
            if ($field) {
                if (!$one) {
                    foreach ($result as &$res) {
                        $res = $res[$field];
                    }
                } else {
                    $result = $result[0][$field];
                }
            } elseif ($one) {
                $result = $result[0];
            }
        }

        return $result;
    }

    private static function variable(&$value)
    {
        if ($value instanceof \DateTime) {
            $value = "'".addslashes(trim($value->format('Y-m-d H:i:s')))."'";
        } elseif (!is_numeric($value)) {
            $value = "'".addslashes(trim($value))."'";
        }

        if (trim($value) === '' || trim($value) === "''") {
            $value = null;
        }
    }

    private static function value($object, $variable, $type, $check = true)
    {
        $value = null;
        if ($type === 'object') {

            $variables = explode('_', $variable);
            foreach ($variables as &$var) {
                $var = ucfirst($var);
            }
            $variable = implode('', $variables);

            $value = $object->{'get'.ucfirst($variable)}();
        } else {
            if (isset($object[$variable])) {
                $value = $object[$variable];
            }
        }

        if ($check) {
            self::variable($value);
        }

        return $value;
    }

    public static function persist($object, $full = false, $extraFields = [], $noFkCheck = false, $manager = null)
    {
        self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);

        $id = self::findNextId($tableName);
        $data = [];

        if (!empty($extraFields) && isset($extraFields[$tableName])) {

            $columns = array_merge($columns, $extraFields[$tableName]);
        }

        $idd = null;
        foreach ($columns as $value => $key) {
            if (!is_array($key) && !is_array($value)) {
                $value = self::value($object, $value, $type);
                if ($value !== null) {
                    $data[$key] = $value;
                    if ($key === 'id') {
                        $idd = $value;
                    }
                }
            }
        }

        $sql = null;
        if (!$full) {
            $data['id'] = $id;
        } else {
            $id = $idd;
        }

        if (!self::isEmpty($data)) {
            $sql = '
                INSERT INTO
                    '.$tableName.'
                        ('.implode(',', array_keys($data)).')
                VALUES
                    ('.implode(',', array_values($data)).')
            ';
        } else {
            $id = null;
        }

        if ($sql !== null && $id !== null) {
            self::runSQL($sql);
        }

        return $id;
    }

    public static function update($id, $object, $extraFields = [], $noFkCheck = false, $manager = null)
    {
        self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);

        $result = self::get(['table_name' => $tableName], true, ['id' => $id], true, ['*']);
        unset($result['id']);

        $data = [];

        if (!empty($extraFields) && isset($extraFields[$tableName])) {

            $columns = array_merge($columns, $extraFields[$tableName]);
        }

        $flip = array_flip($columns);
        foreach ($result as $key => $value) {
            $content = self::value($object, $key, $type, false);
            if ($content !== $value) {
                $data[$key] = $content;
            }
            if (!$id && $content === null) {
                unset($data[$key]);
            }
        }

        if ($data) {
            $sql = '
                UPDATE
                    '.$tableName.'
                SET

            ';
            foreach ($data as $key => $value) {
                $meta = self::$metadata[$tableName]->getFieldMapping($flip[$key])['type'];
                if (in_array($meta, [
                    'boolean',
                    'integer',
                    'longint',
                ])) {
                    $value = intval($value);
                } else {
                    $value = "'".addslashes(trim($value))."'";
                }
                $sql .= " ".$key." = ".$value.",";
            }
            $sql = substr($sql, 0, -1).' WHERE id = '.$id;

            self::runSQL($sql);
        }
    }

    public static function delete($object, $where = [], $noFkCheck = false, $manager = null)

    {
        self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);

        $sql = 'DELETE FROM '.$tableName.self::buildWhere($tableName, $where);
        self::runSQL($sql);
    }

    public static function link($object, $data, $noFkCheck = false, $manager = null)

    {
        self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);

        $data['table_name'] = $tableName;
        self::persist($data, true, [], $noFkCheck, $manager);
    }
}


1		<?php
2
3		namespace Sludio\HelperBundle\Script\Repository;
4
5		class QuickInsertRepository
6		{
7		private static $mock = [];
8		private static $metadata = [];
9		private static $tableName;
10
11		public static $entityManager;
12		public static $connection;
13
14		public static function init($noFkCheck = false, $manager = null)
15		{
16		if (self::$connection) {
17		return;
18		}
19		global $kernel;
20
21		if ('AppCache' === get_class($kernel)) {
22		$kernel = $kernel->getKernel();
23		}
24		$container = $kernel->getContainer();
25
26		$manager = $manager ?: $container->getParameter('sludio_helper.entity.manager');
27		self::$entityManager = $container->get('doctrine')->getManager($manager);
28		self::$connection = self::$entityManager->getConnection();
29
30		if (!$noFkCheck) {
31		self::runSQL('SET FOREIGN_KEY_CHECKS = 0');
32		}
33		}
34
35		public static function close($noFkCheck = false)
36		{
37		if (!$noFkCheck) {
38		self::runSQL('SET FOREIGN_KEY_CHECKS = 1');
39		}
40		}
41
42		public static function isEmpty($variable)
43		{
44		$result = true;
45
46		if (is_array($variable) && count($variable) > 0) {
47		foreach ($variable as $value) {
48		$result = $result && self::isEmpty($value);
49		}
50		} else {
51		$result = empty($variable);
52		}
53
54		return $result;
55		}
56
57		private static function extract($object)
58		{
59		self::init(false);
60		$data = self::extractExt($object, self::$entityManager);
61
62		self::$mock = $data['mock'];
63		self::$tableName = $data['table'];
64		self::$metadata[$data['table']] = $data['meta'];
65		}
66
67		public static function extractExt($object, $entityManager)
68		{
69		$metadata = $entityManager->getClassMetadata(get_class($object));
70
71		$fields = $metadata->getFieldNames();
72		$columns = $metadata->getColumnNames();
73		$table = $metadata->getTableName();
74
75		$result = [];
76		foreach ($fields as $key => $field) {
77		foreach ($columns as $key2 => $column) {
78		if ($key === $key2) {
79		$result[$table][$field] = $column;
80		}
81		}
82		}
83
84		$data = [
85		'mock' => $result,
86		'table' => $table,
87		'meta' => $metadata,
88		];
89
90		return $data;
91		}
92
93		private static function buildExtra($extra)
94		{
95		$methods = [
96		'GROUP BY',
97		'HAVING',
98		'ORDER BY',
99		];
100		$sql = '';
101
102		foreach ($methods as $method) {
103		if (isset($extra[$method])) {
104		$sql .= ' '.$method.' ';
105		if (is_array($extra[$method])) {
106		foreach ($extra[$method] as $group) {
107		$sql .= $group.' ';
108		}
109		} else {
110		$sql .= $extra[$method].' ';
111		}
112		}
113		}
114
115		if (isset($extra['LIMIT'])) {
116		if (is_array($extra['LIMIT'])) {
117		if (isset($extra['LIMIT'][1])) {
118		$offset = $extra['LIMIT'][0];
119		$limit = $extra['LIMIT'][1];
120		} else {
121		$offset = 0;
122		$limit = $extra['LIMIT'][0];
123		}
124		$sql .= 'LIMIT '.$offset.', '.$limit;
125		}
126		}
127
128		$sql = str_replace(' ', ' ', $sql);
129
130		return $sql;
131		}
132
133		private static function buildWhere($tableName, $where)
134		{
135		$whereSql = '';
136		if (is_array($where) && !empty($where)) {
137		reset($where);
138		$first = key($where);
139		$path = ' WHERE ';
140		foreach ($where as $key => $value) {
141		if (!is_array($value) && isset(self::$mock[$tableName][$key])) {
142		$whereSql .= $path.self::$mock[$tableName][$key]." = ".(is_numeric($value) ? $value : "'".addslashes(trim($value))."'");
143		} else {
144		if (is_array($value)) {
145		$whereSql .= $path.$value[0];
146		} else {
147		$whereSql .= $path.$key." = ".(is_numeric($value) ? $value : "'".addslashes(trim($value))."'");
148		}
149		}
150		if ($key === $first) {
151		$path = ' AND ';
152		}
153		}
154		}
155
156		return $whereSql;
157		}
158
159		private static function getTable(&$object, &$tableName, &$columns, &$type, $noFkCheck = true, $manager = null)
160		{
161		self::init($noFkCheck, $manager);
162		if (is_object($object)) {
163		self::extract($object);
164		$tableName = self::$tableName;
165		$columns = self::$mock[$tableName] ?: [];
166		$type = 'object';
167		} else {
168		$tableName = $object['table_name'];
169		unset($object['table_name']);
170		$type = 'table';
171		$columns = array_keys($object) ?: [];
172		}
173		}
174
175		public static function findNextId($tableName)
176		{
177		$result = self::get(['table_name' => 'information_schema.tables'], true, [
178		'table_name' => $tableName,
179		['table_schema = DATABASE()'],
180		], true, ['AUTO_INCREMENT'], null, []);
181
182		if ($result) {
183		return $result;
184		}
185
186		return 1;
187		}
188
189		public static function findNextIdExt($object, $entityManager = null)
190		{
191		self::init(true);
192		$data = self::extractExt($object, $entityManager);
193
194		return self::findNextId($data['table']);
195		}
196
197		public static function runSQL($sql, $noFkCheck = true, $manager = null)
198		{
199		$sql = trim(preg_replace('/\s+/', ' ', $sql));
200		self::init($noFkCheck, $manager);
201		$sth = self::$connection->prepare($sql);
202		$sth->execute();
203
204		self::close($noFkCheck);
205		if (substr($sql, 0, 6) === "SELECT") {
206		return $sth->fetchAll();
207		}
208		}
209
210		public static function get($object, $one = false, $where = [], $noFkCheck = true, $fields = [], $manager = null, $extra = [])
211		{
212		self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);
213
214		$select = (isset($extra['MODE']) ? 'SELECT '.$extra['MODE'] : 'SELECT').' ';
215		$fields = $fields ?: ['id'];
216		$sql = $select.(implode(', ', $fields)).' FROM '.$tableName.self::buildWhere($tableName, $where).self::buildExtra($extra);
217
218		$result = self::runSQL($sql) ?: null;
219
220		if ($result) {
221		$field = null;
222		if (count($fields) === 1 && $fields[0] !== '*') {
223		$field = $fields[0];
224		}
225		if ($field) {
226		if (!$one) {
227		foreach ($result as &$res) {
228		$res = $res[$field];
229		}
230		} else {
231		$result = $result[0][$field];
232		}
233		} elseif ($one) {
234		$result = $result[0];
235		}
236		}
237
238		return $result;
239		}
240
241		private static function variable(&$value)
242		{
243		if ($value instanceof \DateTime) {
244		$value = "'".addslashes(trim($value->format('Y-m-d H:i:s')))."'";
245		} elseif (!is_numeric($value)) {
246		$value = "'".addslashes(trim($value))."'";
247		}
248
249		if (trim($value) === '' \|\| trim($value) === "''") {
250		$value = null;
251		}
252		}
253
254		private static function value($object, $variable, $type, $check = true)
255		{
256		$value = null;
257		if ($type === 'object') {
258
259		$variables = explode('_', $variable);
260		foreach ($variables as &$var) {
261		$var = ucfirst($var);
262		}
263		$variable = implode('', $variables);
264
265		$value = $object->{'get'.ucfirst($variable)}();
266		} else {
267		if (isset($object[$variable])) {
268		$value = $object[$variable];
269		}
270		}
271
272		if ($check) {
273		self::variable($value);
274		}
275
276		return $value;
277		}
278
279		public static function persist($object, $full = false, $extraFields = [], $noFkCheck = false, $manager = null)
280		{
281		self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);
282
283		$id = self::findNextId($tableName);
284		$data = [];
285
286	View Code Duplication	if (!empty($extraFields) && isset($extraFields[$tableName])) {
		0 ignored issues – show Duplication introduced 2017-10-12 11:53 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
287		$columns = array_merge($columns, $extraFields[$tableName]);
288		}
289
290		$idd = null;
291		foreach ($columns as $value => $key) {
292		if (!is_array($key) && !is_array($value)) {
293		$value = self::value($object, $value, $type);
294		if ($value !== null) {
295		$data[$key] = $value;
296		if ($key === 'id') {
297		$idd = $value;
298		}
299		}
300		}
301		}
302
303		$sql = null;
304		if (!$full) {
305		$data['id'] = $id;
306		} else {
307		$id = $idd;
308		}
309
310		if (!self::isEmpty($data)) {
311		$sql = '
312		INSERT INTO
313		'.$tableName.'
314		('.implode(',', array_keys($data)).')
315		VALUES
316		('.implode(',', array_values($data)).')
317		';
318		} else {
319		$id = null;
320		}
321
322		if ($sql !== null && $id !== null) {
323		self::runSQL($sql);
324		}
325
326		return $id;
327		}
328
329		public static function update($id, $object, $extraFields = [], $noFkCheck = false, $manager = null)
330		{
331		self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);
332
333		$result = self::get(['table_name' => $tableName], true, ['id' => $id], true, ['*']);
334		unset($result['id']);
335
336		$data = [];
337
338	View Code Duplication	if (!empty($extraFields) && isset($extraFields[$tableName])) {
		0 ignored issues – show Duplication introduced 2017-10-07 18:41 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
339		$columns = array_merge($columns, $extraFields[$tableName]);
340		}
341
342		$flip = array_flip($columns);
343		foreach ($result as $key => $value) {
344		$content = self::value($object, $key, $type, false);
345		if ($content !== $value) {
346		$data[$key] = $content;
347		}
348		if (!$id && $content === null) {
349		unset($data[$key]);
350		}
351		}
352
353		if ($data) {
354		$sql = '
355		UPDATE
356		'.$tableName.'
357		SET
358
359		';
360		foreach ($data as $key => $value) {
361		$meta = self::$metadata[$tableName]->getFieldMapping($flip[$key])['type'];
362		if (in_array($meta, [
363		'boolean',
364		'integer',
365		'longint',
366		])) {
367		$value = intval($value);
368		} else {
369		$value = "'".addslashes(trim($value))."'";
370		}
371		$sql .= " ".$key." = ".$value.",";
372		}
373		$sql = substr($sql, 0, -1).' WHERE id = '.$id;
374
375		self::runSQL($sql);
376		}
377		}
378
379	View Code Duplication	public static function delete($object, $where = [], $noFkCheck = false, $manager = null)
		0 ignored issues – show Duplication introduced 2017-10-21 01:32 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
380		{
381		self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);
382
383		$sql = 'DELETE FROM '.$tableName.self::buildWhere($tableName, $where);
384		self::runSQL($sql);
385		}
386
387	View Code Duplication	public static function link($object, $data, $noFkCheck = false, $manager = null)
		0 ignored issues – show Duplication introduced 2017-10-21 01:32 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
388		{
389		self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);
390
391		$data['table_name'] = $tableName;
392		self::persist($data, true, [], $noFkCheck, $manager);
393		}
394		}
395

ozo2003 / HelperBundle

Branch — master (c65ffc)

QuickInsertRepository::buildExtra() C

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like