Fabrica\Component\Config\MysqlConfig

Complexity

Total Complexity

7

Size/Duplication

Total Lines	60
Duplicated Lines	16.67 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	doGetAll()	0	11	2
A	doSetAll()	0	9	2
A	runSQL()	10	10	2

<?php

/**
 * This file is part of Fabrica.
 *
 * (c) Alexandre Salomé <alexandre.salome@gmail.com>
 * (c) Julien DIDIER <genzo.wm@gmail.com>
 *
 * This source file is subject to the GPL license that is bundled
 * with this source code in the file LICENSE.
 */

namespace Fabrica\Component\Config;

use Doctrine\DBAL\Connection;

use Fabrica\Component\Config\Exception\RuntimeException;

/**
 * Bulk MySQL version of Config: deletes and reinsert rows.
 *
 * @author Alexandre Salomé <alexandre.salome@gmail.com>
 */
class MysqlConfig extends AbstractConfig
{
    /**
     * @var Connection
     */
    protected $connection;
    protected $tableName;
    protected $tableExists;

    public function __construct(Connection $connection, $tableName = '_config')
    {
        $this->connection = $connection;
        $this->tableName  = $tableName;
    }

    /**
     * {@inheritDoc}
     */
    public function doGetAll()
    {
        $stmt = $this->runSql('SELECT `key`, `value` FROM `'. $this->tableName.'`');

        $result = array();
        while ($row = $stmt->fetch(\PDO::FETCH_ASSOC)) {

The method Doctrine\DBAL\Driver\ResultStatement::fetch() has been deprecated with message: Use fetchNumeric(), fetchAssociative() or fetchOne() instead.

            $result[$row['key']] = json_decode($row['value']);
        }

        return $result;
    }

    /**
     * {@inheritDoc}
     */
    protected function doSetAll(array $values)
    {
        $this->runSQL('DELETE FROM `'.$this->tableName.'`');

        $rows = array();

$rows is not used, you could remove the assignment.

        foreach ($values as $key => $value) {
            $this->runSQL('INSERT INTO '.$this->tableName.' (`key`, `value`) VALUES ('.$this->connection->quote($key).','.$this->connection->quote(json_encode($value)).');');
        }
    }

    /**
     * Proxy method to connection object. If an error occurred because of unfound table, tries to create table and rerun request.
     *
     * @param string $query      SQL query
     * @param array  $parameters query parameters
     */
    protected function runSQL($query, array $parameters = array())

This method seems to be duplicated in your project.

    {
        try {
            return $this->connection->executeQuery($query, $parameters);
        } catch (\Exception $e) {
            $this->connection->executeQuery(sprintf('CREATE TABLE %s (`key` VARCHAR(40), `value` TEXT);', $this->tableName));
        }

        return $this->connection->executeQuery($query, $parameters);
    }
}