DB::runUpdate() - Code Metrics - Inspection of "v0.9, see Changelog" - edyan/neuralyzer - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( ffefc4...9322fd )

by Emmanuel

created 2016-08-04 12:08 UTC

DB::runUpdate() A

↳ Parent: DB

Complexity

Conditions	2
Paths	2

Size

Total Lines	13
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	11
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	13
ccs	11
cts	11
cp	1
rs	9.4285
nc	2
cc	2
eloc	9
nop	3
crap	2

<?php
/**
 * Inet Data Anonymization
 *
 * PHP Version 5.3 -> 7.0
 *
 * @author Emmanuel Dyan
 * @author Rémi Sauvat
 * @copyright 2005-2015 iNet Process
 *
 * @package inetprocess/neuralyzer
 *
 * @license GNU General Public License v2.0
 *
 * @link http://www.inetprocess.com
 */

namespace Inet\Neuralyzer\Anonymizer;

use Inet\Neuralyzer\Exception\InetAnonException;

/**
 * DB Anonymizer
 */
class DB extends AbstractAnonymizer
{
    /**
     * The PDO connection
     *
     * @var \PDO
     */
    protected $pdo;

    /**
     * Constructor
     *
     * @param \PDO $pdo
     */
    public function __construct(\PDO $pdo)
    {
        $this->pdo = $pdo;
        $this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
    }

    /**
     * Process an entity by reading / writing to the DB
     *
     * @param string        $table
     * @param callable|null $callback
     * @param bool          $pretend
     * @param bool          $returnResult
     *
     * @return void|array
     */
    public function processEntity($table, $callback = null, $pretend = true, $returnResult = false)
    {
        $key = $this->getPrimaryKey($table);

        if ($this->whatToDoWithEntity($table) === self::TRUNCATE_TABLE) {
            $where = $this->getWhereConditionInConfig($table);
            $query = $this->runDelete($table, $where, $pretend);

            return ($returnResult === true ? array($query) : '');
        }

        // I need to read line by line if I have to update the table
        // to make sure I do update by update (slower but no other choice for now)
        $res = $this->pdo->query("SELECT $key FROM $table");

        $res->setFetchMode(\PDO::FETCH_ASSOC);
        $i = 0;
        $queries = array();
        while ($row = $res->fetch()) {
            $val = $row['id'];

            $data = $this->generateFakeData($table);

            if ($pretend === false) {
                $this->runUpdate($table, $data, "$key = '$val'");
            }

            ($returnResult === true ? array_push($queries, $this->buildUpdateSQL($table, $data, "$key = '$val'")) : '');

            if (!is_null($callback)) {
                $callback(++$i);
            }
        }

        return $queries;
    }

    /**
     * Identify the primary key for a table
     *
     * @param string $table
     *
     * @return string Field's name
     */
    protected function getPrimaryKey($table)
    {
        try {
            $res = $this->pdo->query("SHOW COLUMNS FROM $table WHERE `Key` = 'Pri'");
        } catch (\Exception $e) {
            throw new \PDOException('Query Error : ' . $e->getMessage());
        }

        $primary = $res->fetchAll(\PDO::FETCH_COLUMN);
        // Didn't find a primary key !
        if (empty($primary)) {
            throw new InetAnonException("Can't find a primary key for '$table'");
        }

        return $primary[0];
    }

    /**
     * Execute the Update with PDO
     *
     * @param string $table
     * @param array  $data
     * @param string $where
     */
    private function runUpdate($table, array $data, $where)
    {
        $fields = array();
        $values = array();
        foreach ($data as $field => $value) {
            $fields[] = "$field = IF($field  IS NOT NULL, :$field, NULL)";
            $values[":$field"] = $value;
        }

        $sql = "UPDATE $table SET " . implode(', ', $fields) . " WHERE $where";
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($values);
    }

    /**
     * Execute the Delete with PDO
     *
     * @param string $table
     * @param string $where
     */
    private function runDelete($table, $where, $pretend)
    {
        $where = empty($where) ? '' : " WHERE $where";
        $sql = "DELETE FROM {$table}{$where}";

        if ($pretend === true) {
            return $sql;
        }

        try {
            $res = $this->pdo->query($sql);
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
        } catch (\Exception $e) {
            throw new \PDOException('Query Error : ' . $e->getMessage());
        }

        return $sql;
    }

    /**
     * Build the SQL just for debug
     *
     * @param string $table
     * @param array  $data
     * @param string $where
     *
     * @return string
     */
    private function buildUpdateSQL($table, array $data, $where)
    {
        $fieldsVals = array();
        foreach ($data as $field => $value) {
            $fieldsVals[] = "$field = IF($field IS NOT NULL, '" . addslashes($value) . "', NULL)";
        }

        $sql = "UPDATE $table SET " . implode(', ', $fieldsVals) . " WHERE $where";

        return $sql;
    }
}


1		<?php
2		/**
3		* Inet Data Anonymization
4		*
5		* PHP Version 5.3 -> 7.0
6		*
7		* @author Emmanuel Dyan
8		* @author Rémi Sauvat
9		* @copyright 2005-2015 iNet Process
10		*
11		* @package inetprocess/neuralyzer
12		*
13		* @license GNU General Public License v2.0
14		*
15		* @link http://www.inetprocess.com
16		*/
17
18		namespace Inet\Neuralyzer\Anonymizer;
19
20		use Inet\Neuralyzer\Exception\InetAnonException;
21
22		/**
23		* DB Anonymizer
24		*/
25		class DB extends AbstractAnonymizer
26		{
27		/**
28		* The PDO connection
29		*
30		* @var \PDO
31		*/
32		protected $pdo;
33
34		/**
35		* Constructor
36		*
37		* @param \PDO $pdo
38		*/
39	15	public function __construct(\PDO $pdo)
40		{
41	15	$this->pdo = $pdo;
42	15	$this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
43	15	}
44
45		/**
46		* Process an entity by reading / writing to the DB
47		*
48		* @param string $table
49		* @param callable\|null $callback
50		* @param bool $pretend
51		* @param bool $returnResult
52		*
53		* @return void\|array
54		*/
55	13	public function processEntity($table, $callback = null, $pretend = true, $returnResult = false)
56		{
57	13	$key = $this->getPrimaryKey($table);
58
59	11	if ($this->whatToDoWithEntity($table) === self::TRUNCATE_TABLE) {
60	4	$where = $this->getWhereConditionInConfig($table);
61	4	$query = $this->runDelete($table, $where, $pretend);
62
63	3	return ($returnResult === true ? array($query) : '');
64		}
65
66		// I need to read line by line if I have to update the table
67		// to make sure I do update by update (slower but no other choice for now)
68	5	$res = $this->pdo->query("SELECT $key FROM $table");
69
70	5	$res->setFetchMode(\PDO::FETCH_ASSOC);
71	5	$i = 0;
72	5	$queries = array();
73	5	while ($row = $res->fetch()) {
74	5	$val = $row['id'];
75
76	5	$data = $this->generateFakeData($table);
77
78	5	if ($pretend === false) {
79	3	$this->runUpdate($table, $data, "$key = '$val'");
80	3	}
81
82	5	($returnResult === true ? array_push($queries, $this->buildUpdateSQL($table, $data, "$key = '$val'")) : '');
83
84	5	if (!is_null($callback)) {
85	3	$callback(++$i);
86	3	}
87	5	}
88
89	5	return $queries;
90		}
91
92		/**
93		* Identify the primary key for a table
94		*
95		* @param string $table
96		*
97		* @return string Field's name
98		*/
99	13	protected function getPrimaryKey($table)
100		{
101		try {
102	13	$res = $this->pdo->query("SHOW COLUMNS FROM $table WHERE `Key` = 'Pri'");
103	13	} catch (\Exception $e) {
104	1	throw new \PDOException('Query Error : ' . $e->getMessage());
105		}
106
107	12	$primary = $res->fetchAll(\PDO::FETCH_COLUMN);
108		// Didn't find a primary key !
109	12	if (empty($primary)) {
110	1	throw new InetAnonException("Can't find a primary key for '$table'");
111		}
112
113	11	return $primary[0];
114		}
115
116		/**
117		* Execute the Update with PDO
118		*
119		* @param string $table
120		* @param array $data
121		* @param string $where
122		*/
123	3	private function runUpdate($table, array $data, $where)
124		{
125	3	$fields = array();
126	3	$values = array();
127	3	foreach ($data as $field => $value) {
128	3	$fields[] = "$field = IF($field IS NOT NULL, :$field, NULL)";
129	3	$values[":$field"] = $value;
130	3	}
131
132	3	$sql = "UPDATE $table SET " . implode(', ', $fields) . " WHERE $where";
133	3	$stmt = $this->pdo->prepare($sql);
134	3	$stmt->execute($values);
135	3	}
136
137		/**
138		* Execute the Delete with PDO
139		*
140		* @param string $table
141		* @param string $where
142		*/
143	4	private function runDelete($table, $where, $pretend)
144		{
145	4	$where = empty($where) ? '' : " WHERE $where";
146	4	$sql = "DELETE FROM {$table}{$where}";
147
148	4	if ($pretend === true) {
149	1	return $sql;
150		}
151
152		try {
153	3	$res = $this->pdo->query($sql);
		0 ignored issues – show Unused Code introduced 2016-08-04 12:13 UTC by Report Bug Copy Issue Report `$res` is not used, you could remove the assignment. This check looks for variable assignements that are either overwritten by other assignments or where the variable is not used subsequently. $myVar = 'Value'; $higher = false; if (rand(1, 6) > 3) { $higher = true; } else { $higher = false; } Both the `$myVar` assignment in line 1 and the `$higher` assignment in line 2 are dead. The first because `$myVar` is never used and the second because `$higher` is always overwritten for every possible time line. Loading history...
154	3	} catch (\Exception $e) {
155	1	throw new \PDOException('Query Error : ' . $e->getMessage());
156		}
157
158	2	return $sql;
159		}
160
161		/**
162		* Build the SQL just for debug
163		*
164		* @param string $table
165		* @param array $data
166		* @param string $where
167		*
168		* @return string
169		*/
170	4	private function buildUpdateSQL($table, array $data, $where)
171		{
172	4	$fieldsVals = array();
173	4	foreach ($data as $field => $value) {
174	4	$fieldsVals[] = "$field = IF($field IS NOT NULL, '" . addslashes($value) . "', NULL)";
175	4	}
176
177	4	$sql = "UPDATE $table SET " . implode(', ', $fieldsVals) . " WHERE $where";
178
179	4	return $sql;
180		}
181		}
182

edyan / neuralyzer

Push — master ( ffefc4...9322fd )

DB::runUpdate() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like