samson\activerecord\dbMySQL

Complexity

Total Complexity

93

Size/Duplication

Total Lines	759
Duplicated Lines	2.37 %

Coupling/Cohesion

Components	2
Dependencies	4

Importance

Changes	50
Bugs	16	Features	16

20 Methods

Rating	Name	Duplication	Size	Complexity
A	debug()	0	8	2
C	getQueryFields()	0	32	7
C	createObject()	0	42	7
B	createField()	0	29	5
B	__get_table_data()	0	46	2
A	create()	0	15	1
A	delete()	0	6	1
A	find_by_id()	0	22	2
A	protectQueryValue()	0	13	2
A	simple_query()	0	4	1
B	profiler()	0	24	3
B	getConditions()	0	24	4
C	parseCondition()	0	44	11
D	toRecords()	0	145	13
B	find()	0	26	4
B	migration()	0	38	6
A	innerCount()	0	13	1
C	prepareSQL()	6	73	12
C	prepareInnerSQL()	12	37	8
A	update_old()	0	9	1

<?php
namespace samson\activerecord;

use samsonframework\orm\QueryInterface;
use samsonframework\orm\ConditionInterface;

/**
 * Класс описывающий работу с MySQL
 * @author Vitaly Iegorov <vitalyiegorov@gmail.com>
 * @author Nikita Kotenko <nick.w2r@gmail.com>
 *
 */
class dbMySQL extends dbMySQLConnector

This class is not in CamelCase format.

There is at least one abstract method in this class. Maybe declare it as abstract, or implement the remaining methods: fetchObjectsWithJoin, insert, update

{
    /**
     * Количество запросов класса
     * @var integer
     */
    private $query_count = 0;

    /** Show hide query debug information */
    public function debug($flag = true)
    {
        if ($flag) {
            $_SESSION['__AR_SHOW_QUERY__'] = true;
        } else {
            unset($_SESSION['__AR_SHOW_QUERY__']);
        }
    }

    /**
     * Check object $field field value as $table column
     * and if database table does not have it - create.
     * $field is not set in object - error returns
     *
     * @param object $object Pointer to object to get field names data
     * @param string $table Database table name
     * @param string $field Object field name
     * @param string $type Database column name
     *
     * @return bool True if database table has field or field has been created
     */
    public function createField($object, $table, $field, $type = 'INT')
    {
        // Check if db identifier field is configured
        if (class_exists($table)) {
            if (strlen($object->$field)) {
                // Variable to get all social table attributes
                $attributes = array();
                // Get table attributes - PHP 5.2 compatible
                eval('$attributes = ' . $table . '::$_table_attributes;');
                // Get table name - PHP 5.2 compatible
                eval('$table = ' . $table . '::$_table_name;');

                // Make keys lowercase
                $attributes = array_change_key_case_unicode($attributes);
                $field = strtolower($object->$field);

                // If table does not have defined identifier field
                if (!array_key_exists($field, $attributes) && !in_array($field, $attributes)) {
                    // Add identifier field to social users table
                    $this->simple_query('ALTER TABLE  `' . $table . '` ADD  `' . $field . '` ' . $type . ' ');

The method samson\activerecord\dbMySQL::simple_query() has been deprecated with message: Use execute()

                }

                return true;

Blank line found at end of control structure

            } else { // Signal error
                return e('Cannot load "' . get_class($object) . '" module - no $' . $field . ' is configured');

The function e() has been deprecated with message: Use custom exceptions

            }
        }
    }

    // TODO: Очень узкое место для совместимости с 5.2 !!!
    /**
     * Обратная совместить с PHP < 5.3 т.к. там нельзя подставлять переменное имя класса
     * в статическом контексте
     * @param unknown_type $class_name
     */
    public function __get_table_data($class_name)

Method name "dbMySQL::__get_table_data" is not in camel caps format

    {
        // Remove table prefix
        $class_name = str_replace(self::$prefix, '', $class_name);

        // Сформируем правильное имя класса
        $class_name = strpos($class_name, '\\') !== false ? $class_name : '\samson\activerecord\\'.$class_name;

        // Сформируем комманды на получение статических переменных определенного класса
        $_table_name = '$_table_name = ' . $class_name . '::$_table_name;';
        $_own_group = '$_own_group = ' . $class_name . '::$_own_group;';
        $_table_attributes = '$_table_attributes = ' . $class_name . '::$_table_attributes;';
        $_primary = '$_primary = ' . $class_name . '::$_primary;';
        $_sql_from = '$_sql_from = ' . $class_name . '::$_sql_from;';
        $_sql_select = '$_sql_select = ' . $class_name . '::$_sql_select;';
        $_attributes = '$_attributes = ' . $class_name . '::$_attributes;';
        $_types = '$_types = ' . $class_name . '::$_types;';
        $_map = '$_map = ' . $class_name . '::$_map;';
        $_relations = '$_relations = ' . $class_name . '::$_relations;';
        $_unique = '$_unique = ' . $class_name . '::$_unique;';
        $_relation_type = '$_relation_type = ' . $class_name . '::$_relation_type;';
        $_relation_alias = '$_relation_alias = ' . $class_name . '::$_relation_alias;';

        //trace($_table_name.$_primary.$_sql_from.$_sql_select.$_map.$_attributes.$_relations.$_relation_type.$_types.$_unique);

        // Выполним специальный код получения значений переменной
        eval($_own_group . $_table_name . $_primary . $_sql_from . $_sql_select . $_map . $_attributes . $_relations . $_relation_type . $_relation_alias . $_types . $_unique . $_table_attributes);

        // Вернем массив имен переменных и их значений
        return array
        (
            '_table_name' => $_table_name,
            '_own_group' => $_own_group,
            '_primary' => $_primary,
            '_attributes' => $_attributes,
            '_table_attributes' => $_table_attributes,
            '_types' => $_types,
            '_map' => $_map,
            '_relations' => $_relations,
            '_relation_type' => $_relation_type,
            '_relation_alias' => $_relation_alias,
            '_sql_from' => $_sql_from,
            '_sql_select' => $_sql_select,
            '_unique' => $_unique,
        );
    }

    public function create($className, &$object = null)
    {
        // ??
        $fields = $this->getQueryFields($className, $object);
        // Build SQL query
        $sql = 'INSERT INTO `' . $className::$_table_name . '` (`'
            . implode('`,`', array_keys($fields)) . '`)
            VALUES (' . implode(',', $fields) . ')';

        // TODO: CRITICAL FOR HIGHLOAD NEEDS DECISION!
        $result = $this->execute($sql);

$result is not used, you could remove the assignment.

        // Return last inserted row identifier
        return $this->driver->lastInsertId();
    }

    public function update_old($className, &$object)

Method name "dbMySQL::update_old" is not in camel caps format

    {
        // ??
        $fields = $this->getQueryFields($className, $object, true);
        // Build SQL query
        $sql = 'UPDATE `' . $className::$_table_name . '` SET ' . implode(',',
                $fields) . ' WHERE ' . $className::$_table_name . '.' . $className::$_primary . '="' . $object->id . '"';
        $this->query($sql);

The method samsonframework\orm\Database::query() has been deprecated with message: Use execute()

    }

    public function delete($className, &$object)
    {
        // Build SQL query
        $sql = 'DELETE FROM `' . $className::$_table_name . '` WHERE ' . $className::$_primary . ' = "' . $object->id . '"';
        $this->query($sql);

The method samsonframework\orm\Database::query() has been deprecated with message: Use execute()

    }

    /**
     * @see idb::find()
     */
    public function &find($class_name, QueryInterface $query)
    {
        // Результат выполнения запроса
        $result = array();

        if ($query->empty) {

Accessing empty on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

            return $result;
        }

        // Get SQL
        $sql = $this->prepareSQL($class_name, $query);

        // Выполним запрос к БД
        $db_data = $this->fetch($sql);

It seems like $sql defined by $this->prepareSQL($class_name, $query) on line 172 can also be of type boolean; however, samsonframework\orm\Database::fetch() does only seem to accept string, maybe add an additional type check?

        //trace($query->virtual_fields);

        // Выполним запрос к БД и создадим объекты
        if ((is_array($db_data)) && (sizeof($db_data) > 0)) {
            $result = $this->toRecords($class_name, $db_data, $query->join,

Accessing join on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

                array_merge($query->own_virtual_fields, $query->virtual_fields));

Accessing own_virtual_fields on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

Accessing virtual_fields on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        }

        // Вернем коллекцию полученных объектов
        return $result;
    }


    /**
     * @see idb::find_by_id()
     */
    public function &find_by_id($class_name, $id)

Method name "dbMySQL::find_by_id" is not in camel caps format

    {
        // Получим переменные для запроса
        extract($this->__get_table_data($class_name));

$this->__get_table_data($class_name) cannot be passed to extract() as the parameter $var_array expects a reference.

        // Выполним запрос к БД
        $record_data = $this->fetch('SELECT ' . $_sql_select['this'] . ' FROM ' . $_sql_from['this'] . ' WHERE ' . $_table_name . '.' . $_primary . ' = "' . $id . '"');

        // Если запрос выполнился успешно и получена минимум 1-на запись из БД - создадим объект-запись из неё
        $db_records = $this->toRecords($class_name, $record_data);

        // Переменная для возврата
        $ret = null;

        // Если мы получили 1ю запись то вернем её
        if (sizeof($db_records) >= 1) {
            $ret = array_shift($db_records);
        }

        // Вернем переменную
        return $ret;
    }

    /**
     * Выполнить защиту значения поля для его безопасного использования в запросах
     *
     * @param string $value Значения поля для запроса
     * @return string $value Безопасное представление значения поля для запроса
     */
    protected function protectQueryValue($value)
    {
        // If magic quotes are on - remove slashes
        if (get_magic_quotes_gpc()) {
            $value = stripslashes($value);
        }

        // Normally escape string
        $value = $this->driver->quote($value);

        // Return value in quotes
        return $value;
    }

    /** @deprecated Use execute() */
    public function simple_query($sql)

Method name "dbMySQL::simple_query" is not in camel caps format

    {
        return $this->query($sql);

The method samsonframework\orm\Database::query() has been deprecated with message: Use execute()

    }

    /**
     * Prepare create & update SQL statements fields
     * @param string $className Entity name
     * @param Record $object Database object to get values(if needed)
     * @param bool $straight Way of forming SQL field statements
     * @return array Collection of key => value with SQL fields statements
     */
    protected function &getQueryFields($className, & $object = null, $straight = false)
    {
        // Результирующая коллекция
        $collection = array();

        // Установим флаг получения значений атрибутов из переданного объекта
        $use_values = isset($object);

$use_values is not used, you could remove the assignment.

        // Переберем "настоящее" имена атрибутов схемы данных для объекта
        foreach ($className::$_table_attributes as $attribute => $map_attribute) {
            // Отметки времени не заполняем
            if ($className::$_types[$map_attribute] == 'timestamp') {
                continue;
            }

            // Основной ключ не заполняем
            if ($className::$_primary == $attribute) {
                continue;
            }

            // Only add attributes that have value
            $value = $object->$attribute !== null ?
                (is_numeric($object->$attribute)? $object->$attribute : $this->driver->quote($object->$attribute))
                : 'NULL';

            // Добавим значение поля, в зависимости от вида вывывода метода
            $collection[$map_attribute] = ($straight ? $className::$_table_name . '.' . $map_attribute . '=' : '') . $value;
        }

        // Вернем полученную коллекцию
        return $collection;
    }

    /**
     * Generic database migration handler
     * @param string $classname Class for searching migration methods
     * @param string $version_handler External handler for interacting with database version
     */
    public function migration($classname, $version_handler)
    {
        if (!is_callable($version_handler)) {
            return e('No version handler is passed', E_SAMSON_ACTIVERECORD_ERROR);

The function e() has been deprecated with message: Use custom exceptions

        }

        // Get current database version
        $version = call_user_func($version_handler);

        // DB version migrating mechanism
        foreach (get_class_methods($classname) as $m) {
            // Parse migration method name to get migrating versions
            if (preg_match('/^migrate_(?<from>\d+)_to_(?<to>\d+)/i', $m, $matches)) {
                $from = $matches['from'];
                $to = $matches['to'];

                // If we found migration method from current db version
                if ($from == $version) {
                    // Run migration method
                    if (call_user_func(array($version_handler[0], $m)) !== false) {
                        // Save current version for further migrating
                        $version = $to;

                        // Call database version changing handler
                        call_user_func($version_handler, $to);

                        // Reload page
                        elapsed('Database migration from version: ' . $from . ' -> ' . $to);
                    } // Break and error
                    else {
                        e('Database migration from ## -> ## - has Failed', E_SAMSON_ACTIVERECORD_ERROR,

The function e() has been deprecated with message: Use custom exceptions

                            array($from, $to));
                        break;
                    }
                }
            }
        }
    }

    /** @see idb::profiler() */
    public function profiler()
    {
        // Выведем список объектов из БД
        $list = array();

        // Общее кво созданных объектов
        $total_obj_count = 0;

        // Переберм коллекции созданных объектов
        foreach (dbRecord::$instances as $n => $v) {
            // Если для данного класса были созданы объекты
            if ($c = sizeof($v)) {
                // Увеличим общий счетчик созданных объектов
                $total_obj_count += $c;

                // Выведем имя класса и кво созданных объектов
                $list[] = '' . $n . '(' . $c . ')';
            }
        }

        // Сформируем строку профайлинга
        return 'DB: ' . round($this->elapsed,
            3) . 'с, ' . $this->query_count . ' запр., ' . $total_obj_count . ' об.(' . implode($list, ',') . ')';
    }

    /** Count query result */
    public function innerCount($className, $query)
    {
        $params = $this->__get_table_data($className);

        // Get SQL
        $sql = 'SELECT Count(*) as __Count FROM (' .
            $this->prepareInnerSQL($className, $query, $params) .
            ') as __table';

        $result = $this->fetch($sql);

        return $result[0]['__Count'];
    }

    //
    // Приватный контекст
    //

    /**
     * Create SQL request
     *
     * @param string $class_name Classname for request creating
     * @param QueryInterface $query Query with parameters
     * @return string SQL string
     */
    protected function prepareSQL($class_name, QueryInterface $query)
    {
        //elapsed( 'dbMySQL::find() Начало');
        $params = $this->__get_table_data($class_name);

$class_name is of type string, but the function expects a object<samson\activerecord\unknown_type>.

        // Получим переменные для запроса
        extract($params);

        // Текст выборки полей
        $select = '`' . $_table_name . '`.*';//$_sql_select['this'];

        // If virtual fields defined
        if (sizeof($query->virtual_fields)) {

Accessing virtual_fields on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

This code seems to be duplicated across your project.

            $select .= ', ' . "\n" . implode("\n" . ', ', $query->virtual_fields);

Accessing virtual_fields on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        }

        $from = ' ( ' . $this->prepareInnerSQL($class_name, $query, $params);

        // Добавим алиас
        $from .= ' ) as `' . $_table_name . '`';

        //trace($query->join);

        // Iterate related tables
        foreach ($query->join as $relation_data) {

Accessing join on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

            $c_table = self::$prefix . $relation_data->table;

            // Если существует требуемая связь
            if (isset($_sql_from[$c_table])) {
                // Получим текст для выборки данных из связанных таблиц
                $select .= ',' . $_sql_select[$c_table];

                // Получим текст для привязывания таблицы к запросу
                $from .= "\n" . ' ' . $_sql_from[$c_table];
            } else {
                return e('Ошибка! В таблице связей для класса(##), не указана связь с классом(##)',

The return type of return e('Ошибка! В таблице связей для класса(##), не указана связь с классом(##)', E_SAMSON_FATAL_ERROR, array($class_name, $c_table)); (boolean) is incompatible with the return type of the parent method samsonframework\orm\Database::prepareSQL of type string|null.

The function e() has been deprecated with message: Use custom exceptions

                    E_SAMSON_FATAL_ERROR, array($class_name, $c_table));
            }
        }

        // Сформируем строку запроса на поиск записи
        $sql = "\n" . 'SELECT ' . $select . "\n" . ' FROM ' . $from;

        // Получим все условия запроса
        $sql .= "\n" . ' WHERE (' . $this->getConditions($query->condition, $class_name) . ')';

Accessing condition on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        // Добавим нужные сортировщики
        if (sizeof($query->group)) {

Accessing group on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

            $sql .= "\n" . ' GROUP BY ' . $query->group[0];

Accessing group on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        }
        // Если указана сортировка результатов
        if (sizeof($query->order)) {

Accessing order on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

            $sql .= "\n" . ' ORDER BY ';
            for ($i = 0; $i < sizeof($query->order); $i++) {

Accessing order on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

It seems like you are calling the size function sizeof() as part of the test condition. You might want to compute the size beforehand, and not on each iteration.

                $item = &$query->order[$i];

Accessing order on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

                if (sizeof($item)) {
                    $sql .= $item[0] . ' ' . $item[1];
                }
                if ($i < (sizeof($query->order) - 1)) {

Accessing order on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

                    $sql .= ', ';
                }
            }
        }
        // Если нужно ограничить к-во записей в выдаче по главной таблице
        if (sizeof($query->limit)) {

Accessing limit on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

This code seems to be duplicated across your project.

            $sql .= "\n" . ' LIMIT ' . $query->limit[0] . (isset($query->limit[1]) ? ',' . $query->limit[1] : '');

Accessing limit on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        }

        if (isset($GLOBALS['show_sql'])) {
            elapsed($sql);
        }

        return $sql;
    }

    protected function prepareInnerSQL($class_name, QueryInterface $query, $params)
    {
        //trace($class_name);
        //print_r($query->own_condition);
        // Получим текст цели запроса
        $from = 'SELECT ' . $params['_sql_select']['this'];

        // Если заданны виртуальные поля, добавим для них колонки
        if (sizeof($query->own_virtual_fields)) {

Accessing own_virtual_fields on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

This code seems to be duplicated across your project.

            $from .= ', ' . "\n" . implode("\n" . ', ', $query->own_virtual_fields);

Accessing own_virtual_fields on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        }

        // From part
        $from .= "\n" . ' FROM ' . $params['_sql_from']['this'];

        // Если существуют условия для главной таблицы в запросе - получим их
        if ($query->own_condition->size()) {

Accessing own_condition on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

            $from .= "\n" . ' WHERE (' . $this->getConditions($query->own_condition, $class_name) . ')';

Accessing own_condition on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        }

        // Добавим нужные групировщики
        $query->own_group = array_merge($params['_own_group'],

Accessing own_group on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

            is_array($query->own_group) ? $query->own_group : array());

Accessing own_group on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        if (sizeof($query->own_group)) {

Accessing own_group on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

This code seems to be duplicated across your project.

            $from .= "\n" . 'GROUP BY ' . implode(',', $query->own_group);

Accessing own_group on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        }
        // Если указана сортировка результатов
        if (sizeof($query->own_order)) {

Accessing own_order on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

This code seems to be duplicated across your project.

            $from .= "\n" . ' ORDER BY ' . $query->own_order[0] . ' ' . $query->own_order[1];

Accessing own_order on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        }
        // Если нужно ограничить к-во записей в выдаче по главной таблице
        if (sizeof($query->own_limit)) {

Accessing own_limit on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

This code seems to be duplicated across your project.

            $from .= "\n" . ' LIMIT ' . $query->own_limit[0] . (isset($query->own_limit[1]) ? ',' . $query->own_limit[1] : '');

Accessing own_limit on the interface samsonframework\orm\QueryInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        }

        return $from;
    }

    protected function getConditions(ConditionInterface $cond_group, $class_name)
    {
        // Соберем сюда все сформированные условия для удобной "упаковки" их в строку
        $sql_condition = array();

        // Переберем все аргументы условий в условной группе условия
        foreach ($cond_group as $argument) {
            // Если аргумент я вляется группой аргументов, разпарсим его дополнительно
            if (is_a($argument, '\samsonframework\orm\ConditionInterface')) {
                $sql_condition[] = $this->getConditions($argument, $class_name);
            } else {
                // Если условие успешно разпознано - добавим его в коллекцию условий
                $sql_condition[] = $this->parseCondition($class_name, $argument);
            }
        }

        // Соберем все условия условной группы в строку
        if (sizeof($sql_condition)) {
            return '(' . implode(') ' . $cond_group->relation . ' (', $sql_condition) . ')';

Accessing relation on the interface samsonframework\orm\ConditionInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        } // Вернем то что получилось
        else {
            return '(1=1)';
        }
    }

    /**
     * "Правильно" разпознать переданный аргумент условия запроса к БД
     *
     * @param string $class_name Схема сущности БД для которой данные условия
     * @param Argument $arg Аругемнт условия для преобразования
     * @return string Возвращает разпознанную строку с условием для MySQL
     */
    protected function parseCondition($class_name, & $arg)
    {
        // Получим переменные для запроса
        extract($this->__get_table_data($class_name));

$this->__get_table_data($class_name) cannot be passed to extract() as the parameter $var_array expects a reference.

$class_name is of type string, but the function expects a object<samson\activerecord\unknown_type>.

        // Получим "правильное" имя аттрибута сущности и выделим постоянную часть условия
        $sql_cond_t = isset($_map[$arg->field]) ? $_map[$arg->field] : $arg->field;

        // Если аргумент условия - это НЕ массив - оптимизации по более частому условию
        if (!is_array($arg->value)) {
            // NULL condition
            if ($arg->relation === dbRelation::NOTNULL || $arg->relation === dbRelation::ISNULL) {
                return $sql_cond_t . $arg->relation;
            } // Own condition
            else {
                if ($arg->relation === dbRelation::OWN) {
                    return $arg->field;
                } // Regular condition
                else {
                    return $sql_cond_t . $arg->relation . $this->protectQueryValue($arg->value);
                }
            }
        } // Если аргумент условия - это массив и в нем есть значения
        else {
            if (sizeof($arg->value)) {
                // TODO: Add other numeric types support
                // TODO: Get types of joined tables fields

                // Generate list of values, integer type optimization
                $sql_values = isset($class_name::$_types[$arg->field]) && $class_name::$_types[$arg->field] == 'int'
                    ? ' IN (' . implode(',', $arg->value) . ')'
                    : ' IN ("' . implode('","', $arg->value) . '")';

                switch ($arg->relation) {
                    case dbRelation::EQUAL:
                        return $sql_cond_t . $sql_values;
                    case dbRelation::NOT_EQUAL:
                        return $sql_cond_t . ' NOT ' . $sql_values;
                }
            } else { // If we received a condition with empty array - consider this as failing condition
                return '1 = 0';
            }
        }
    }


    /**
     * Create object instance by specified parameters
     * @param string $className Object class name
     * @param RelationData $metaData Object metadata for creation and filling

There is no parameter named $metaData. Was it maybe removed?

     * @param array $dbData Database record with object data
     *
     * @return idbRecord Database record object instance
     */
    public function &createObject(
        $className,
        $identifier,
        array & $attributes,
        array & $dbData,
        array & $virtualFields = array()
    )
    {

The closing parenthesis and the opening brace of a multi-line function declaration must be on the same line

        // If this object instance is not cached
        if (!isset(dbRecord::$instances[$className][$identifier]) || isset($dbData['__Count']) || sizeof($virtualFields)) {

Blank line found at start of control structure

            // Create empry dbRecord ancestor and store it to cache
            dbRecord::$instances[$className][$identifier] = new $className($this, new dbQuery());

            // Pointer to object
            $object = &dbRecord::$instances[$className][$identifier];

            // Set object identifier
            $object->id = $identifier;

            // Fix object connection with DB record
            $object->attached = true;

            // Fill object attributes
            foreach ($attributes as $lc_field => $field) {
                $object->$lc_field = $dbData[$field];
            }

            // Fill virtual fields
            foreach ($virtualFields as $alias => $virtual_field) {
                // If DB record contains virtual field data
                if (isset($dbData[$alias])) {
                    $object->$alias = $dbData[$alias];
                }
            }

            return $object;

Blank line found at end of control structure

        } else { // Get object instance from cache
            return dbRecord::$instances[$className][$identifier];
        }
    }

    /**
     * Преобразовать массив записей из БД во внутреннее представление dbRecord
     * @param string $class_name Имя класса
     * @param array $response Массив записей полученных из БД
     * @return array Коллекцию записей БД во внутреннем формате
     * @see dbRecord
     */
    protected function &toRecords($class_name, array & $response, array $join = array(), array $virtual_fields = array())
    {
        // Сформируем правильное имя класса
        $class_name = strpos($class_name, '\\') !== false ? $class_name : '\\samson\activerecord\\'.$class_name;

        // Результирующая коллекция полученных записей из БД
        $collection = array();

        // Получим переменные для запроса
        extract($this->__get_table_data($class_name));

$class_name is of type string, but the function expects a object<samson\activerecord\unknown_type>.

$this->__get_table_data($class_name) cannot be passed to extract() as the parameter $var_array expects a reference.

        // Generate table metadata for joined tables
        $joinedTableData = array();
        foreach ($join as $relationData) {

Blank line found at start of control structure

            // Generate full joined table name(including prefix)
            $joinTable = self::$prefix . $relationData->table;

            // Get real classname of the table without alias
            $tableName = $_relation_alias[$joinTable];

            // Get joined table class metadata
            $joinedTableData[$tableName] = $this->__get_table_data($tableName);
        }

        // Получим имя главного
        $main_primary = $_primary;

        // Перебем массив полученных данных от БД - создадим для них объекты
        $records_count = sizeof($response);

        // Идентификатор текущего создаваемого объекта
        $main_id = isset($response[0]) ? $response[0][$main_primary] : 0;

        // Указатель на текущий обрабатываемый объект
        $main_obj = null;

        // Переберем полученные записи из БД
        for ($i = 0; $i < $records_count; $i++) {
            // Строка данных полученная из БД
            $db_row = &$response[$i];

            // Get object instance
            $collection[$main_id] = &$this->createObject($class_name, $main_id, $_attributes, $db_row, $virtual_fields);

            // Pointer to main object
            $main_obj = &$collection[$main_id];

            // Выполним внутренний перебор строк из БД начиная с текущей строки
            // Это позволит нам розабрать объекты полученные со связью один ко многим
            // А если это связь 1-1 то цикл выполниться только один раз
            for ($j = $i; $j < $records_count; $j++) {
                // Строка данных полученная из БД
                $db_inner_row = &$response[$j];

                // Получим идентфиикатор главного объекта в текущей строче БД
                $obj_id = $db_inner_row[$main_primary];

                // Если в строке из БД новый идентификатор
                if ($obj_id != $main_id) {
                    // Установим новый текущий идентификатор материала
                    $main_id = $obj_id;

                    // Установим индекс главного цикла на строку с новым главным элементом
                    // учтем что главный цикл сам увеличит на единицу индекс
                    $i = $j - 1;

                    //trace(' - Найден новый объект на строке №'.$j.'-'.$db_inner_row[$main_primary]);

                    // Прервем внутренний цикл
                    break;
                }
                //else trace(' + Заполняем данные из строки №'.$j);

                // Переберем все присоединенные таблицы в запросе
                foreach ($join as $relation_data) {
                    /**@var \samson\activerecord\RelationData $relation_data */

                    // If this table is not ignored
                    if (!$relation_data->ignore) {

Blank line found at start of control structure

                        // TODO: Prepare all data in RelationObject to speed up this method

                        $join_name = $relation_data->relation;

                        $join_table = self::$prefix . $relation_data->table;

                        //trace('Filling related table:'.$join_name.'/'.$join_table);

                        // Get real classname of the table without alias
                        $_relation_name = $_relation_alias[$join_table];
                        $join_class = str_replace(self::$prefix, '', $relation_data->table);

                        // Get joined table metadata from previously prepared object
                        $r_data = $joinedTableData[$_relation_name];

                        // Try to get identifier
                        if (isset($_relations[$join_table][$r_data['_primary']])) {
                            $r_obj_id_field = $_relations[$join_table][$r_data['_primary']];
                        } // Получим имя ключевого поля связанного объекта
                        else {
                            e('Cannot find related table(##) primary field(##) description',

The function e() has been deprecated with message: Use custom exceptions

                                E_SAMSON_ACTIVERECORD_ERROR, array($join_table, $r_data['_primary']));
                        }

                        // Если задано имя ключевого поля связанного объекта - создадим его
                        if (isset($db_inner_row[$r_obj_id_field])) {
                            // Получим ключевое поле связанного объекта
                            $r_obj_id = $db_inner_row[$r_obj_id_field];

                            // Get joined object instance
                            $r_obj = &$this->createObject($join_name, $r_obj_id, $_relations[$join_table],
                                $db_inner_row);

                            // Call handler for object filling
                            $r_obj->filled();

                            // TODO: Это старый подход - сохранять не зависимо от алиаса под реальным именем таблицы

                            // Если связанный объект привязан как один-к-одному - просто довами ссылку на него
                            if ($_relation_type[$join_table] == 0) {
                                $main_obj->onetoone['_' . $join_table] = $r_obj;
                                $main_obj->onetoone['_' . $join_class] = $r_obj;
                            } // Иначе создадим массив типа: идентификатор -> объект
                            else {
                                $main_obj->onetomany['_' . $join_table][$r_obj_id] = $r_obj;
                                $main_obj->onetomany['_' . $join_class][$r_obj_id] = $r_obj;
                            }
                        }
                    }
                }
            }

            // Call handler for object filling
            $main_obj->filled();

            // Если внутренний цикл дошел до конца остановим главный цикл
            if ($j == $records_count) {
                break;
            }
        }

        // Вернем то что у нас вышло
        return $collection;
    }
}