Mattbit\MysqlCompat\Result

Complexity

Total Complexity

21

Size/Duplication

Total Lines	134
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	7
Bugs	2	Features	2

15 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getStatement()	0	4	1
A	toArray()	0	4	1
A	count()	0	4	1
A	column()	0	6	1
A	fetch()	0	15	3
A	fetchObject()	0	6	1
A	fetchAll()	0	4	1
A	free()	0	4	1
B	convertFetchStyle()	0	19	5
A	setCursor()	0	4	1
A	getColumnMeta()	0	4	1
A	getColumnCount()	0	4	1
A	getConnection()	0	4	1
A	getLastFetch()	0	4	1

<?php

namespace Mattbit\MysqlCompat;

use PDO;
use PDOStatement;

class Result
{
    const FETCH_ASSOC = 1;
    const FETCH_NUM = 2;
    const FETCH_BOTH = 3;
    const FETCH_OBJ = PDO::FETCH_OBJ;

    /**
     * @var Connection
     */
    protected $connection;

    /**
     * @var PDOStatement
     */
    protected $statement;

    /**
     * @var int
     */
    protected $cursor;

    protected $lastFetch;

    public function __construct(PDOStatement $statement, Connection $connection)
    {
        $this->statement = $statement;
        $this->connection = $connection;
    }

    /**
     * Get the PDO statement.
     *
     * @return PDOStatement
     */
    public function getStatement()
    {
        return $this->statement;
    }

    public function toArray()
    {
        return $this->statement->fetchAll();
    }

    public function count()
    {
        return $this->statement->rowCount();
    }

    public function column($column, $row)
    {
        $row = $this->statement->fetch(PDO::FETCH_BOTH, PDO::FETCH_ORI_ABS, $row);

        return $row[$column];
    }

    public function fetch($style = self::FETCH_BOTH, $orientation = PDO::FETCH_ORI_NEXT, $offset = 0)
    {
        $fetchMode = $this->convertFetchStyle($style);

        if ($this->cursor !== null) {
            $result = $this->statement->fetch($fetchMode, PDO::FETCH_ORI_ABS, $this->cursor);
            $this->cursor++;
        } else {
            $result = $this->statement->fetch($fetchMode, $orientation, $offset);
        }

        $this->lastFetch = is_object($result) ? clone($result) : $result;

        return $result;
    }

    public function fetchObject($class = 'stdClass', array $params = [])
    {
        $this->statement->setFetchMode(PDO::FETCH_CLASS, $class, $params);

        return $this->fetch(static::FETCH_OBJ);
    }
    public function fetchAll()
    {
        return $this->statement->fetchAll();
    }

    public function free()
    {
        return $this->statement->closeCursor();
    }

    public function convertFetchStyle($style)
    {
        switch ($style) {
            case static::FETCH_ASSOC:
                return PDO::FETCH_ASSOC;

            case static::FETCH_NUM:
                return PDO::FETCH_NUM;

            case static::FETCH_BOTH:
                return PDO::FETCH_BOTH;

            case static::FETCH_OBJ:
                return PDO::FETCH_CLASS;

            default:
                return $style;
        }
    }

    public function setCursor($rowNumber)
    {
        $this->cursor = $rowNumber;
    }

    public function getColumnMeta($columnNumber)
    {
        return $this->statement->getColumnMeta($columnNumber);
    }

    public function getColumnCount()
    {
        return $this->statement->columnCount();
    }

    public function getConnection()
    {
        return $this->connection;
    }

    public function getLastFetch()
    {
        return $this->lastFetch;
    }
}