Mattbit\MysqlCompat\Result

Complexity

Total Complexity

19

Size/Duplication

Total Lines	112
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	6
Bugs	2	Features	1

14 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	13	2
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

<?php

namespace Mattbit\MysqlCompat;

use PDO;

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

    protected $connection;

    protected $statement;

    protected $cursor;

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

    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++;

            return $result;
        }

        return $this->statement->fetch($fetchMode, $orientation, $offset);
    }

    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;
    }
}