Willry\QueryBuilder\Query

Complexity

Total Complexity

12

Size/Duplication

Total Lines	106
Duplicated Lines	0 %

Importance

Changes	11
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	select()	0	4	1
A	selectRaw()	0	5	1
A	get()	0	14	2
A	order()	0	5	1
A	groupBy()	0	5	1
A	having()	0	5	1
A	first()	0	18	3
A	count()	0	14	2

<?php

namespace Willry\QueryBuilder;

use Exception;
use PDOStatement;
use stdClass;

class Query extends Base
{

    /**
     * @param string $columns
     * @return $this
     */
    public function selectRaw(string $columns = "*", array $params = []): self
    {
        $this->setBindings($params, 'select');
        $this->columns = array_merge($this->columns, explode(',', $columns));
        return $this;
    }

    public function select(array $columns = ['*']): self
    {
        $this->columns = array_merge($this->columns, $columns);
        return $this;
    }


    /**
     * @param string $columnOrder
     */
    public function order(string $columnOrder): self
    {
        $this->order = "ORDER BY ?";
        $this->setBindings([$columnOrder], 'order');
        return $this;
    }


    /**
     * @param array $group
     * @return DB
     */
    public function groupBy(string $group): self
    {

        $this->groupBy = "GROUP BY {$group}";
        return $this;
    }

    /**
     * @param string $having
     * @return DB
     */
    public function having(string $having, array $params = []): self
    {
        $this->having = "HAVING {$having}";
        $this->setBindings($params, 'having');
        return $this;
    }

    public function get(): ?array
    {
        $this->mountQuery();

        try {
            $this->type = self::TYPE_SELECT;

            $stmt = $this->db->prepare($this->query);
            QueryHelpers::bind($stmt, $this->flatBindings());
            $stmt->execute();

            return $stmt->fetchAll(\PDO::FETCH_CLASS);
        } catch (\PDOException $exception) {
            $this->handleError($exception);
        }
    }

    public function first(): ?\stdClass
    {
        $this->mountQuery();

        try {
            $this->type = self::TYPE_SELECT;

            $stmt = $this->db->prepare($this->query);
            QueryHelpers::bind($stmt, $this->flatBindings());
            $stmt->execute();

            if (!$stmt->rowCount()) {
                return null;
            }

            return $stmt->fetchObject();
        } catch (\PDOException $exception) {
            $this->handleError($exception);
        }
    }

    public function count(): ?int
    {
        $this->mountQuery();

        try {
            $this->type = self::TYPE_SELECT;

            $stmt = $this->db->prepare($this->query);
            QueryHelpers::bind($stmt, $this->flatBindings());
            $stmt->execute();

            return $stmt->rowCount();
        } catch (\PDOException $exception) {
            $this->handleError($exception);
        }
    }
}