PdoOci8Statement - Code Metrics - Inspection of "Make PdoOci8Statement extend from PDOStatement" - jpina/pdooci8 - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — dev-0.1.x ( 89d2d8...828717 )

by Josué

created 2016-04-02 21:53 UTC

PdoOci8Statement D

↳ Parent: Project

Complexity

Total Complexity

118

Size/Duplication

Total Lines	722
Duplicated Lines	2.91 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

78.34%

Importance

Changes	4
Bugs	0	Features	2

Metric	Value
wmc	118
c	4
b	0
f	2
lcom	1
cbo	5
dl	21
loc	722
ccs	264
cts	337
cp	0.7834
rs	4.4444

30 Methods

Rating	Name	Duplication	Size	Complexity
A	bindColumn()	0	12	3
B	bindParam()	0	27	6
A	bindValue()	0	4	1
A	closeCursor()	0	4	1
A	columnCount()	0	4	1
B	debugDumpParams()	0	36	5
A	errorCode()	12	12	2
A	errorInfo()	0	20	2
B	execute()	0	28	5
C	fetch()	0	66	14
B	__construct()	5	44	6
C	fetchAll()	0	31	16
A	fetchColumn()	0	14	3
A	fetchObject()	0	16	3
A	getAttribute()	0	8	2
B	getColumnMeta()	0	35	4
A	nextRowset()	0	4	1
A	rowCount()	0	4	1
A	setAttribute()	4	15	3
A	setFetchMode()	0	10	2
B	getTableName()	0	23	4
D	getPDODataType()	0	25	10
C	getDriverDataType()	0	31	14
A	getConnection()	0	4	1
A	getInternalIterator()	0	16	3
A	current()	0	6	1
A	next()	0	6	1
A	key()	0	6	1
A	valid()	0	6	1
A	rewind()	0	6	1

How to fix Duplicated Code Complexity

Duplicated Code

Duplicate code is one of the most pungent code smells. A rule that is often used is to re-structure code once it is duplicated in three or more places.

Common duplication problems, and corresponding solutions are:

If you have the same expression in different places: Extract expression to a method
If you have the same method in different sub-classes: Extract method, and pull up field to the parent class
If you have the same code in unrelated classes: Consider extracting the code to a new class, and injecting that class

Complex Class

Tip: Before tackling complexity, make sure that you eliminate any duplication first. This often can reduce the size of classes significantly.

Complex classes like PdoOci8Statement often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes. You can also have a look at the cohesion graph to spot any un-connected, or weakly-connected components.

Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.

While breaking up the class, it is a good idea to analyze how other classes use PdoOci8Statement, and based on these observations, apply Extract Interface, too.

<?php

namespace Jpina\PdoOci8;

use Jpina\Oci8\Oci8ConnectionInterface;
use Jpina\Oci8\Oci8FieldInterface;
use Jpina\Oci8\Oci8StatementInterface;

/**
 * Custom PDO_OCI implementation via OCI8 driver
 *
 * @see http://php.net/manual/en/class.pdostatement.php
 */
class PdoOci8Statement extends \PDOStatement
{
    /** @var  Oci8ConnectionInterface */
    private $connection;

    /** @var  Oci8StatementInterface */
    private $statement;

    /** @var string */
    private $sqlText = '';

    /** @var array */
    private $boundParameters = array();

    /** @var array */
    private $options;

    /** @var \ArrayIterator */
    private $iterator;

    public function __construct(Oci8ConnectionInterface $connection, $sqlText, $options = array())
    {
        if (!is_string($sqlText)) {
            throw new PdoOci8Exception('$sqlText is not a string');
        }

        $this->connection  = $connection;
        $this->sqlText     = $sqlText;
        //TODO assign value to queryString
        //$this->queryString = $sqlText;


        $this->options = array(
            \PDO::ATTR_AUTOCOMMIT          => true,
            \PDO::ATTR_CASE                => \PDO::CASE_NATURAL,
            \PDO::ATTR_ERRMODE             => \PDO::ERRMODE_SILENT,
            \PDO::ATTR_ORACLE_NULLS        => \PDO::NULL_NATURAL,
            \PDO::ATTR_PREFETCH            => 100,
            \PDO::ATTR_TIMEOUT             => 600,
            \PDO::ATTR_STRINGIFY_FETCHES   => false,
            \PDO::ATTR_STATEMENT_CLASS     => null,
            \PDO::ATTR_EMULATE_PREPARES    => false,
            \PDO::ATTR_DEFAULT_FETCH_MODE  => \PDO::FETCH_BOTH,
            \PDO::ATTR_FETCH_TABLE_NAMES   => false,
            \PDO::ATTR_FETCH_CATALOG_NAMES => false,
            \PDO::ATTR_MAX_COLUMN_LEN      => 0,
            PdoOci8::OCI_ATTR_RETURN_LOBS  => false,
        );

        foreach ($options as $option => $value) {

            if (array_key_exists($option, $this->options)) {
                $this->options[$option] = $value;
            }
        }

        foreach ($options as $attribute => $value) {
            $this->setAttribute($attribute, $value);
        }

        try {
            $this->statement = $connection->parse($sqlText);
        } catch (\Exception $ex) {
            throw new PdoOci8Exception($ex->getMessage(), $ex->getCode(), $ex);
        }
    }

    /**
     * @param int|string $column
     * @param mixed $param
     * @param int $type
     * @param int $maxlen
     * @param mixed $driverdata
     *
     * @link http://php.net/manual/en/pdostatement.bindcolumn.php
     * @return bool
     */
    public function bindColumn($column, &$param, $type = null, $maxlen = null, $driverdata = null)
    {
        try {
            $type = $type === null ? \PDO::PARAM_STR : $type;
            $dataType = $this->getDriverDataType($type);
            return $this->statement->defineByName($column, $param, $dataType);
        } catch (\Exception $ex) {
            //throw new PdoOci8Exception($ex->getMessage(), $ex->getCode(), $ex);

        }

        return false;
    }

    /**
     * @param string $parameter
     * @param mixed $variable
     * @param int $data_type
     * @param int $length
     * @param mixed $driver_options
     *
     * @link http://php.net/manual/en/pdostatement.bindparam.php
     * @return bool
     */
    public function bindParam(
        $parameter,
        &$variable,
        $data_type = \PDO::PARAM_STR,
        $length = null,
        $driver_options = null
    ) {
        $isBound = false;
        try {
            $data_type = $data_type === null ? \PDO::PARAM_STR : $data_type;
            $dataType = $this->getDriverDataType($data_type);
            $length = $length !== null ? $length : -1;
            $isBound = $this->statement->bindByName($parameter, $variable, $length, $dataType);
            if ($isBound) {
                $this->boundParameters[$parameter] = array(
                    'name'     => is_int($parameter) ? '' : $parameter,
                    'position' => strrpos($this->sqlText, $parameter),
                    'value'    => &$variable,
                    'type'     => $data_type,
                );
            }
        } catch (\Exception $ex) {
            //throw new PdoOci8Exception($ex->getMessage(), $ex->getCode(), $ex);

        }

        return $isBound;
    }

    /**
     * @param string $parameter
     * @param $value
     * @param int $data_type
     *
     * @link http://php.net/manual/en/pdostatement.bindvalue.php
     * @return bool
     */
    public function bindValue($parameter, $value, $data_type = \PDO::PARAM_STR)
    {
        return $this->bindParam($parameter, $value, $data_type);
    }

    /**
     * @link http://php.net/manual/en/pdostatement.closecursor.php
     * @return bool
     */
    public function closeCursor()
    {
        return $this->statement->cancel();
    }

    /**
     * @link http://php.net/manual/en/pdostatement.columncount.php
     * @return int
     */
    public function columnCount()
    {
        return 0;
    }

    /**
     * @link http://php.net/manual/en/pdostatement.debugdumpparams.php
     */
    public function debugDumpParams()
    {
        $sqlText = $this->sqlText;
        $sqlTextLength = strlen($sqlText);
        $parameters = $this->boundParameters;
        usort($parameters, function ($a, $b) {
            if ($a['position'] === $b['position']) {
                return 0;
            }

            return $a['position'] < $b['position'] ? -1 : 1;
        });
        $parametersCount = count($parameters);

        echo "SQL: [{$sqlTextLength}] {$sqlText}". PHP_EOL .
            "Params: {$parametersCount}";
        foreach ($parameters as $key => $parameter) {
            //TODO Add parameter position and number
            $position = $parameter['position'];
            $nameLength = strlen($parameter['name']);
            $name = $parameter['name'];
            $index = $key + 1;
            $dataType = $parameter['type'];

            echo PHP_EOL;
            if ($name === '') {
                echo "Key: Position #{$position}:". PHP_EOL;
            } else {
                echo "Key: Name: [{$nameLength}] {$name}". PHP_EOL;
            }
            echo "paramno={$index}". PHP_EOL .
                "name=[{$nameLength}]{$name}". PHP_EOL .
                "is_param=1". PHP_EOL .
                "param_type={$dataType}";
        }
    }

    /**
     * @link http://php.net/manual/en/pdostatement.errorcode.php
     * @return string
     */
    public function errorCode()

    {
        $driverError = $this->statement->getError();
        if (!$driverError) {

            return null;
        }

        $error = $this->errorInfo();
        $sqlStateErrorCode = $error[0];

        return $sqlStateErrorCode;
    }

    /**
     * @link http://php.net/manual/en/pdo.errorinfo.php
     * @return array
     */
    public function errorInfo()
    {
        $driverError = $this->statement->getError();
        if ($driverError) {

            $driverErrorMessage = $driverError['message'];
            $driverErrorCode = $driverError['code'];
        } else {
            $driverErrorMessage = null;
            $driverErrorCode = null;
        }

        $sqlStateErrorCode = OracleSqlStateCode::getSqlStateErrorCode((int)$driverErrorCode);
        $error = array(
            $sqlStateErrorCode,
            $driverErrorCode,
            $driverErrorMessage
        );

        return $error;
    }

    /**
     * @param array $input_parameters
     *
     * @link http://php.net/manual/en/pdostatement.execute.php
     * @return bool
     */
    public function execute($input_parameters = array())
    {
        try {
            foreach ($input_parameters as $key => $value) {
                if (is_int($key)) {
                    $parameterName = $key + 1;
                } else {
                    $parameterName = $key;
                }
                $this->bindValue($parameterName, $value);
            }

            if ($this->getAttribute(\PDO::ATTR_AUTOCOMMIT)) {
                $isCommitOnSuccess = OCI_NO_AUTO_COMMIT;
            } else {
                $isCommitOnSuccess = OCI_COMMIT_ON_SUCCESS;
            }

            $result = $this->statement->execute($isCommitOnSuccess);

            return $result;
        } catch (\Exception $ex) {
            //TODO Handle Exception
            new PdoOci8Exception($ex->getMessage(), $ex->getCode(), $ex);
        }

        return false;
    }

    /**
     * @param int $fetch_style
     * @param int $cursor_orientation
     * @param int $cursor_offset
     *
     * @link http://php.net/manual/en/pdostatement.fetch.php
     * @return mixed
     */
    public function fetch(
        $fetch_style = \PDO::ATTR_DEFAULT_FETCH_MODE,
        $cursor_orientation = \PDO::FETCH_ORI_NEXT,
        $cursor_offset = 0
    ) {
        if ($fetch_style === null) {
            $fetch_style === \PDO::ATTR_DEFAULT_FETCH_MODE;
        }

        try {
//            if ($fetch_style === \PDO::ATTR_DEFAULT_FETCH_MODE) {

//                $fetch_style = $this->getAttribute(\PDO::ATTR_DEFAULT_FETCH_MODE);
//            }

            switch ($fetch_style) {
                case \PDO::FETCH_ASSOC:
                    $mode = OCI_ASSOC;
                    break;
                case \PDO::FETCH_BOUND:
                    // returns TRUE and assigns the values of the columns in your result set to the PHP
                    // variables to which they were bound with the PDOStatement::bindColumn() method
                    return $this->statement->fetch();
                case \PDO::FETCH_CLASS:
                    // returns a new instance of the requested class, mapping the columns of the result
                    // set to named properties in the class
                    break;
                case \PDO::FETCH_CLASS | \PDO::FETCH_CLASSTYPE:
                    // the name of the class is determined from a value of the first column.
                    break;
                case \PDO::FETCH_INTO:
                    // updates an existing instance of the requested class, mapping the columns of the
                    // result set to named properties in the class
                    break;
                case \PDO::FETCH_LAZY:
                case \PDO::FETCH_BOTH + \PDO::FETCH_OBJ:
                     // combines PDO::FETCH_BOTH and PDO::FETCH_OBJ, creating the object variable names
                    // as they are accessed
                    break;
                case \PDO::FETCH_NAMED:
                    // returns an array with the same form as PDO::FETCH_ASSOC, except that if there are
                    // multiple columns with the same name, the value referred to by that key will be an
                    // array of all the values in the row that had that column name
                    break;
                case \PDO::FETCH_NUM:
                    $mode = OCI_NUM;
                    break;
                case \PDO::FETCH_OBJ:
                    // returns an anonymous object with property names that correspond to the column names
                    // returned in your result set
                    return $this->statement->fetchObject();
                    break;
switch ($x) {
    case 1:
        return 'foo';
        break; // This break is not necessary and can be left off.
}
                case \PDO::FETCH_BOTH:
                default:
                    $mode = OCI_BOTH;
                    break;
            }
            // TODO Combine other flags: eg. OCI_NULLS and OCI_LOBS
            // TODO update $this->numRows on successfull fetch
            // TODO update $this->isIteratorValid on NOT successfull fetch
            return $this->statement->fetchArray($mode);
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
        } catch (\Exception $ex) {
            new PdoOci8Exception($ex->getMessage(), $ex->getCode(), $ex);
        }

        return false;
    }

    /**
     * @param int $fetch_style
     * @param mixed $fetch_argument
     * @param array $ctor_args
     *
     * @link http://php.net/manual/en/pdostatement.fetchall.php
     * @return array
     */
    public function fetchAll($fetch_style = null, $fetch_argument = null, $ctor_args = array())
    {
        // TODO Implement properly (use all other fetch modes)
        switch ($fetch_style) {
            case \PDO::FETCH_NUM:
                $mode = OCI_NUM;
                break;
            case \PDO::FETCH_OBJ:
            case \PDO::FETCH_INTO:
            case \PDO::FETCH_CLASS:
            case \PDO::FETCH_BOTH:
            case \PDO::FETCH_COLUMN:
            case \PDO::FETCH_BOUND:
            case \PDO::FETCH_CLASSTYPE:
            case \PDO::FETCH_FUNC:
            case \PDO::FETCH_GROUP:
            case \PDO::FETCH_KEY_PAIR:
            case \PDO::FETCH_LAZY:
            case \PDO::FETCH_NAMED:
            case \PDO::FETCH_UNIQUE:
                throw new PdoOci8Exception('Not implemented.');
                //break;
            case \PDO::FETCH_ASSOC:
            default:
                $mode = OCI_ASSOC;
        }

        $this->statement->fetchAll($rows, 0, -1, OCI_FETCHSTATEMENT_BY_ROW | $mode);

        return $rows;
    }

    /**
     * @param int $column_number
     *
     * @link http://php.net/manual/en/pdostatement.fetchcolumn.php
     * @return mixed
     */
    public function fetchColumn($column_number = 0)
    {
        $row = $this->fetch(\PDO::FETCH_NUM);
        if ($row === false) {
            return false;
class Author {
    private $name;

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

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
        }

        if (array_key_exists($column_number, $row)) {
            return $row[$column_number];
        }

        // TODO Throw Exception
        return false;
class Author {
    private $name;

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

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
    }


    /**
     * @param string $class_name
     * @param array $ctor_args
     *
     * @link http://php.net/manual/en/pdostatement.fetchobject.php
     * @return bool|object
     */
    public function fetchObject($class_name = "stdClass", $ctor_args = array())
    {
        $row = $this->fetch(\PDO::FETCH_ASSOC);
        if ($row === false) {
            return false;
        }

        $reflexionClass = new \ReflectionClass($class_name);
        $classInstance = $reflexionClass->newInstanceArgs($ctor_args);

        foreach ($row as $property => $value) {
$collection = json_decode($data, true);
if ( ! is_array($collection)) {
    throw new \RuntimeException('$collection must be an array.');
}

foreach ($collection as $item) { /** ... */ }
            $classInstance->{$property} = $value;
        }

        return $classInstance;
    }

    /**
     * @param int $attribute
     *
     * @link http://php.net/manual/en/pdostatement.getattribute.php
     * @return mixed
     */
    public function getAttribute($attribute)
    {
        if (array_key_exists($attribute, $this->options)) {
            return $this->options[$attribute];
        }

        return null;
    }

    /**
     * @param int $column
     *
     * @throws PdoOci8Exception
     *
     * @link http://php.net/manual/en/pdostatement.getcolumnmeta.php
     * @return bool|array
     */
    public function getColumnMeta($column)
    {
        $statementType = $this->statement->getType();
        if ($statementType !== 'SELECT') {
            return false;
class Author {
    private $name;

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

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
        }

        $table = $this->getTableName();

        $sqlText = $this->sqlText;
        $statement = $this->getConnection()->parse($sqlText);
        $statement->execute(OCI_DESCRIBE_ONLY);
        $field = $statement->getField($column + 1);

        if ($field instanceof Oci8FieldInterface) {
            // Oracle returns attributes in upper case by default
            $fieldName = $field->getName();
            if ($this->getAttribute(\PDO::ATTR_CASE) === \PDO::CASE_LOWER) {
                $fieldName = strtolower($fieldName);
            }

            return array(
                'native_type'      => $field->getRawType(),
                'driver:decl_type' => $field->getType(),
                'flags'            => array(),
                'name'             => $fieldName,
                'table'            => $table,
                'len'              => $field->getSize(),
                'precision'        => $field->getPrecision() - $field->getScale(),
                'pdo_type'         => $this->getPDODataType($field->getType()),
            );
        }

        return false;
class Author {
    private $name;

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

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
    }

    /**
     * @link http://php.net/manual/en/pdostatement.nextrowset.php
     * @return bool
     */
    public function nextRowset()
    {
        // TODO Implement
    }

    /**
     * @link http://php.net/manual/en/pdostatement.rowcount.php
     * @return int
     */
    public function rowCount()
    {
        return $this->statement->getNumRows();
    }


    /**
     * @param $attribute
     * @param $value
     *
     * @link http://php.net/manual/en/pdostatement.setattribute.php
     * @return bool
     */
    public function setAttribute($attribute, $value)
    {
        $readOnlyAttributes = array(
            \PDO::ATTR_AUTOCOMMIT,
        );

        if (array_search($attribute, $readOnlyAttributes) !== false ||

            !array_key_exists($attribute, $this->options)) {
            return false;
        }

        $this->options[$attribute] = $value;

        return true;
    }

    /**
     * @param int $mode
     * @param string|int|object $target
     * @param array $ctor_args
     *
     * @link http://php.net/manual/en/pdostatement.setfetchmode.php
     * @return bool
     */
    public function setFetchMode($mode, $target = null, $ctor_args = array())
    {
        $isSuccess = $this->setAttribute(\PDO::ATTR_DEFAULT_FETCH_MODE, $mode);
        if ($isSuccess) {
            $this->fetchTarget = $target;
class MyClass { }

$x = new MyClass();
$x->foo = true;
            $this->fetchTargetConstructorArgs = $ctor_args;

        }

        return $isSuccess;
    }

    /**
     * @return string
     */
    protected function getTableName()
    {
        $statementType = $this->statement->getType();
        if ($statementType !== 'SELECT') {
            return '';
        }

        $sqlText = strtoupper($this->sqlText);
        $idx     = strpos($sqlText, ' FROM ');
        $table   = substr($this->sqlText, $idx + 6);
        $table   = trim($table);

        if (strpos($table, '(') !== false) {
            return '';
        }

        $idxSpace = strpos($table, ' ');
        if ($idxSpace !== false) {
            $table = substr($table, 0, $idxSpace);
        }

        return $table;
    }

    /**
     * @param string $data_type The data type name
     *
     * @return int
     */
    protected function getPDODataType($data_type)
    {
        //TODO Add all oracle data types
        $pdoDataType = \PDO::PARAM_STR;
        switch ($data_type) {
            case 'NUMBER':
                $pdoDataType = \PDO::PARAM_INT;
                break;
            case 'CHAR':
            case 'VARCHAR2':
            case 'NVARCHAR2':
                $pdoDataType = \PDO::PARAM_STR;
                break;
            case 'LOB':
            case 'CLOB':
            case 'BLOB':
            case 'NCLOB':
                $pdoDataType = \PDO::PARAM_LOB;
                break;
            case 'BOOLEAN':
                $pdoDataType = \PDO::PARAM_BOOL;
        }

        return $pdoDataType;
    }

    /**
     * @param int $type
     * @throws PdoOci8Exception
     * @return int
     */
    protected function getDriverDataType($type)

    {
        $dataType = null;
        switch ($dataType) {
            case \PDO::PARAM_BOOL:
                $dataType = SQLT_BOL;
                break;
            case \PDO::PARAM_INT:
                $dataType = SQLT_INT;
                break;
            case \PDO::PARAM_LOB:
                $dataType = SQLT_CLOB;
                break;
            case \PDO::PARAM_STMT:
                throw new PdoOci8Exception('Parameter type \PDO::PARAM_STMT is not currently supported.');
            case \PDO::PARAM_NULL:
            case \PDO::PARAM_STR:
                $dataType = SQLT_CHR;
                break;
            case \PDO::PARAM_INPUT_OUTPUT:
            case \PDO::PARAM_INPUT_OUTPUT | \PDO::PARAM_BOOL:
            case \PDO::PARAM_INPUT_OUTPUT | \PDO::PARAM_INT:
            case \PDO::PARAM_INPUT_OUTPUT | \PDO::PARAM_LOB:
            case \PDO::PARAM_INPUT_OUTPUT | \PDO::PARAM_STMT:
            case \PDO::PARAM_INPUT_OUTPUT | \PDO::PARAM_NULL:
            case \PDO::PARAM_INPUT_OUTPUT | \PDO::PARAM_STR:
                throw new PdoOci8Exception('Parameter type \PDO::PARAM_INPUT_OUTPUT is not currently supported.');
        }

        return $dataType;
    }

    /**
     * @return Oci8ConnectionInterface
     */
    protected function getConnection()
    {
        return $this->connection;
    }

    /**
     * @return \Traversable
     */
    protected function getInternalIterator()
    {
        if ($this->iterator instanceof \Traversable) {
            return $this->iterator;
        }

        $rows = $this->fetchAll();
        if ($rows === false) {
            //TODO Throw Exception?
            $rows = array();
        }

        $this->iterator = new \ArrayIterator($rows);

        return $this->iterator;
    }

    /**
     * @return array
     */
    public function current()
    {
        $iterator = $this->getInternalIterator();

        return $iterator->current();
    }

    public function next()
    {
        $iterator = $this->getInternalIterator();

        $iterator->next();
    }

    /**
     * @return int|null
     */
    public function key()
    {
        $iterator = $this->getInternalIterator();

        return $iterator->key();
    }

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

        return $iterator->valid();
    }

    public function rewind()
    {
        $iterator = $this->getInternalIterator();

        $iterator->rewind();
    }
}


jpina / pdooci8