DrMVC\Database\Drivers\Mysql

Complexity

Total Complexity

6

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	genDsn()	0	10	3
A	connect()	0	16	2
A	getOptions()	0	10	1

<?php

namespace DrMVC\Database\Drivers;

use DrMVC\Database\SQLException;

class Mysql extends SQL
{
    const DEFAULT_HOST = '127.0.0.1';
    const DEFAULT_PORT = '3306';
    const DEFAULT_CHARSET = 'utf8';
    const DEFAULT_COLLATION = 'utf8_unicode_ci';

    /**
     * @link https://secure.php.net/manual/en/ref.pdo-mysql.connection.php
     *
     * The PDO_MYSQL Data Source Name (DSN) is composed of the following elements:
     */
    const AVAILABLE_ELEMENTS = [
        'host',
        'port',
        'dbname',
        'unix_socket'
    ];

    /**
     * Generate DSN by parameters in config
     *
     * @param   array $config
     * @return  string
     */
    public function genDsn($config): string
    {
        // Parse config
        $dsn = '';
        foreach ($config as $key => $value) {
            if (\in_array($key, self::AVAILABLE_ELEMENTS, false)) {
                $dsn .= "$key=$value;";
            }
        }
        return $dsn;
    }

    /**
     * Initiate connection to database
     *
     * @return  DriverInterface
     */
    public function connect(): DriverInterface
    {
        $connection = null;

The assignment to $connection is dead and can be removed.

        try {
            $connection = new \PDO(
                $this->getDsn(),
                $this->getParam('username'),
                $this->getParam('password'),
                $this->getOptions()
            );
        } catch (SQLException $e) {
            // __construct
        }

        $this->setConnection($connection);
        return $this;
    }

    private function getOptions(): array
    {
        // Current charset
        $charset = $this->getParam('charset') ?? self::DEFAULT_CHARSET;

        // Current collation
        $collation = $this->getParam('collation') ?? self::DEFAULT_COLLATION;

        // Return array of options
        return [\PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES '$charset' COLLATE '$collation'"];
    }

}