Inji\Db

Complexity

Total Complexity

36

Size/Duplication

Total Lines	137
Duplicated Lines	17.52 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
C	init()	0	30	8
A	loadMigrationsVersion()	0	10	3
C	compareMigrations()	0	22	7
A	makeMigration()	0	12	3
B	__call()	0	16	5
A	newQuery()	0	6	2
A	__get()	11	11	4
A	__set()	11	11	4

<?php

namespace Inji;
class Db extends Module {
    public $name = 'Db';
    public $connection = null;
    public $connect = false;
    public $dbConfig = [];
    public $curQuery = null;
    public $className = '';
    public $QueryClassName = '';
    public $ResultClassName = '';
    public $migrationsVersions = [];

    public function init($param = 'default') {
        if (!$param || $param === 'default') {
            $param = isset($this->config['default']) ? $this->config['default'] : 'local';
        }
        if ($param === 'injiStorage') {
            $db = [
                'driver' => 'InjiStorage'
            ];
        } else if (!is_array($param)) {
            if (!($dbOption = Db\Options::sharedStorage()->where($param, 'connect_alias')->get(['array' => true]))) {

'connect_alias' is of type string, but the function expects a boolean.

                return false;
            }
            $db = $dbOption;
        } else {
            $db = $param;
        }

        $className = 'Inji\Db\\' . $db['driver'];
        $this->connection = new $className();
        if (method_exists($className, 'init')) {
            $this->connection->init($db);
        }
        $this->connection->dbInstance = $this;
        $this->connect = $this->connection->connect;
        $this->dbConfig = $db;

        $this->className = 'Inji\Db\\' . $this->dbConfig['driver'];
        $this->QueryClassName = 'Inji\Db\\' . $this->dbConfig['driver'] . '\\Query';
        $this->ResultClassName = 'Inji\Db\\' . $this->dbConfig['driver'] . '\\Result';
    }

    public function loadMigrationsVersion($code) {
        if (!$this->connect) {
            return false;
        }
        $version = Db\Migration::getList(['where' => ['code', $code], 'order' => ['date_create', 'desc'], 'limit' => 1, 'key' => false]);
        if ($version) {

The expression $version of type Inji\Model[] is implicitly converted to a boolean; are you sure this is intended? If so, consider using ! empty($expr) instead to make it clear that you intend to check for an array without elements.

            $this->migrationsVersions[$code] = $version[0]->version;
        }
        return true;
    }

    public function compareMigrations($code, $migrations) {
        if (!isset($this->migrationsVersions[$code])) {
            $this->loadMigrationsVersion($code);
        }
        if (!isset($this->migrationsVersions[$code]) || !isset($migrations[$this->migrationsVersions[$code]])) {
            return $migrations;
        }
        $startVersion = $this->migrationsVersions[$code];
        end($migrations);
        if ($startVersion == key($migrations)) {
            return [];
        }
        $pos = 0;
        foreach ($migrations as $migrationVersion => $migration) {
            $pos++;
            if ($startVersion == $migrationVersion) {
                return array_slice($migrations, $pos, null, true);
            }

        }
        return [];
    }

    public function makeMigration($code, $version, $migration) {
        if (!isset($migration['up'])) {
            return false;
        }
        if (is_callable($migration['up'])) {
            $migration['up']();
        }
        $this->migrationsVersions[$code] = $version;
        $migrationVersion = new Db\Migration(['code' => $code, 'version' => $version]);
        $migrationVersion->save();
        return true;
    }

    public function __call($name, $params) {
        if (!is_object($this->connection)) {
            return false;
        }
        if (method_exists($this->className, $name)) {
            return call_user_func_array(array($this->connection, $name), $params);
        }
        if (method_exists($this->QueryClassName, $name)) {
            if (!is_object($this->curQuery)) {
                $this->curQuery = new $this->QueryClassName($this->connection);
            }
            return call_user_func_array(array($this->curQuery, $name), $params);
        }

        return false;
    }

    public function newQuery() {
        if ($this->QueryClassName) {
            return new $this->QueryClassName($this->connection);
        }
        return false;
    }

    public function __get($name) {
        if (isset($this->connection->$name)) {
            return $this->connection->$name;
        }
        if (!is_object($this->curQuery)) {
            $this->curQuery = $this->newQuery();
        }
        if (isset($this->curQuery->$name)) {
            return $this->curQuery->$name;
        }
    }

    public function __set($name, $value) {
        if (isset($this->connection->$name)) {
            return $this->connection->$name = $value;
        }
        if (!is_object($this->curQuery)) {
            $this->curQuery = $this->newQuery();
        }
        if (isset($this->curQuery->$name)) {
            return $this->curQuery->$name = $value;
        }
    }
}