lav45\settings\storage\DbStorage

Complexity

Total Complexity

5

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

96.3%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	init()	0	5	1
A	getValue()	0	10	1
A	setValue()	0	16	2
A	deleteValue()	0	8	1

<?php
/**
 * @link https://github.com/LAV45/yii2-settings
 * @copyright Copyright (c) 2016 LAV45
 * @author Alexey Loban <lav451@gmail.com>
 * @license http://opensource.org/licenses/BSD-3-Clause
 */

namespace lav45\settings\storage;

use yii\db\Query;
use yii\db\Connection;
use yii\di\Instance;
use yii\base\BaseObject;

/**
 * Class DbStorage
 * @package lav45\settings\storage
 */
class DbStorage extends BaseObject implements StorageInterface
{
    /**
     * @var Connection|array|string
     */
    public $db = 'db';
    /**
     * @var string
     */
    public $tableName = '{{%settings}}';

    /**
     * Initializes the application component.
     */
    public function init()
    {
        parent::init();
        $this->db = Instance::ensure($this->db, Connection::class);
    }

    /**
     * @param string $key
     * @return false|null|string
     */
    public function getValue($key)
    {
        return (new Query())
            ->select(['data'])
            ->from($this->tableName)
            ->where(['id' => $key])
            ->limit(1)
            ->createCommand($this->db)
            ->queryScalar();
    }

    /**
     * @param string $key
     * @param string $value
     * @return bool
     */
    public function setValue($key, $value)
    {
        $exists = (new Query())
            ->from($this->tableName)
            ->where(['id' => $key])
            ->exists($this->db);

        $query = (new Query())->createCommand($this->db);

        if ($exists) {
            $result = $query->update($this->tableName, ['data' => $value], ['id' => $key])->execute();
        } else {
            $result = $query->insert($this->tableName, ['id' => $key, 'data' => $value])->execute();
        }
        return $result > 0;
    }

    /**
     * @param string $key
     * @return bool
     */
    public function deleteValue($key)
    {
        $result = (new Query())->createCommand($this->db)
            ->delete($this->tableName, ['id' => $key])
            ->execute();

        return $result > 0;
    }
}