samson\activerecord\dbMySQL::toRecords()

Complexity

Conditions	13
Paths	40

Size

Total Lines	145
Code Lines	51

Duplication

Lines	0
Ratio	0 %

Importance

Changes	10
Bugs	3	Features	5

<?php
    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;
    }
}