DataAccess::__construct() - Code Metrics - Inspection of "添加：对象映射功能" - dxkite/suda - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — sudav3 ( b29c56...468d62 )

by 世昌
created 2019-04-16 08:33 UTC
DataAccess::__construct() A

↳ Parent: DataAccess
Complexity

Conditions	1
Paths	1
Size

Total Lines	6
Code Lines	4
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	1
eloc	4
nc	1
nop	3
dl	0
loc	6
rs	10
c	0
b	0
f	0
<?php
namespace suda\orm;

use ReflectionClass;
use ReflectionProperty;
use suda\orm\DataSource;
use suda\orm\TableAccess;
use suda\orm\struct\ReadStatement;
use suda\orm\struct\QueryStatement;
use suda\orm\struct\WriteStatement;
use suda\orm\struct\TableStructBuilder;
use suda\orm\struct\TableStructMiddleware;
use suda\orm\struct\TableStructAwareInterface;

/**
 * 数据访问
 */
class DataAccess
{

    /**
     * 数据源
     *
     * @var TableAccess
     */
    protected $access;

    /**
     * 数据类型
     *
     * @var string
     */
    protected $type;

    /**
     * 创建对数据的操作
     *
     * @param string $object
     * @param \suda\orm\DataSource $source
     * @param Middleware|null $middleware
     */
    public function __construct(string $object, DataSource $source, ?Middleware $middleware = null)
    {
        $this->type = $object;
        $struct = $this->createStruct($object);
        $middleware = $middleware ?? new TableStructMiddleware($object);
        $this->access = new TableAccess($struct, $source, $middleware);
    }

    /**
     * 读取数据
     *
     * @param array|string $fields
     * @return \suda\orm\struct\ReadStatement
     */
    public function read($fields): ReadStatement
    {
        if ($fields === null) {
            $fields = \array_keys($this->fields);

        } elseif (\func_num_args() > 1) {
            $fields = \func_get_args();
        }
        return $this->access->read($fields)->wantType($this->type);
    }
    
    /**
     * 写数据
     *
     * @param array|object $object
     * @return \suda\orm\struct\WriteStatement
     */
    public function write($object): WriteStatement
    {
        if (\is_object($object)) {
            $object = $this->createDataFromObject($object);
        }
        return $this->access->write($object);
    }

    /**
     * 统计计数
     *
     * @param string|array $where
     * @param array $whereBinder
     * @return integer
     */
    public function count($where, array $whereBinder):int
    {
        $fields = $this->access->getStruct()->getFields();
        $field = \array_shift($fields);
        $field = \array_shift(/** @scrutinizer ignore-type */ $fields);
        $total = $this->access->read([$field->getName()])->where($where, $whereBinder);
        $data = $this->access->query('SELECT count(*) as `count` from ('.$total.') as total', $total->getBinder())->one();
        return intval($data['count']);
    }

    /**
     * 查询语句
     *
     * @param string $query
     * @param mixed ...$parameter
     * @return QueryStatement
     */
    public function query(string $query, ...$parameter):QueryStatement
    {
        return $this->access->query($query, ...$parameter);
    }

    /**
     * 获取最后一次插入的主键ID（用于自增值
     *
     * @param string $name
     * @return string 则获取失败，整数则获取成功
     */
    public function lastInsertId(string $name = null):string
    {
        return $this->access->lastInsertId($name);
    }

    /**
     * 事务系列，开启事务
     *
     * @return void
     */
    public function beginTransaction()
    {
        $this->access->beginTransaction();
    }

    /**
     * 事务系列，提交事务
     *
     * @return void
     */
    public function commit()
    {
        $this->access->commit();
    }

    /**
     * 事务系列，撤销事务
     *
     * @return void
     */
    public function rollBack()
    {
        $this->access->rollBack();
    }

    /**
     * 创建数据
     *
     * @param object $object
     * @return array
     */
    protected function createDataFromObject($object)
    {
        if (\method_exists($object, '__get')) {
            return $this->createDataViaMagicGet($object);
        }
        return $this->createDataViaReflection($object);
    }

    /**
     * 使用魔术方法获取值
     *
     * @param object $object
     * @return array
     */
    protected function createDataViaMagicGet($object)
    {
        $fields = $this->access->getStruct()->getFields();
        $data = [];
        $isset = \method_exists($object, '__isset');
        if ($isset) {
            foreach ($fields as $name => $value) {
                if ($data->__isset($name)) {
                    $data[$name] = $data->__get($name);
                }
            }
        } else {
            foreach ($fields as $name => $value) {
                $data[$name] = $data->__get($name);
            }
        }
        return $data;
    }

    /**
     * 使用反射方法获取值
     *
     * @param object $object
     * @return array
     */
    protected function createDataViaReflection($object)
    {
        $fields = $this->access->getStruct()->getFields();
        $reflection = new ReflectionClass($object);
        $data = [];
        foreach ($reflection->getProperties(ReflectionProperty::IS_PUBLIC | ReflectionProperty::IS_PROTECTED | ReflectionProperty::IS_PRIVATE) as $property) {
            $name = TableStructBuilder::getFieldName($property);
            if ($fields->hasField($name)) {
                $property->setAccessible(true);
                $value = $property->getValue($object);
                if ($value !== null) {
                    $data[$name] = $value;
                }
            }
        }
        return $data;
    }

    /**
     * 创建表结构
     *
     * @param string $object
     * @return TableStruct
     */
    protected function createStruct(string $object)
    {
        $reflection = new ReflectionClass($object);
        $hasMethod = $reflection->implementsInterface(TableStructAwareInterface::class) || \method_exists($object, 'getTableStruct');
        if ($hasMethod) {
            return $reflection->getMethod('getTableStruct')->invoke(null);
        }
        return (new TableStructBuilder($object))->createStruct();
    }

    /**
     * 获取表结构
     *
     * @return \suda\orm\TableStruct
     */
    public function getStruct():TableStruct
    {
        return $this->access->getStruct();
    }

    /**
     * 获取表名
     *
     * @return string
     */
    public function getName():string
    {
        return $this->access->getName();
    }
}

dxkite / suda

Push — sudav3 ( b29c56...468d62 )

DataAccess::__construct() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
