Borobudur\Cqrs\ReadModel\Storage\Pdo\PdoConfig

Complexity

Total Complexity

11

Size/Duplication

Total Lines	157
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	getDsn()	0	4	1
A	getEngine()	0	4	1
A	getHost()	0	4	1
A	getPort()	0	4	1
A	getDatabase()	0	4	1
A	getUser()	0	4	1
A	getPass()	0	4	1
A	getParser()	0	4	1
A	createParser()	0	9	2

<?php
/*
 * This file is part of the Borobudur-Cqrs package.
 *
 * (c) Hexacodelabs <http://hexacodelabs.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Borobudur\Cqrs\ReadModel\Storage\Pdo;

use Borobudur\Cqrs\ReadModel\Storage\Pdo\Parser\ParserInterface;
use Borobudur\Cqrs\ReadModel\Storage\Pdo\Parser\DefaultParser;
use Borobudur\Cqrs\ReadModel\Storage\Pdo\Parser\PostgresParser;

/**
 * @author      Iqbal Maulana <iq.bluejack@gmail.com>
 * @created     8/18/15
 */
class PdoConfig
{
    /**
     * @var string
     */
    private $dsn;

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

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

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

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

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

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

    /**
     * @var ParserInterface
     */
    private $parser;

    /**
     * Constructor.
     *
     * @param string      $engine
     * @param string      $host
     * @param int         $port
     * @param string      $database
     * @param string|null $user
     * @param string|null $pass
     */
    public function __construct($engine, $host, $port, $database, $user = null, $pass = null)
    {
        $this->dsn = sprintf('%s:dbname=%s;host=%s;port=%d', $engine, $database, $host, $port);
        $this->engine = $engine;
        $this->host = $host;
        $this->port = $port;
        $this->database = $database;
        $this->user = $user;
        $this->pass = $pass;
        $this->parser = $this->createParser();
    }

    /**
     * Get dsn.
     *
     * @return string
     */
    public function getDsn()
    {
        return $this->dsn;
    }

    /**
     * Get engine.
     *
     * @return string
     */
    public function getEngine()
    {
        return $this->engine;
    }

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

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

    /**
     * Get database.
     *
     * @return string
     */
    public function getDatabase()
    {
        return $this->database;
    }

    /**
     * Get user.
     *
     * @return string|string
     */
    public function getUser()
    {
        return $this->user;
    }

    /**
     * Get pass.
     *
     * @return string|null
     */
    public function getPass()
    {
        return $this->pass;
    }

    /**
     * Get parser.
     *
     * @return ParserInterface
     */
    public function getParser()
    {
        return $this->parser;
    }

    /**
     * @return ParserInterface
     */
    protected function createParser()
    {
        switch(strtolower($this->engine)) {
            case 'pgsql':
                return new PostgresParser();
        }

        return new DefaultParser();
    }
}