Connection::setAppLogger() - Code Metrics - Inspection of "Merge branch 'Results'" - maikees/moc-orm - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( d50d64...3e68ba )

by Maike

created 2017-10-25 13:47 UTC

Connection::setAppLogger() A

↳ Parent: Connection

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

Metric	Value
cc	1
eloc	2
nc	1
nop	1
dl	0
loc	4
ccs	0
cts	3
cp	0
crap	2
rs	10
c	0
b	0
f	0

<?php

namespace MocOrm\Connection;


use phpDocumentor\Reflection\Types\Boolean;

class Connection
{
    /**
     * This instance object
     * @var Connection.
     */

    private static $_instance;

    /**
     * This is instance current connect object connected
     * @var PDO

     */
    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.
filter:
    dependency_paths: ["lib/*"]
     * @var query string
     */
    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;
    }

    /**
     * Initialize the connection
     * @return $this
     * @throws \Exception
     */
    public function connection($connectionString, $username, $password)
    public function connection($connectionString, /** @scrutinizer ignore-unused */ $username, $password)
    {
        if (is_null($this->getCurrentConnectionName())) throw new \Exception('Conexão não setada.');
        if (is_null($this->/** @scrutinizer ignore-call */ getCurrentConnectionName())) throw new \Exception('Conexão não setada.');

        try {
            $connectionName = $this->getCurrentConnectionName();

            $this->_connection = new \PDO(

                $this->_connectionString[$connectionName],

                $this->_username[$connectionName],

                $this->_password[$connectionName]

            );

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

        return $this;
    }

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

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

    /**
     * @return query
     */
    public function getLastPerformedQuery()
    {
        return end($this->performed_query);
        return end(/** @scrutinizer ignore-type */ $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
filter:
    dependency_paths: ["lib/*"]
     * @param $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'];
    }
}


maikees / moc-orm

Push — master ( d50d64...3e68ba )

Connection::setAppLogger() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like