suda\database\struct\ReadStatement

Complexity

Total Complexity

9

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	hasLimit()	0	3	1
A	getAccess()	0	3	1
A	__construct()	0	7	1
A	one()	0	6	3
A	fetchAll()	0	3	1
A	all()	0	3	1
A	fetch()	0	3	1

<?php

namespace suda\database\struct;

use suda\database\exception\SQLException;
use suda\database\TableAccess;

class ReadStatement extends \suda\database\statement\ReadStatement
{
    /**
     * 访问操作
     *
     * @var TableAccess
     */
    protected $access;

    public function __construct(TableAccess $access)
    {
        $this->access = $access;
        parent::__construct(
            $access->getSource()->write()->rawTableName($access->getStruct()->getName()),
            $access->getStruct(),
            $access->getMiddleware()
        );
    }

    /**
     * 取1
     *
     * @param string|null $class
     * @param array $args
     * @return mixed
     * @throws SQLException
     */
    public function one(?string $class = null, array $args = [])
    {
        if ($this->isScroll() === false && $this->hasLimit() === false) {
            $this->limit(0, 1);
        }
        return $this->access->run($this->wantOne($class, $args));
    }

    /**
     * @return bool
     */
    private function hasLimit()
    {
        return strlen($this->limit) > 0;
    }

    /**
     * 取全部
     *
     * @param string|null $class
     * @param array $args
     * @return array
     * @throws SQLException
     */
    public function all(?string $class = null, array $args = []): array
    {
        return $this->access->run($this->wantAll($class, $args));
    }

    /**
     * 取1
     *
     * @param string|null $class
     * @param array $args
     * @return mixed
     * @throws SQLException
     */
    public function fetch(?string $class = null, array $args = [])
    {
        return $this->one($class, $args);
    }

    /**
     * 取全部
     *
     * @param string|null $class
     * @param array $args
     * @return array
     * @throws SQLException
     */
    public function fetchAll(?string $class = null, array $args = []): array
    {
        return $this->all($class, $args);
    }

    /**
     * Get 访问操作
     *
     * @return  TableAccess
     */
    public function getAccess(): TableAccess
    {
        return $this->access;
    }
}