QuickInsertRepository::variable() - Code Metrics - Inspection of "quick insert rebuild [wip]" - ozo2003/HelperBundle - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 8d042a...ae13b9 )

by Dāvis

created 2017-10-21 01:29 UTC

QuickInsertRepository::variable() B

↳ Parent: QuickInsertRepository

Complexity

Conditions	5
Paths	6

Size

Total Lines	10
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	5
eloc	6
c	0
b	0
f	0
nc	6
nop	1
dl	0
loc	10
rs	8.8571

<?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);

        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) {
            $variable = null;

            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);
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		$variable = null;
		0 ignored issues – show Unused Code introduced 2017-10-21 01:32 UTC by Report Bug Copy Issue Report The assignment to `$variable` is dead and can be removed. Loading history...
293		if (!is_array($key) && !is_array($value)) {
294		$value = self::value($object, $value, $type);
295		if ($value !== null) {
296		$data[$key] = $value;
297		if ($key === 'id') {
298		$idd = $value;
299		}
300		}
301		}
302		}
303
304		$sql = null;
305		if (!$full) {
306		$data['id'] = $id;
307		} else {
308		$id = $idd;
309		}
310
311		if (!self::isEmpty($data)) {
312		$sql = '
313		INSERT INTO
314		'.$tableName.'
315		('.implode(',', array_keys($data)).')
316		VALUES
317		('.implode(',', array_values($data)).')
318		';
319		} else {
320		$id = null;
321		}
322
323		if ($sql !== null && $id !== null) {
324		self::runSQL($sql);
325		}
326
327		return $id;
328		}
329
330		public static function update($id, $object, $extraFields = [], $noFkCheck = false, $manager = null)
331		{
332		self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);
333
334		$result = self::get(['table_name' => $tableName], true, ['id' => $id], true, ['*']);
335		unset($result['id']);
336
337		$data = [];
338
339	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...
340		$columns = array_merge($columns, $extraFields[$tableName]);
341		}
342
343		$flip = array_flip($columns);
344		foreach ($result as $key => $value) {
345		$content = self::value($object, $key, $type, false);
346		if ($content !== $value) {
347		$data[$key] = $content;
348		}
349		if (!$id && $content === null) {
350		unset($data[$key]);
351		}
352		}
353
354		if ($data) {
355		$sql = '
356		UPDATE
357		'.$tableName.'
358		SET
359
360		';
361		foreach ($data as $key => $value) {
362		$meta = self::$metadata[$tableName]->getFieldMapping($flip[$key])['type'];
363		if (in_array($meta, [
364		'boolean',
365		'integer',
366		'longint',
367		])) {
368		$value = intval($value);
369		} else {
370		$value = "'".addslashes(trim($value))."'";
371		}
372		$sql .= " ".$key." = ".$value.",";
373		}
374		$sql = substr($sql, 0, -1).' WHERE id = '.$id;
375
376		self::runSQL($sql);
377		}
378		}
379
380	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...
381		{
382		self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);
383
384		$sql = 'DELETE FROM '.$tableName.self::buildWhere($tableName, $where);
385		self::runSQL($sql);
386		}
387
388	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...
389		{
390		self::getTable($object, $tableName, $columns, $type, $noFkCheck, $manager);
391
392		$data['table_name'] = $tableName;
393		self::persist($data, true, [], $noFkCheck, $manager);
394		}
395		}
396

ozo2003 / HelperBundle

Push — master ( 8d042a...ae13b9 )

QuickInsertRepository::variable() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like