Opeyemiabiodun\PotatoORM\Connections\SqliteConnection

Complexity

Total Complexity

10

Size/Duplication

Total Lines	104
Duplicated Lines	19.23 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

75.86%

Importance

Changes	2
Bugs	1	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getPdo()	0	4	1
A	__construct()	0	9	2
A	getColumns()	10	10	2
A	getPrimaryKey()	10	10	2
A	loadColumnInfo()	0	17	3

<?php

namespace Opeyemiabiodun\PotatoORM\Connections;

use PDO;
use PDOException;
use InvalidArgumentException;

final class SqliteConnection implements Connection
{
    use DatabaseTransactionsTrait;

    /**
     * $_pdo The PDO instance of the connection.
     *
     * @var PDO
     */
    private $_pdo;

    /**
     * $columns Columns of the database table.
     *
     * @var array
     */
    private $columns = [];

    /**
     * $keys Keys of the database table.
     *
     * @var array
     */
    private $keys = [];

    /**
     * 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.

     */
    public function __construct()
    {
        $dsn = 'sqlite:../../potatodb.sq3';

        try {
            $this->_pdo = new PDO($dsn);
        } 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.");
        }

        $this->loadColumnInfo($table);

        return $this->columns[$table];
    }

    /**
     * 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.");
        }

        $this->loadColumnInfo($table);

        return $this->keys[$table][0];
    }

    private function loadColumnInfo($table)
    {
        $query = "PRAGMA table_info('{$table}')";
        $statement = $this->_pdo->query($query);

        /* @var $statement PDOStatement */
        $this->columns[$table] = [];
        $this->keys[$table] = [];

        while ($columnData = $statement->fetch(PDO::FETCH_NUM)) {
            $this->columns[$table][] = ['column_name' => $columnData[1]];

            if ($columnData[5] == 1) {
                $this->keys[$table][] = $columnData[1];
            }
        }
    }
}