WebStream\Database\EntityManager

Complexity

Total Complexity

23

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Test Coverage

Coverage

87.23%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	setColumnMeta()	0	3	1
A	__construct()	0	3	1
D	getEntity()	0	59	21

<?php

namespace WebStream\Database;

use WebStream\DI\Injector;

The type WebStream\DI\Injector was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * EntityManager
 * @author Ryuichi TANAKA.
 * @since 2015/01/11
 * @version 0.7
 */
class EntityManager
{
    use Injector;

    /**
     * @var string エンティティクラスパス
     */
    private $classpath;

    /**
     * @var array<string> カラムメタ情報
     */
    private $columnMeta;

    /**
     * コンストラクタ
     * @param string エンティティクラスパス

The doc comment エンティティクラスパス at position 0 could not be parsed: Unknown type name 'エンティティクラスパス' at position 0 in エンティティクラスパス.

     */
    public function __construct($classpath)
    {
        $this->classpath = $classpath;
    }

    /**
     * カラムメタ情報を設定する
     * @param string カラムメタ情報

The doc comment カラムメタ情報 at position 0 could not be parsed: Unknown type name 'カラムメタ情報' at position 0 in カラムメタ情報.

     */
    public function setColumnMeta(array $columnMeta)
    {
        $this->columnMeta = $columnMeta;
    }

    /**
     * 列データをエンティティに変換して返却する
     * @param array<string> 列データ

The doc comment 列データ at position 0 could not be parsed: Unknown type name '列データ' at position 0 in 列データ.

     * @return object 列データエンティティ
     */
    public function getEntity($row)
    {
        $instance = new $this->classpath();
        $propertyMap = null;

        // EntityPropertyを使っている場合はリフレクションを使用しない
        if (!array_key_exists(EntityProperty::class, class_uses($instance))) {
            $propertyMap = [];
            $refClass = new \ReflectionClass($instance);
            $properties = $refClass->getProperties();
            foreach ($properties as $property) {
                if ($property->isPrivate() || $property->isProtected()) {
                    $property->setAccessible(true);
                }
                $propertyMap[strtolower($property->getName())] = $property;
            }
        }

        foreach ($row as $col => $value) {
            switch ($this->columnMeta[$col]) {
                case 'LONG':      // mysql:int
                case 'SHORT':     // mysql:smallint
                case 'int4':      // postgres:int
                case 'int2':      // postgres:smallint
                case 'integer':   // sqlite:int
                case 'smallint':  // sqlite:smallint
                    $value = intval($value);
                    break;
                case 'LONGLONG':  // mysql:bigint
                case 'int8':      // postgres:bigint
                case 'bigint':    // sqlite:bigint
                    $value = doubleval($value);
                    break;
                case 'DATETIME':  // mysql:datetime
                case 'DATE':      // mysql:date
                case 'timestamp': // postgres:timestamp, sqlite:timestamp
                case 'date':      // postgres:date, sqlite:date
                    $value = new \DateTime($value);
                    break;
                default: // string
                    break;
            }

            $col = strtolower(preg_replace_callback('/_([a-zA-Z])/', function ($matches) {
                return ucfirst($matches[1]);
            }, $col));

            if ($propertyMap === null) {
                $instance->{$col} = $value;
            } else {
                if (array_key_exists($col, $propertyMap)) {
                    $propertyMap[$col]->setValue($instance, $value);
                } else {
                    $this->logger->error("Column '$col' is failed mapping in " . $this->classpath);
                }
            }
        }

        return $instance;
    }
}