mindplay\sql\framework\pdo\PDOProvider

Complexity

Total Complexity

12

Size/Duplication

Total Lines	146
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

84.38%

Importance

Changes	1
Bugs	0	Features	1

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	23	3
A	getPDO()	0	8	2
A	getDBMS()	0	4	1
A	getDSN()	0	4	1
A	getUsername()	0	4	1
A	getPassword()	0	4	1
A	getOptions()	0	4	1
A	getHost()	0	4	1
A	getPort()	0	4	1

<?php

namespace mindplay\sql\framework\pdo;

use InvalidArgumentException;
use PDO;

/**
 * This class implements a provider layer over PDO.
 *
 * You don't need to use this layer - the framework itself has no dependency on it, but you
 * may find it useful as a means of addressing certain issues with `PDO`.
 * 
 * For one, `PDO` instances cannot be created without immediately opening the connection - this
 * provider does not construct `PDO` and open the connection until you ask for the `PDO` instance.
 *
 * Also, `PDO` has no ability to report properties like database-name, username, etc. if you need them.
 */
class PDOProvider
{
    /**
     * @var string
     */
    private $type;

    /**
     * @var string
     */
    private $dsn;

    /**
     * @var string
     */
    private $username;
    
    /**
     * @var string
     */
    private $password;

    /**
     * @var array
     */
    private $options;

    /**
     * @var string
     */
    private $host;

    /**
     * @var string
     */
    private $port;

    /**
     * @var PDO|null
     */
    private $pdo;

    const DBMS_POSTGRES = "pgsql";
    const DBMS_MYSQL    = "mysql";

    /**
     * @param string   $dbms    database type; one of the DBMS_* class constants
     * @param string   $dbname  name of the database to connect to
     * @param string   $username
     * @param string   $password
     * @param array    $options PDO constructor options
     * @param string   $host    optional hostname; defaults to "localhost"
     * @param int|null $port    optional port-number; defaults to the standard port-number for the given $db type
     */
    public function __construct($dbms, $dbname, $username, $password, $options = [], $host = 'localhost', $port = null)
    {
        static $default_port = [
            self::DBMS_MYSQL    => 3306,
            self::DBMS_POSTGRES => 5432,
        ];

        if (!isset($default_port[$dbms])) {
            throw new InvalidArgumentException("unsupported DBMS type: {$dbms}");
        }

        if ($port === null) {
            $port = $default_port[$dbms];
        }
        
        $this->type = $dbms;
        $this->dsn = "{$dbms}:host={$host};port={$port};dbname={$dbname}";
        $this->username = $username;
        $this->password = $password;
        $this->options = $options;
        $this->host = $host;
        $this->port = $port;
    }
    
    /**
     * @return PDO
     */
    public function getPDO()
    {
        if (!isset($this->pdo)) {
            $this->pdo = new PDO($this->dsn, $this->username, $this->password, $this->options);
        }
        
        return $this->pdo;
    }

    /**
     * @return string one of the DBMS_* class constants
     */
    public function getDBMS()
    {
        return $this->type;
    }
    
    /**
     * @return string
     */
    public function getDSN()
    {
        return $this->dsn;
    }

    /**
     * @return string
     */
    public function getUsername()
    {
        return $this->username;
    }

    /**
     * @return string
     */
    public function getPassword()
    {
        return $this->password;
    }

    /**
     * @return array
     */
    public function getOptions()
    {
        return $this->options;
    }

    /**
     * @return string
     */
    public function getHost()
    {
        return $this->host;
    }

    /**
     * @return string
     */
    public function getPort()
    {
        return $this->port;
    }
}