DrMVC\Database\Model

Complexity

Total Complexity

18

Size/Duplication

Total Lines	163
Duplicated Lines	0 %

Importance

Changes

0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	insert()	0	3	1
A	exec()	0	3	1
A	select()	0	3	1
A	update()	0	3	1
A	setInstance()	0	3	1
A	getConnection()	0	3	1
A	getCollection()	0	3	1
A	__construct()	0	17	2
A	getInstance()	0	3	1
A	truncate()	0	3	1
A	delete()	0	3	1
A	setCollection()	0	4	1
A	getConfigDB()	0	14	3
A	classToShake()	0	11	2

<?php

namespace DrMVC\Database;

use DrMVC\Config\ConfigInterface;
use DrMVC\Database\Drivers\QueryInterface;
use Stringy\Stringy;

class Model implements ModelInterface
{
    /**
     * @var QueryInterface
     */
    private $_instance;

    /**
     * Default connection name
     * @var string
     */
    protected $connection = Database::DEFAULT_CONNECTION;

    /**
     * Name of collection for query
     * @var string|null
     */
    protected $collection;

    /**
     * Model constructor.
     * @param   ConfigInterface $config
     * @param   string $collection name of active collection
     */
    public function __construct(ConfigInterface $config, string $collection = null)
    {
        // Create database object with config from above
        $config_db = $this->getConfigDB($config);
        $database = new Database($config_db);

        // If collection name is not provided
        if (null === $collection) {
            // Get current collection name
            $collection = $this->getCollection();
        }

        // Extract instance created by driver and put collection name
        $instance = $database->getInstance($collection);

        // Keep driver's instance as local parameter
        $this->setInstance($instance);
    }

    /**
     * Extract configuration of current database
     *
     * @param   ConfigInterface $config
     * @return  ConfigInterface
     */
    private function getConfigDB(ConfigInterface $config): ConfigInterface
    {
        // get current connection
        $connection = $this->getConnection();
        // Get config of required connection
        $config_db = $config->get($connection);
        try {
            if (null === $config_db) {
                throw new Exception("Connection \"$connection\" is not found in database config");
            }
        } catch (Exception $e) {
            // __constructor
        }
        return $config_db;
    }

    /**
     * Get current database name
     *
     * @return string
     */
    public function getConnection(): string
    {
        return $this->connection;
    }

    /**
     * Convert class name for snake case
     *
     * @return  string
     */
    private function classToShake(): string
    {
        $className = \get_class($this);
        $classArray = explode('\\', $className);
        $class = end($classArray);
        try {
            $class = Stringy::create($class)->underscored();
        } catch (\InvalidArgumentException $e) {
            new Exception('Invalid argument provided');
        }
        return $class;
    }

    /**
     * Get current collection
     *
     * @return  string|null
     */
    public function getCollection()
    {
        return $this->collection ?? $this->classToShake();
    }

    /**
     * Set name of collection for queries
     *
     * @param   null|string $collection
     * @return  ModelInterface
     */
    public function setCollection(string $collection): ModelInterface
    {
        $this->collection = $collection;
        return $this;
    }

    /**
     * Set database instance
     *
     * @param   QueryInterface $instance
     */
    private function setInstance(QueryInterface $instance)
    {
        $this->_instance = $instance;
    }

    /**
     * Get database instance
     *
     * @return QueryInterface
     */
    public function getInstance(): QueryInterface
    {
        return $this->_instance;
    }

    public function update(array $data, array $where = [])
    {
        return $this->getInstance()->update($data, $where);
    }

    public function delete(array $where)
    {
        return $this->getInstance()->delete($where);
    }

    public function exec(string $query)
    {
        return $this->getInstance()->exec($query);
    }

    public function insert(array $data)
    {
        return $this->getInstance()->insert($data);
    }

    public function select(string $query, array $data = [])
    {
        return $this->getInstance()->select($query, $data);
    }

    public function truncate()
    {
        return $this->getInstance()->truncate();
    }
}