MocOrm\Connection\Connection

Complexity

Total Complexity

19

Size/Duplication

Total Lines	203
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	getCurrentConnectionString()	0	3	1
A	getAppLogger()	0	2	1
A	beginTransaction()	0	4	1
A	closeConnection()	0	2	1
A	getSchema()	0	3	1
A	getPerformedQuery()	0	3	1
A	getDriver()	0	3	1
A	__construct()	0	11	1
A	rollbackTransaction()	0	4	1
A	commitTransaction()	0	4	1
A	getLastPerformedQuery()	0	3	1
A	setPerformedQuery()	0	5	1
A	changeSchema()	0	7	3
A	setConnection()	0	20	2
A	getConnection()	0	3	1
A	setAppLogger()	0	4	1

<?php

namespace MocOrm\Connection;

class Connection
{
    /**
     * This instance object
     * @var Connection \Connection
     */
    private static $_instance;

    /**
     * This is instance current connect object connected
     * @var \PDO $_connection
     */
    private $_connection;

    /**
     * @currentConnectionName string of the current connection name
     */
    private $_currentConnectionString;

    private $connectionString;
    private $driver;
    private $username;
    private $password;
    private $charset;
    private $schema;
    private $options;

    /**
     * This save all query orm use.
     * @var Array Query strings
     */
    private $performed_query = [];

    /**
     * Initialize the object or return this object if have value set in attribute $_instance
     * @return Connection
     */
    public function __construct($config)
    {
        $this->connectionString = $config['connectionString'];
        $this->driver = $config['driver'];
        $this->username = $config['username'];
        $this->password = $config['password'];
        $this->charset = $config['charset'];
        $this->schema = $config['schema'];

        self::$_instance = $this;
        return $this;
    }

    /**
     * Initialize the connection
     * @param string $connectionName name on connection
     * @return $this This object from other interator
     * @throws \Exception if the connect name haven't set;
     */
    public function setConnection()
    {
        $this->_currentConnectionString = $this->connectionString;

        try {
            $this->_connection = new \PDO(
                $this->connectionString,
                $this->username,
                $this->password
            );

            $charsetQuery = "set names '$this->charset'";

            $this->_connection->query($charsetQuery);

        } catch (\Exception $e) {
            throw new \Exception($e->getMessage(), $e->getCode());
        }

        return $this;
    }

    /**
     * Get name on current connection
     * @return string name on current connection or null if don't have
     */
    final public function getCurrentConnectionString()
    {
        return $this->_currentConnectionString;
    }

    /**
     * Get PDO of current connection
     * @return \PDO
     */
    public function getConnection()
    {
        return $this->_connection;
    }

    /**
     * Close current connection
     */
    public function closeConnection() {
        $this->_connection = null;
    }

    /**
     * @return Array query
     */
    public function getPerformedQuery()
    {
        return $this->performed_query;
    }

    /**
     * @return String query
     */
    public function getLastPerformedQuery()
    {
        return end($this->performed_query);
    }

    /**
     * @param String $query
     * @param String $time
     * @return $this
     */
    public function setPerformedQuery(String $query, String $time)
    {
        $this->performed_query[] = ['query' => $query, 'time' => $time];

        return $this;
    }

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

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

    /**
     * Open transaction for insert, update, delete.
     * @return $this
     */
    final public function beginTransaction()
    {
        $this->_connection->beginTransaction();
        return $this;
    }

    /**
     * Using commit to all actions executed after begin transaction
     * @return $this
     */
    final public function commitTransaction()
    {
        $this->_connection->commit();
        return $this;
    }

    /**
     * Using rollback to all actions executed after begin transaction
     * @return $this
     */
    final public function rollbackTransaction()
    {
        $this->_connection->rollBack();
        return $this;
    }

    /**
     * Change schema on postgres
     * @param String $schema schema name
     * @return $this
     */
    final public function changeSchema($schema = null)
    {
        if (!is_string($schema)) throw new \InvalidArgumentException('The parameter don\'t is an String.');
        if ($this->driver == 'mysql') throw new \InvalidArgumentException('This driver not supported schemas.');

        $this->getConnection()->exec("SET search_path TO '$schema';");
        return $this;
    }

    /**
     * @param bool $logger
     * @return Connection
     */
    final public function setAppLogger($logger) {
        $this->options['appLogger'] = $logger;

        return $this;
    }

    final public function getAppLogger() {
        return $this->options['appLogger'];
    }
}