Opeyemiabiodun\PotatoORM\Connections\MySqlConnection

Complexity

Total Complexity

8

Size/Duplication

Total Lines	73
Duplicated Lines	26.03 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	5
Bugs	0	Features	2

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	2
A	getColumns()	11	11	2
A	getPdo()	0	4	1
A	getPrimaryKey()	8	8	2
A	load()	0	4	1

<?php

namespace Opeyemiabiodun\PotatoORM\Connections;

use PDO;
use PDOException;
use InvalidArgumentException;
use Opeyemiabiodun\PotatoORM\Connections\Connection;
use Opeyemiabiodun\PotatoORM\Connections\LoadEnvVariablesTrait;
use Opeyemiabiodun\PotatoORM\Connections\DatabaseTransactionsTrait;

final class MySqlConnection implements Connection
{
    use LoadEnvVariablesTrait, DatabaseTransactionsTrait;

    /**
     * The method called in the constructor.
     *
     * @return void

Adding a @return annotation to constructors is generally not recommended as a constructor does not have a meaningful return value.

     */
    private function __construct()
    {
        $this->useDbEnv();

        $dsn = 'mysql:host='.$this->_host
                .';port='.$this->_port
                .';dbname='.$this->_database;

        try {
            $this->_pdo = new PDO($dsn, $this->_username, $this->_password);

It seems like new \PDO($dsn, $this->_username, $this->_password) of type object<PDO> is incompatible with the declared type object<Opeyemiabiodun\PotatoORM\Connections\PDO> of property $_pdo.

        } catch (PDOException $e) {

Consider adding a comment why this CATCH block is empty.

        }
    }

    /**
     * Returns the columns of a table.
     *
     * @param string $table The table inspected for its columns.
     *
     * @return array The columns of the table.        
     */
    public function getColumns($table)

This method seems to be duplicated in your project.

    {
        if (gettype($table) !== 'string') {
            throw new InvalidArgumentException("The parameter {$table} is not an string. A string is required instead.");
        }

        return $this->getPdo()->query("SELECT COLUMN_NAME
                                        FROM INFORMATION_SCHEMA.COLUMNS
                                        WHERE TABLE_NAME = N'{$table}' 
                                        AND TABLE_SCHEMA = N'{$this->_database}'")->fetchAll();
    }

    /**
     * Returns the Connection's PDO.
     *
     * @return PDO PHP Data Objects
     */
    public function getPdo()
    {
        return $this->_pdo;
    }

    /**
     * Returns the primary key of a table.
     *
     * @param string $table The table inspected for its primary key.
     *
     * @return string The primary key of the table.
     */
    public function getPrimaryKey($table)

This method seems to be duplicated in your project.

    {
        if (gettype($table) !== 'string') {
            throw new InvalidArgumentException("The parameter {$table} is not an string. A string is required instead.");
        }

        return $this->getPdo()->query("SHOW KEYS FROM {$table} WHERE Key_name = 'PRIMARY'")->fetchAll()[0]['Column_name'];
    }

    public static function load()
    {
        return new MySqlConnection();
    }
}