Micro\Cache\Drivers\DbDriver

Complexity

Total Complexity

16

Size/Duplication

Total Lines	135
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	1
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	20	2
A	check()	0	4	3
A	get()	0	9	3
A	getElement()	0	11	1
A	set()	0	4	1
A	delete()	0	4	1
A	clean()	0	4	1
A	info()	0	4	1
A	getMeta()	0	4	1
A	increment()	0	4	1
A	decrement()	0	4	1

<?php /** MicroDbDriver */

namespace Micro\Cache\Drivers;

use Micro\Base\Exception;
use Micro\Db\ConnectionInjector;
use Micro\Db\Drivers\IDriver;
use Micro\Mvc\Models\Query;

/**
 * Class DbDriver
 *
 * @author Oleg Lunegov <testuser@mail.linpax.org>
 * @link https://github.com/linpax/microphp-framework
 * @copyright Copyright (c) 2013 Oleg Lunegov
 * @license https://github.com/linpax/microphp-framework/blob/master/LICENSE
 * @package Micro
 * @subpackage Cache\Driver
 * @version 1.0
 * @since 1.0
 */
class DbDriver extends CacheDriver
{
    /** @var IDriver $driver DB driver */
    protected $driver;
    /** @var string $table table name */
    protected $table;


    /**
     * Constructor
     *
     * @access public
     *
     * @param array $config config array
     *
     * @result void
     * @throws Exception
     */
    public function __construct(array $config = [])
    {
        parent::__construct($config);

        $this->table = 'cache';
        if (!empty($config['table'])) {
            $this->table = $config['table'];
            unset($config['table']);
        }

        $this->driver = (new ConnectionInjector)->getDriver();

        $this->driver->createTable($this->table, [
            '`name` VARCHAR(127) NOT NULL',
            '`value` TEXT NULL',
            '`duration` INT(11) NOT NULL',
            '`date_create` INT(11) NOT NULL',
            'UNIQUE(`name`)'
        ], '');
    }

    /**
     * @inheritdoc
     */
    public function check()
    {
        return ($this->driver instanceof IDriver) && $this->driver->tableExists($this->table) ?: false;
    }

    /**
     * @inheritdoc
     * @throws \Micro\Base\Exception
     */
    public function get($name)
    {
        /** @var array $element */
        if ($element = $this->getElement($name)) {
            return array_key_exists('value', $element) ? $element['value'] : null;
        }

        return null;
    }

    /**
     * @inheritdoc
     * @throws \Micro\Base\Exception
     * @param string $name
     */
    protected function getElement($name)
    {
        $query = new Query($this->driver);
        $query->table = $this->table;
        $query->addWhere('`name`=:name');
        $query->params = ['name' => $name];
        $query->limit = 1;
        $query->single = true;

        return $query->run(\PDO::FETCH_ASSOC);
    }

    /**
     * @inheritdoc
     */
    public function set($name, $value)
    {
        return $this->driver->update($this->table, ['`name`="'.$value.'"'], 'name="'.$name.'"');
    }

    /**
     * @inheritdoc
     */
    public function delete($name)
    {
        return $this->driver->delete($this->table, 'name=:name', ['name' => $name]);
    }

    /**
     * @inheritdoc
     */
    public function clean()
    {
        $this->driver->clearTable($this->table);
    }

    /**
     * @inheritdoc
     */
    public function info()
    {
        return $this->driver->count(null, $this->table);
    }

    /**
     * @inheritdoc
     * @throws \Micro\Base\Exception
     */
    public function getMeta($id)
    {
        return $this->getElement($id);
    }

    /**
     * @inheritdoc
     */
    public function increment($name, $offset = 1)
    {
        return $this->driver->update($this->table, ['value' => 'value+'.$offset], 'name="'.$name.'"');
    }

    /**
     * @inheritdoc
     */
    public function decrement($name, $offset = 1)
    {
        return $this->driver->update($this->table, ['value' => 'value-'.$offset], 'name="'.$name.'"');
    }
}