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

Passed

Push — master ( 7a67cc...c6bdad )

by Dāvis

created 2017-10-20 09:34 UTC

QuickInsertRepository::link() A

↳ Parent: QuickInsertRepository

Complexity

Conditions	1
Paths	1

Size

Total Lines	7
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	4
nc	1
nop	5
dl	0
loc	7
rs	9.4285
c	0
b	0
f	0

<?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) {
            $sth = self::$connection->prepare('SET FOREIGN_KEY_CHECKS = 0');
            $sth->execute();
        }
    }

    public static function close($noFkCheck = false)
    {
        if (!$noFkCheck) {
            $sth = self::$connection->prepare('SET FOREIGN_KEY_CHECKS = 1');
            $sth->execute();
        }
    }

    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 = $fvalue = $fkey = '';
        if (is_array($where) && !empty($where)) {
            $skip = false;
            foreach ($where as $key => $value) {
                $fkey = $key;
                if (is_array($value)) {
                    $skip = true;
                    $fvalue = trim($value[0]);
                } else {
                    $fvalue = trim($value);
                }
                break;
            }
            if (!$skip && isset(self::$mock[$tableName][$fkey])) {

                if (is_numeric($fvalue)) {
                    $whereSql .= ' WHERE '.self::$mock[$tableName][$fkey]." = $fvalue";
                } else {
                    $whereSql .= ' WHERE '.self::$mock[$tableName][$fkey]." = '".addslashes(trim($fvalue))."'";
                }
            } else {
                if (!$skip && is_numeric($fvalue)) {
                    $whereSql .= ' WHERE '.$fkey." = $fvalue";
                } elseif (!$skip && !is_numeric($fvalue)) {
                    $whereSql .= ' WHERE '.$fkey." = '".addslashes(trim($fvalue))."'";
                } elseif ($skip && is_numeric($fkey)) {
                    $whereSql .= " WHERE $fvalue";
                }
            }
            unset($where[$fkey]);
            if (is_array($where) && !empty($where)) {
                foreach ($where as $key => $value) {
                    $skip = is_array($value);
                    if (!$skip && isset(self::$mock[$tableName][$key])) {

                        if (is_numeric($value)) {
                            $whereSql .= ' AND '.self::$mock[$tableName][$key]." = $value";
                        } else {
                            $whereSql .= ' AND '.self::$mock[$tableName][$key]." = '".addslashes(trim($value))."'";
                        }
                    } else {
                        if (!$skip && is_numeric($value)) {
                            $whereSql .= ' AND '.$key." = $value";
                        } elseif (!$skip && !is_numeric($value)) {
                            $whereSql .= ' AND '.$key." = '".addslashes(trim($value))."'";
                        } elseif ($skip && is_numeric($key)) {
                            $whereSql .= " AND {$value[0]}";
                        }
                    }
                }
            }
        }

        return $whereSql;
    }

    private static function getTable(&$object, &$tableName, &$columns, &$type)
    {
        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, &$out = null)
    {
        $result = self::get(['table_name' => 'information_schema.tables'], true, [
            'table_name' => $tableName,
            ['table_schema = DATABASE()'],
        ], true, ['AUTO_INCREMENT'], null, [], $out);

        if ($result) {
            return $result;
        }

        return 1;
    }

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

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

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

        $whereSql = self::buildWhere($tableName, $where);
        $select = (isset($extra['MODE']) ? 'SELECT '.$extra['MODE'] : 'SELECT').' ';
        if (!$fields) {
            $sql = $select.'id FROM '.$tableName.$whereSql;
        } else {
            $sql = $select.(implode(', ', $fields)).' FROM '.$tableName.$whereSql;
        }
        if (!empty($extra)) {
            $extraSql = self::buildExtra($extra);
            $sql .= $extraSql;
        }
        if ($out) {
            $out = $sql;
        }
        $sth = self::$connection->prepare($sql);
        $sth->execute();
        $result = $sth->fetchAll();
        if ($one && $result) {
            if (!$fields) {
                return intval($result[0]['id']);
            } else {
                if (count($fields) === 1 && $fields[0] !== '*') {
                    return $result[0][$fields[0]];
                } else {
                    return $result[0];
                }
            }
        }

        self::close(true);
        if ($one || !$result) {
            return null;
        }

        $field = null;
        if (!$fields) {
            $field = 'id';
        } elseif (count($fields) === 1 && $fields[0] !== '*') {
            $field = $fields[0];
        }

        if ($field) {
            foreach ($result as &$res) {
                $res = $res[$field];
            }
        }

        return $result;
    }

    private static function value($object, $variable, $type)
    {
        if ($type === 'object') {
            return $object->{'get'.ucfirst($variable)}();
        } else {
            return $object[$variable];
        }
    }

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

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

        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 instanceof \DateTime) {
                    $variable = "'".addslashes(trim($value->format('Y-m-d H:i:s')))."'";
                } else {
                    $variable = "'".addslashes(trim($value))."'";
                }
                if (trim($variable) === '' || trim($variable) === "''" || (is_numeric($variable) && $variable === 0)) {
                    $variable = null;
                }
                if ($variable !== null) {
                    $values[] = $variable;
                    $keys[] = $key;
                    if ($key === 'id') {
                        $idd = $value;
                    }
                }
            }
        }

        $sql = null;
        if (!$full && !self::isEmpty($values)) {
            $sql = '
                INSERT INTO
                    '.$tableName.'
                        (id, '.implode(',', $keys).")
                VALUES
                    ({$id},".implode(',', $values).')
            ';
        } elseif ($full && !self::isEmpty($values)) {
            $id = $idd;
            $sql = '
                INSERT INTO
                    '.$tableName.'
                        ('.implode(',', $keys).")
                VALUES
                    (".implode(',', $values).')
            ';
        } else {
            $id = null;
        }
        if ($sql !== null && $id !== null) {
            if ($out) {
                $out = $sql;
            }
            $sth = self::$connection->prepare($sql);
            $sth->execute();
        }

        self::close($noFkCheck);

        return $id;
    }

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

        $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);
        if ($type === 'object') {
            if ($id) {
                foreach ($result as $key => $value) {
                    if ($object->{'get'.ucfirst($flip[$key])}() !== $value) {

                        $data[$columns[$flip[$key]]] = $object->{'get'.ucfirst($flip[$key])}();
                    }
                }
            } else {
                foreach ($result as $key => $value) {
                    if ($object->{'get'.ucfirst($flip[$key])}() !== null) {
                        if ($object->{'get'.ucfirst($flip[$key])}() !== $value) {

                            $data[$columns[$flip[$key]]] = $object->{'get'.ucfirst($flip[$key])}();
                        }
                    }
                }
            }
        } else {
            foreach ($result as $key => $value) {
                if (isset($object[$key]) && $object[$key] !== $value) {
                    $data[$key] = $extraFields[$key];
                }
            }

        }

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

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

            $sthu = self::$connection->prepare($sql);
            $sthu->execute();
        }

        self::close($noFkCheck);
    }

    public static function delete($object, $where = [], $noFkCheck = false, $manager = null, &$out = null)
    {
        self::init($noFkCheck, $manager);
        self::getTable($object, $tableName, $columns, $type);

        $whereSql = self::buildWhere($tableName, $where);
        $sql = 'DELETE FROM '.$tableName.' '.$whereSql;
        if ($out) {
            $out = $sql;
        }
        $sth = self::$connection->prepare($sql);
        $sth->execute();

        self::close($noFkCheck);
    }

    public static function link($object, $data, $noFkCheck = false, $manager = null, &$out = null)
    {
        self::init($noFkCheck, $manager);
        self::getTable($object, $tableName, $columns, $type);

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


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		$sth = self::$connection->prepare('SET FOREIGN_KEY_CHECKS = 0');
32		$sth->execute();
33		}
34		}
35
36		public static function close($noFkCheck = false)
37		{
38		if (!$noFkCheck) {
39		$sth = self::$connection->prepare('SET FOREIGN_KEY_CHECKS = 1');
40		$sth->execute();
41		}
42		}
43
44		public static function isEmpty($variable)
45		{
46		$result = true;
47
48		if (is_array($variable) && count($variable) > 0) {
49		foreach ($variable as $value) {
50		$result = $result && self::isEmpty($value);
51		}
52		} else {
53		$result = empty($variable);
54		}
55
56		return $result;
57		}
58
59		private static function extract($object)
60		{
61		self::init(false);
62		$data = self::extractExt($object, self::$entityManager);
63
64		self::$mock = $data['mock'];
65		self::$tableName = $data['table'];
66		self::$metadata[$data['table']] = $data['meta'];
67		}
68
69		public static function extractExt($object, $entityManager)
70		{
71		$metadata = $entityManager->getClassMetadata(get_class($object));
72
73		$fields = $metadata->getFieldNames();
74		$columns = $metadata->getColumnNames();
75		$table = $metadata->getTableName();
76
77		$result = [];
78		foreach ($fields as $key => $field) {
79		foreach ($columns as $key2 => $column) {
80		if ($key === $key2) {
81		$result[$table][$field] = $column;
82		}
83		}
84		}
85
86		$data = [
87		'mock' => $result,
88		'table' => $table,
89		'meta' => $metadata,
90		];
91
92		return $data;
93		}
94
95		private static function buildExtra($extra)
96		{
97		$methods = [
98		'GROUP BY',
99		'HAVING',
100		'ORDER BY',
101		];
102		$sql = '';
103
104		foreach ($methods as $method) {
105		if (isset($extra[$method])) {
106		$sql .= ' '.$method.' ';
107		if (is_array($extra[$method])) {
108		foreach ($extra[$method] as $group) {
109		$sql .= $group.' ';
110		}
111		} else {
112		$sql .= $extra[$method].' ';
113		}
114		}
115		}
116
117		if (isset($extra['LIMIT'])) {
118		if (is_array($extra['LIMIT'])) {
119		if (isset($extra['LIMIT'][1])) {
120		$offset = $extra['LIMIT'][0];
121		$limit = $extra['LIMIT'][1];
122		} else {
123		$offset = 0;
124		$limit = $extra['LIMIT'][0];
125		}
126		$sql .= 'LIMIT '.$offset.', '.$limit;
127		}
128		}
129
130		$sql = str_replace(' ', ' ', $sql);
131
132		return $sql;
133		}
134
135		private static function buildWhere($tableName, $where)
136		{
137		$whereSql = $fvalue = $fkey = '';
138		if (is_array($where) && !empty($where)) {
139		$skip = false;
140		foreach ($where as $key => $value) {
141		$fkey = $key;
142		if (is_array($value)) {
143		$skip = true;
144		$fvalue = trim($value[0]);
145		} else {
146		$fvalue = trim($value);
147		}
148		break;
149		}
150	View Code Duplication	if (!$skip && isset(self::$mock[$tableName][$fkey])) {
		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...
151		if (is_numeric($fvalue)) {
152		$whereSql .= ' WHERE '.self::$mock[$tableName][$fkey]." = $fvalue";
153		} else {
154		$whereSql .= ' WHERE '.self::$mock[$tableName][$fkey]." = '".addslashes(trim($fvalue))."'";
155		}
156		} else {
157		if (!$skip && is_numeric($fvalue)) {
158		$whereSql .= ' WHERE '.$fkey." = $fvalue";
159		} elseif (!$skip && !is_numeric($fvalue)) {
160		$whereSql .= ' WHERE '.$fkey." = '".addslashes(trim($fvalue))."'";
161		} elseif ($skip && is_numeric($fkey)) {
162		$whereSql .= " WHERE $fvalue";
163		}
164		}
165		unset($where[$fkey]);
166		if (is_array($where) && !empty($where)) {
167		foreach ($where as $key => $value) {
168		$skip = is_array($value);
169	View Code Duplication	if (!$skip && isset(self::$mock[$tableName][$key])) {
		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...
170		if (is_numeric($value)) {
171		$whereSql .= ' AND '.self::$mock[$tableName][$key]." = $value";
172		} else {
173		$whereSql .= ' AND '.self::$mock[$tableName][$key]." = '".addslashes(trim($value))."'";
174		}
175		} else {
176		if (!$skip && is_numeric($value)) {
177		$whereSql .= ' AND '.$key." = $value";
178		} elseif (!$skip && !is_numeric($value)) {
179		$whereSql .= ' AND '.$key." = '".addslashes(trim($value))."'";
180		} elseif ($skip && is_numeric($key)) {
181		$whereSql .= " AND {$value[0]}";
182		}
183		}
184		}
185		}
186		}
187
188		return $whereSql;
189		}
190
191		private static function getTable(&$object, &$tableName, &$columns, &$type)
192		{
193		if (is_object($object)) {
194		self::extract($object);
195		$tableName = self::$tableName;
196		$columns = self::$mock[$tableName] ?: [];
197		$type = 'object';
198		} else {
199		$tableName = $object['table_name'];
200		unset($object['table_name']);
201		$type = 'table';
202		$columns = array_keys($object) ?: [];
203		}
204		}
205
206		public static function findNextId($tableName, &$out = null)
207		{
208		$result = self::get(['table_name' => 'information_schema.tables'], true, [
209		'table_name' => $tableName,
210		['table_schema = DATABASE()'],
211		], true, ['AUTO_INCREMENT'], null, [], $out);
212
213		if ($result) {
214		return $result;
215		}
216
217		return 1;
218		}
219
220		public static function findNextIdExt($object, $entityManager = null, &$out = null)
221		{
222		self::init(true);
223		$data = self::extractExt($object, $entityManager);
224
225		return self::findNextId($data['table'], $out);
226		}
227
228		public static function get($object, $one = false, $where = [], $noFkCheck = true, $fields = [], $manager = null, $extra = [], &$out = null)
229		{
230		self::init(true, $manager);
231		self::getTable($object, $tableName, $columns, $type);
232
233		$whereSql = self::buildWhere($tableName, $where);
234		$select = (isset($extra['MODE']) ? 'SELECT '.$extra['MODE'] : 'SELECT').' ';
235		if (!$fields) {
236		$sql = $select.'id FROM '.$tableName.$whereSql;
237		} else {
238		$sql = $select.(implode(', ', $fields)).' FROM '.$tableName.$whereSql;
239		}
240		if (!empty($extra)) {
241		$extraSql = self::buildExtra($extra);
242		$sql .= $extraSql;
243		}
244		if ($out) {
245		$out = $sql;
246		}
247		$sth = self::$connection->prepare($sql);
248		$sth->execute();
249		$result = $sth->fetchAll();
250		if ($one && $result) {
251		if (!$fields) {
252		return intval($result[0]['id']);
253		} else {
254		if (count($fields) === 1 && $fields[0] !== '*') {
255		return $result[0][$fields[0]];
256		} else {
257		return $result[0];
258		}
259		}
260		}
261
262		self::close(true);
263		if ($one \|\| !$result) {
264		return null;
265		}
266
267		$field = null;
268		if (!$fields) {
269		$field = 'id';
270		} elseif (count($fields) === 1 && $fields[0] !== '*') {
271		$field = $fields[0];
272		}
273
274		if ($field) {
275		foreach ($result as &$res) {
276		$res = $res[$field];
277		}
278		}
279
280		return $result;
281		}
282
283		private static function value($object, $variable, $type)
284		{
285		if ($type === 'object') {
286		return $object->{'get'.ucfirst($variable)}();
287		} else {
288		return $object[$variable];
289		}
290		}
291
292		public static function persist($object, $full = false, $extraFields = [], $noFkCheck = false, $manager = null, &$out = null)
293		{
294		self::init($noFkCheck, $manager);
295		self::getTable($object, $tableName, $columns, $type);
296
297		$id = self::findNextId($tableName);
298		$keys = [];
299		$values = [];
300
301	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...
302		$columns = array_merge($columns, $extraFields[$tableName]);
303		}
304
305		$idd = null;
306		foreach ($columns as $value => $key) {
307		$variable = null;
308		if (!is_array($key) && !is_array($value)) {
309		$value = self::value($object, $value, $type);
310		if ($value instanceof \DateTime) {
311		$variable = "'".addslashes(trim($value->format('Y-m-d H:i:s')))."'";
312		} else {
313		$variable = "'".addslashes(trim($value))."'";
314		}
315		if (trim($variable) === '' \|\| trim($variable) === "''" \|\| (is_numeric($variable) && $variable === 0)) {
316		$variable = null;
317		}
318		if ($variable !== null) {
319		$values[] = $variable;
320		$keys[] = $key;
321		if ($key === 'id') {
322		$idd = $value;
323		}
324		}
325		}
326		}
327
328		$sql = null;
329		if (!$full && !self::isEmpty($values)) {
330		$sql = '
331		INSERT INTO
332		'.$tableName.'
333		(id, '.implode(',', $keys).")
334		VALUES
335		({$id},".implode(',', $values).')
336		';
337		} elseif ($full && !self::isEmpty($values)) {
338		$id = $idd;
339		$sql = '
340		INSERT INTO
341		'.$tableName.'
342		('.implode(',', $keys).")
343		VALUES
344		(".implode(',', $values).')
345		';
346		} else {
347		$id = null;
348		}
349		if ($sql !== null && $id !== null) {
350		if ($out) {
351		$out = $sql;
352		}
353		$sth = self::$connection->prepare($sql);
354		$sth->execute();
355		}
356
357		self::close($noFkCheck);
358
359		return $id;
360		}
361
362		public static function update($id, $object, $extraFields = [], $noFkCheck = false, $manager = null, &$out = null)
363		{
364		self::init($noFkCheck, $manager);
365		self::getTable($object, $tableName, $columns, $type);
366
367		$result = self::get(['table_name' => $tableName], true, ['id' => $id], true, ['*']);
368		unset($result['id']);
369
370		$data = [];
371
372	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...
373		$columns = array_merge($columns, $extraFields[$tableName]);
374		}
375
376		$flip = array_flip($columns);
377		if ($type === 'object') {
378		if ($id) {
379		foreach ($result as $key => $value) {
380	View Code Duplication	if ($object->{'get'.ucfirst($flip[$key])}() !== $value) {
		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...
381		$data[$columns[$flip[$key]]] = $object->{'get'.ucfirst($flip[$key])}();
382		}
383		}
384		} else {
385		foreach ($result as $key => $value) {
386		if ($object->{'get'.ucfirst($flip[$key])}() !== null) {
387	View Code Duplication	if ($object->{'get'.ucfirst($flip[$key])}() !== $value) {
		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...
388		$data[$columns[$flip[$key]]] = $object->{'get'.ucfirst($flip[$key])}();
389		}
390		}
391		}
392		}
393		} else {
394		foreach ($result as $key => $value) {
395		if (isset($object[$key]) && $object[$key] !== $value) {
396		$data[$key] = $extraFields[$key];
397		}
398		}
399
400		}
401
402		if ($data) {
403		$sql = "
404		UPDATE
405		".$tableName."
406		SET
407
408		";
409		foreach ($data as $key => $value) {
410		$meta = self::$metadata[$tableName]->getFieldMapping($flip[$key]);
411		$meta = $meta['type'];
412		if (in_array($meta, [
413		'boolean',
414		'integer',
415		'longint',
416		])) {
417		$value = intval($value);
418		} else {
419		$value = "'".addslashes(trim($value))."'";
420		}
421		$sql .= " ".$key." = ".$value.",";
422		}
423		$sql = substr($sql, 0, -1);
424		$sql .= " WHERE id = ".$id;
425		if ($out) {
426		$out = $sql;
427		}
428
429		$sthu = self::$connection->prepare($sql);
430		$sthu->execute();
431		}
432
433		self::close($noFkCheck);
434		}
435
436		public static function delete($object, $where = [], $noFkCheck = false, $manager = null, &$out = null)
437		{
438		self::init($noFkCheck, $manager);
439		self::getTable($object, $tableName, $columns, $type);
440
441		$whereSql = self::buildWhere($tableName, $where);
442		$sql = 'DELETE FROM '.$tableName.' '.$whereSql;
443		if ($out) {
444		$out = $sql;
445		}
446		$sth = self::$connection->prepare($sql);
447		$sth->execute();
448
449		self::close($noFkCheck);
450		}
451
452		public static function link($object, $data, $noFkCheck = false, $manager = null, &$out = null)
453		{
454		self::init($noFkCheck, $manager);
455		self::getTable($object, $tableName, $columns, $type);
456
457		$data['table_name'] = $tableName;
458		self::persist($data, true, [], $noFkCheck, $manager, $out);
459		}
460		}
461

ozo2003 / HelperBundle

Push — master ( 7a67cc...c6bdad )

QuickInsertRepository::link() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like