MocOrm\Connection\Connection::connection()

Complexity

Conditions	3
Paths	1

Size

Total Lines	18
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	12

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	Connection::getLastPerformedQuery()	0	3	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;
    }

    public function getConnection()
    {
        return $this->_connection;
    }

    /**
     * @return query

The type MocOrm\Connection\query was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    public function getPerformedQuery()
    {
        return $this->performed_query;

The expression return $this->performed_query returns the type array which is incompatible with the documented return type MocOrm\Connection\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): Connection {
        $this->options['appLogger'] = $logger;

        return $this;
    }


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