Rentgen\Database\Connection\Connection

Complexity

Total Complexity

7

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	6
Bugs	2	Features	2

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	execute()	0	4	1
A	query()	0	9	2
A	getConnection()	0	13	3

<?php

namespace Rentgen\Database\Connection;

class Connection
{
    private $connection;
    private $config;

    /**
     * Constructor.
     *
     * @param ConnectionConfigInterface $config Connection config.
     */
    public function __construct(ConnectionConfigInterface $config)
    {
       $this->config = $config;
    }

    /**
     * Execute sql query.
     *
     * @param string $sql Sql query.
     *
     * @return integer
     */
    public function execute($sql)
    {
        return $this->getConnection()->exec($sql);
    }

    /**
     * Execute sql and expect return a data.
     *
     * @param string $sql Sql query.
     *
     * @return array
     */
    public function query($sql)
    {
        $rows = array();
        foreach ($this->getConnection()->query($sql) as $row) {
            $rows[] = $row;
        }

        return $rows;
    }

    private function getConnection()
    {
        if (null === $this->connection) {
            try {
                $this->connection = new \PDO($this->config->getDsn(), $this->config->getUsername(), $this->config->getPassword(),
                    array(\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION));
            } catch (\PDOException $exception) {
                throw new \InvalidArgumentException($exception->getMessage());
            }
        }

        return $this->connection;
    }
}