vakata\database\driver\odbc\Result

Complexity

Total Complexity

24

Size/Duplication

Total Lines	104
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	16	3
A	__destruct()	0	4	1
A	affected()	0	4	1
A	insertID()	0	4	1
A	toArray()	0	4	1
A	count()	0	4	1
A	key()	0	4	1
A	current()	0	4	1
A	rewind()	0	12	3
A	next()	0	14	3
A	valid()	0	4	1
B	convert()	0	16	7

<?php

namespace vakata\database\driver\odbc;

use \vakata\database\DBException;
use \vakata\database\DriverInterface;
use \vakata\database\ResultInterface;
use \vakata\collection\Collection;

class Result implements ResultInterface
{
    protected $statement;
    protected $data;
    protected $charIn;
    protected $charOut;
    protected $columns;
    protected $last = null;
    protected $fetched = -1;
    protected $iid = null;

    public function __construct($statement, $data, $iid, $charIn = null, $charOut = null)
    {
        $this->statement = $statement;
        $this->data = $data;
        $this->iid = $iid;
        $this->charIn = $charIn;
        $this->charOut = $charOut;
        $this->columns = [];
        $i = 0;
        try {
            while ($temp = \odbc_field_name($this->statement, ++$i)) {
                $this->columns[] = $temp;
            }
        } catch (\Exception $ignore) {

Consider adding a comment why this CATCH block is empty.

        }
    }
    public function __destruct()
    {
        \odbc_free_result($this->statement);
    }
    public function affected() : int
    {
        return \odbc_num_rows($this->statement);
    }
    public function insertID()
    {
        return $this->iid;
    }
    public function toArray() : array
    {
        return iterator_to_array($this);
    }

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

    public function key()
    {
        return $this->fetched;
    }
    public function current()
    {
        return $this->last;
    }
    public function rewind()
    {
        if ($this->fetched >= 0) {
            $temp = \odbc_execute($this->statement, $this->data);
            if (!$temp) {
                throw new DBException('Could not execute query : '.\odbc_errormsg());
            }
        }
        $this->last = null;
        $this->fetched = -1;
        $this->next();
    }
    public function next()
    {
        $this->fetched ++;
        $temp = \odbc_fetch_row($this->statement);
        if (!$temp) {
            $this->last = false;
        } else {
            $this->last = [];
            foreach ($this->columns as $col) {
                $this->last[$col] = \odbc_result($this->statement, $col);
            }
            $this->last = $this->convert($this->last);
        }
    }
    public function valid()
    {
        return !!$this->last;
    }
    protected function convert($data)
    {
        if (!is_callable("\iconv") || !isset($this->charIn) || !isset($this->charOut)) {
            return $data;
        }
        if (is_array($data)) {
            foreach ($data as $k => $v) {
                $data[$k] = $this->convert($v);
            }
            return $data;
        }
        if (is_string($data)) {
            return \iconv($this->charIn, $this->charOut, $data);
        }
        return $data;
    }
}