DrMVC\Database\Database

Complexity

Total Complexity

10

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getConfig()	0	5	2
A	__construct()	0	3	1
A	getInstance()	0	9	2
A	setConfig()	0	4	1
A	getDriver()	0	19	4

<?php

namespace DrMVC\Database;

use DrMVC\Config\ConfigInterface;
use DrMVC\Database\Interfaces\DatabaseInterface;
use DrMVC\Database\Drivers\Interfaces\QueryInterface;
use MongoDB\Driver\Manager;
use PDO;

/**
 * Class for work with databases
 *
 * @package Modules\Database\Core
 * @since   3.0
 */
class Database implements DatabaseInterface
{
    /**
     * @var ConfigInterface
     */
    private $_config;

    /**
     * Database constructor.
     *
     * @param   ConfigInterface $config
     */
    public function __construct(ConfigInterface $config)
    {
        $this->setConfig($config);
    }

    /**
     * @param   string $collection
     * @return  QueryInterface|PDO|Manager
     */
    public function getInstance(string $collection = null)
    {
        $class = $this->getDriver();
        $instance = new $class($this->getConfig(), $collection);

        // If collection name is not provided then need return clean instance for ORM
        return (null !== $collection)
            ? $instance->connect()
            : $instance->connect()->getInstance();
    }

    /**
     * Get driver of current database
     *
     * @return  string
     */
    public function getDriver(): string
    {
        // Extract driver name from current config
        $driver = $this->getConfig('driver');

        try {
            if (!\is_string($driver)) {
                throw new Exception('Wrong type of "driver" item in config, must be a string');
            }

            if (!\in_array($driver, self::ALLOWED_DRIVERS, false)) {
                $allowed = implode(',', self::ALLOWED_DRIVERS);
                throw new Exception("Driver \"$driver\" is not in allowed list [" . $allowed . ']');
            }
        } catch (Exception $e) {
            // __constructor
        }

        return __NAMESPACE__ . '\\Drivers\\' . ucfirst(strtolower($driver));
    }

    /**
     * Set configuration of database
     *
     * @param   ConfigInterface $config
     * @return  DatabaseInterface
     */
    public function setConfig(ConfigInterface $config): DatabaseInterface
    {
        $this->_config = $config;
        return $this;
    }

    /**
     * Get database configuration object or array with single database
     *
     * @param   string|null $name
     * @return  mixed
     */
    public function getConfig(string $name = null)
    {
        return (null !== $name)
            ? $this->_config->get($name)
            : $this->_config;
    }

}