Foolz\SphinxQL\Drivers\Pdo\ResultSetAdapter

Complexity

Total Complexity

17

Size/Duplication

Total Lines	128
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getAffectedRows()	0	4	1
A	getNumRows()	0	4	1
A	getFields()	0	10	2
A	isDml()	0	4	1
A	store()	0	4	1
A	toRow()	0	4	1
A	freeResult()	0	4	1
A	rewind()	0	4	1
A	valid()	0	4	1
A	fetch()	0	15	3
A	fetchAll()	0	14	3

<?php

namespace Foolz\SphinxQL\Drivers\Pdo;

use \PDO;
use \PDOStatement;

class ResultSetAdapter implements \Foolz\SphinxQL\Drivers\ResultSetAdapterInterface
{
    /**
     * @var null|PDOStatement
     */
    protected $statement = null;

    /**
     * @var bool
     */
    protected $valid = true;

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

    /**
     * @return int
     */
    public function getAffectedRows()
    {
        return $this->statement->rowCount();
    }

    /**
     * @return int
     */
    public function getNumRows()
    {
        return $this->statement->rowCount();
    }

    /**
     * @return array
     */
    public function getFields()
    {
        $fields = array();

        for ($i = 0; $i < $this->statement->columnCount(); $i++) {
            $fields[] = (object)$this->statement->getColumnMeta($i);
        }

        return $fields;
    }

    /**
     * @return bool
     */
    public function isDml()
    {
        return $this->statement->columnCount() == 0;
    }

    /**
     * @return array
     */
    public function store()
    {
        return $this->statement->fetchAll(PDO::FETCH_NUM);
    }

    /**
     * @param $num
     */
    public function toRow($num)
    {
        throw new \BadMethodCallException('Not implemented');
    }

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

    public function rewind()
    {

    }

    /**
     * @return bool
     */
    public function valid()
    {
        return $this->valid;
    }

    /**
     * @param self::FETCH_ASSOC|self::FETCH_NUM $fetch_type

The doc-type self::FETCH_ASSOC|self::FETCH_NUM could not be parsed: Unknown type name "self::FETCH_ASSOC" at position 0. (view supported doc-types)

     * @return array|null
     */
    public function fetch($fetch_type)
    {
        if ($fetch_type == self::FETCH_ASSOC) {
            $row = $this->statement->fetch(PDO::FETCH_ASSOC);
        } else {
            $row = $this->statement->fetch(PDO::FETCH_NUM);
        }

        if (!$row) {
            $this->valid = false;
            $row = null;
        }

        return $row;
    }

    /**
     * @param self::FETCH_ASSOC|self::FETCH_NUM $fetch_type

The doc-type self::FETCH_ASSOC|self::FETCH_NUM could not be parsed: Unknown type name "self::FETCH_ASSOC" at position 0. (view supported doc-types)

     * @return array
     */
    public function fetchAll($fetch_type)
    {
        if ($fetch_type == self::FETCH_ASSOC) {
            $row = $this->statement->fetchAll(PDO::FETCH_ASSOC);
        } else {
            $row = $this->statement->fetchAll(PDO::FETCH_NUM);
        }

        if (empty($row)) {
            $this->valid = false;
        }

        return $row;
    }
}