dbMySQL::getQueryFields() - Code Metrics - Inspection of "Merge pull request #21 from onysko/master" - samsonos/php_activerecord - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — master ( 2d1a2e...608ac1 )

by Vitaly
created 2016-02-16 10:38 UTC
dbMySQL::getQueryFields() C

↳ Parent: dbMySQL
Complexity

Conditions	7
Paths	11
Size

Total Lines	32
Code Lines	13
Duplication

Lines	0
Ratio	0 %
Importance

Changes	8
Bugs	1	Features	3
Metric	Value
c	8
b	1
f	3
dl	0
loc	32
rs	6.7272
cc	7
eloc	13
nc	11
nop	3
<?php
namespace samson\activerecord;

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

/**
 * Класс описывающий работу с MySQL
 * @author Vitaly Iegorov <[email protected]>
 * @author Nikita Kotenko <[email protected]>
 *
 */
class dbMySQL extends dbMySQLConnector

{
    /**
     * Количество запросов класса
     * @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 . '::$_attributes;');

                // Remove namespaces
                $table = \samson\core\AutoLoader::getOnlyClass($table);

                // Make keys lowercase
                $attributes = array_change_key_case_unicode($attributes);

                // If table does not have defined identifier field
                if (!isset($attributes[strtolower($object->$field)])) {
                    // Add identifier field to social users table
                    $this->simple_query('ALTER TABLE  `' . $table . '` ADD  `' . $object->$field . '` ' . $type . ' ');

                }

                return true;

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

            }
        }
    }

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

    {
        // 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) . ')';
        $this->query($sql);

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

    public function update($className, &$object)
    {
        // ??
        $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);

    }

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

    }

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

        if ($query->empty) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            return $result;
        }

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

        // Выполним запрос к БД
        $db_data = $this->fetch($sql);
/**
 * @return array|string
 */
function returnsDifferentValues($x) {
    if ($x) {
        return 'foo';
    }

    return array();
}

$x = returnsDifferentValues($y);
if (is_array($x)) {
    // $x is an array.
}

        //trace($query->virtual_fields);

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

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
                array_merge($query->own_virtual_fields, $query->virtual_fields));
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        }

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


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

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


        // Выполним запрос к БД
        $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)

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

    }

    /**
     * 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);
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}

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

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

            // Only add attributes that have value
            $value = $object->$map_attribute !== null ?
                (is_numeric($object->$map_attribute)? $object->$map_attribute : $this->driver->quote($object->$map_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);

        }

        // 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,

                            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);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        // Получим переменные для запроса
        extract($params);

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

        // If virtual fields defined
        if (sizeof($query->virtual_fields)) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            $select .= ', ' . "\n" . implode("\n" . ', ', $query->virtual_fields);
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        }

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

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

        //trace($query->join);

        // Iterate related tables
        foreach ($query->join as $relation_data) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            $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('Ошибка! В таблице связей для класса(##), не указана связь с классом(##)',
class Author {
    private $name;

    public function __construct($name) {
        $this->name = $name;
    }

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
                    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) . ')';
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}

        // Добавим нужные сортировщики
        if (sizeof($query->group)) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            $sql .= "\n" . ' GROUP BY ' . $query->group[0];
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        }
        // Если указана сортировка результатов
        if (sizeof($query->order)) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            $sql .= "\n" . ' ORDER BY ';
            for ($i = 0; $i < sizeof($query->order); $i++) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
                $item = &$query->order[$i];
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
                if (sizeof($item)) {
                    $sql .= $item[0] . ' ' . $item[1];
                }
                if ($i < (sizeof($query->order) - 1)) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
                    $sql .= ', ';
                }
            }
        }
        // Если нужно ограничить к-во записей в выдаче по главной таблице
        if (sizeof($query->limit)) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            $sql .= "\n" . ' LIMIT ' . $query->limit[0] . (isset($query->limit[1]) ? ',' . $query->limit[1] : '');
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        }

        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)) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            $from .= ', ' . "\n" . implode("\n" . ', ', $query->own_virtual_fields);
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        }

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

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

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            $from .= "\n" . ' WHERE (' . $this->getConditions($query->own_condition, $class_name) . ')';
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        }

        // Добавим нужные групировщики
        $query->own_group = array_merge($params['_own_group'],
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            is_array($query->own_group) ? $query->own_group : array());
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        if (sizeof($query->own_group)) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            $from .= "\n" . 'GROUP BY ' . implode(',', $query->own_group);
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        }
        // Если указана сортировка результатов
        if (sizeof($query->own_order)) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            $from .= "\n" . ' ORDER BY ' . $query->own_order[0] . ' ' . $query->own_order[1];
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        }
        // Если нужно ограничить к-во записей в выдаче по главной таблице
        if (sizeof($query->own_limit)) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            $from .= "\n" . ' LIMIT ' . $query->own_limit[0] . (isset($query->own_limit[1]) ? ',' . $query->own_limit[1] : '');
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        }

        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) . ')';
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
        } // Вернем то что получилось
        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));
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

        // Получим "правильное" имя аттрибута сущности и выделим постоянную часть условия
        $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;
                }
            }
        }
    }


    /**
     * Create object instance by specified parameters
     * @param string $className Object class name
     * @param RelationData $metaData Object metadata for creation and filling
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     * @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()
    )

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

            // 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;

        } 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 = ns_classname($class_name, 'samson\activerecord');


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

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

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

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

            // 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) {

                        // 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',

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

Push — master ( 2d1a2e...608ac1 )

dbMySQL::getQueryFields() C

Complexity

Size

Duplication

Importance

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

samsonos / php_activerecord

Push — master ( 2d1a2e...608ac1 )

dbMySQL::getQueryFields() C

Complexity

Size

Duplication

Importance

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Duplication Side-by-Side

Filter issues like
