MysqlConfig::doSetAll()   A
last analyzed

Complexity

Conditions 2
Paths 2

Size

Total Lines 9

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
dl 0
loc 9
rs 9.9666
c 0
b 0
f 0
cc 2
nc 2
nop 1
1
<?php
2
3
/**
4
 * This file is part of Fabrica.
5
 *
6
 * (c) Alexandre Salomé <[email protected]>
7
 * (c) Julien DIDIER <[email protected]>
8
 *
9
 * This source file is subject to the GPL license that is bundled
10
 * with this source code in the file LICENSE.
11
 */
12
13
namespace Fabrica\Component\Config;
14
15
use Doctrine\DBAL\Connection;
16
17
use Fabrica\Component\Config\Exception\RuntimeException;
18
19
/**
20
 * Bulk MySQL version of Config: deletes and reinsert rows.
21
 *
22
 * @author Alexandre Salomé <[email protected]>
23
 */
24
class MysqlConfig extends AbstractConfig
25
{
26
    /**
27
     * @var Connection
28
     */
29
    protected $connection;
30
    protected $tableName;
31
    protected $tableExists;
32
33
    public function __construct(Connection $connection, $tableName = '_config')
34
    {
35
        $this->connection = $connection;
36
        $this->tableName  = $tableName;
37
    }
38
39
    /**
40
     * {@inheritDoc}
41
     */
42
    public function doGetAll()
43
    {
44
        $stmt = $this->runSql('SELECT `key`, `value` FROM `'. $this->tableName.'`');
45
46
        $result = array();
47
        while ($row = $stmt->fetch(\PDO::FETCH_ASSOC)) {
0 ignored issues
show
Deprecated Code introduced by
The method Doctrine\DBAL\Driver\ResultStatement::fetch() has been deprecated with message: Use fetchNumeric(), fetchAssociative() or fetchOne() instead.

This method has been deprecated. The supplier of the class has supplied an explanatory message.

The explanatory message should give you some clue as to whether and when the method will be removed from the class and what other method or class to use instead.

Loading history...
48
            $result[$row['key']] = json_decode($row['value']);
49
        }
50
51
        return $result;
52
    }
53
54
    /**
55
     * {@inheritDoc}
56
     */
57
    protected function doSetAll(array $values)
58
    {
59
        $this->runSQL('DELETE FROM `'.$this->tableName.'`');
60
61
        $rows = array();
0 ignored issues
show
Unused Code introduced by
$rows 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...
62
        foreach ($values as $key => $value) {
63
            $this->runSQL('INSERT INTO '.$this->tableName.' (`key`, `value`) VALUES ('.$this->connection->quote($key).','.$this->connection->quote(json_encode($value)).');');
64
        }
65
    }
66
67
    /**
68
     * Proxy method to connection object. If an error occurred because of unfound table, tries to create table and rerun request.
69
     *
70
     * @param string $query      SQL query
71
     * @param array  $parameters query parameters
72
     */
73 View Code Duplication
    protected function runSQL($query, array $parameters = array())
0 ignored issues
show
Duplication introduced by
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...
74
    {
75
        try {
76
            return $this->connection->executeQuery($query, $parameters);
77
        } catch (\Exception $e) {
78
            $this->connection->executeQuery(sprintf('CREATE TABLE %s (`key` VARCHAR(40), `value` TEXT);', $this->tableName));
79
        }
80
81
        return $this->connection->executeQuery($query, $parameters);
82
    }
83
}
84