EmmetBlue\Core\Connection\Adapters\MySQL

Complexity

Total Complexity

9

Size/Duplication

Total Lines	104
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setDsn()	4	4	1
A	connect()	28	28	4
A	getConnection()	14	14	2
A	disableConnection()	4	4	1
A	setAttribute()	4	4	1

<?php declare(strict_types=1);
/**
 * @license MIT
 * @author Samuel Adeshina <samueladeshina73@gmail.com>
 *
 * This file is part of the EmmetBlue project, please read the license document
 * available in the root level of the project
 */
namespace EmmetBlue\Core\Connection\Adapters;

use EmmetBlue\Core\Connection\ConnectableInterface;
use EmmetBlue\Core\Exception\SQLException;

/**
 * class ConnectionAdapter.
 * Instantiates a new instance of ConnectableInterface
 *
 * @author Samuel Adeshina <samueladeshina73@gmail.com>
 *
 * @since v0.0.1 08/06/2016 14:20
 */
class MySQL implements ConnectableInterface

This class seems to be duplicated in your project.

{
    /**
     * @var string $dsn
     */
    protected $dsn;

    /**
     * @var \PDO $connectionObject
     */
    protected $connectionObject;

    /**
     * @var array loginData
     */
    private $loginData = [];

    /**
     * Setter for the DSN string {@see $dsn}
     *
     * @param array $dsnArray
     * @return void
     */
    public function setDsn(array $dsnArray)
    {
        $this->dsn = $dsnArray;

It seems like $dsnArray of type array is incompatible with the declared type string of property $dsn.

    }

    /**
     * Establishes connection
     *
     * @param string $username
     * @param string $password optional
     * @throws \EmmetBlue\Core\Exception\SQLException
     * @return void
     */
    public function connect(string $username, string $password="")
    {
        $host = $this->dsn[0];
        $database = $this->dsn[1];

        $this->loginData['username'] = $username;
        $this->loginData['password'] = $password;

        try
        {
            $this->connectionObject = new \PDO("mysql:host=$host;dbname=$database;", $username, $password);
        }
        catch (\PDOException $e)
        {
            throw new SQLException("Unable to connect to database", 400, $e);  

The call to SQLException::__construct() has too many arguments starting with $e.

        }

        $dsn = $this->dsn;
        unset($dsn[0], $dsn[1]);
        
        foreach ($dsn as $attribute)

The expression $dsn of type string is not traversable.

        {
            foreach ($attribute as $key=>$value)
            {
                $this->connectionObject->setAttribute($key, $value);
            }
        }
    }

    /**
     * Returns an instance a pdo intance of the connection object
     *
     * @return \PDO
     */
    public function getConnection() : \PDO
    {
        if ($this->connectionObject instanceof \PDO)
        {
            return $this->connectionObject;
        }

        $this->connect(
            $this->loginData['username'] ?? '',
            $this->loginData['password'] ?? ''
        );

        return $this->connectionObject;
    }

    /**
     * Closes connection
     */
    public function disableConnection()
    {
        $this->connectionObject = null;
    }

    /**
     * Sets attributes for the PDO object
     *
     * @param \PDO $attribute
     * @param \PDO $value
     */
    public function setAttribute(\PDO $attribute, \PDO $value)
    {
         $this->connectionObject->setAttribute($attribute, $value);
    }
}