vakata\database\driver\odbc\Statement

Complexity

Total Complexity

14

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
B	execute()	0	21	6
B	convert()	0	16	7

<?php

namespace vakata\database\driver\odbc;

use \vakata\database\DBException;
use \vakata\database\DriverInterface;
use \vakata\database\StatementInterface;
use \vakata\database\ResultInterface;

class Statement implements StatementInterface
{
    protected $statement;
    protected $sql;
    protected $driver;
    protected $charIn;
    protected $charOut;

    public function __construct(string $statement, $driver, $charIn = null, $charOut = null)
    {
        $this->sql = $statement;
        $this->driver = $driver;
        $this->charIn = $charIn;
        $this->charOut = $charOut;
        $this->statement = \odbc_prepare($this->driver, $statement);
    }
    public function execute(array $data = []) : ResultInterface
    {
        if (!is_array($data)) {
            $data = array();
        }
        $data = $this->convert($data);
        $temp = \odbc_execute($this->statement, $data);
        if (!$temp) {
            throw new DBException('Could not execute query : '.\odbc_errormsg($this->driver));
        }
        $iid = null;
        if (preg_match('@^\s*(INSERT|REPLACE)\s+INTO@i', $this->sql)) {
            $iid = \odbc_exec($this->driver, 'SELECT @@IDENTITY');
            if ($iid && \odbc_fetch_row($iid)) {
                $iid = odbc_result($result, 1);

The variable $result does not exist. Did you forget to declare it?

            } else {
                $iid = null;
            }
        }
        return new Result($this->statement, $data, $iid, $this->charIn, $this->charOut);
    }
    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->charOut, $this->charIn, $data);
        }
        return $data;
    }
}