Doctrine\DBAL\Driver\SQLAnywhere\SQLAnywhereStatement

Complexity

Total Complexity

53

Size/Duplication

Total Lines	328
Duplicated Lines	0 %

Test Coverage

Coverage

1.8%

Importance

Changes

0

15 Methods

Rating	Name	Duplication	Size	Complexity
A	rowCount()	0	3	1
A	errorInfo()	0	3	1
A	bindValue()	0	3	1
A	execute()	0	19	6
A	errorCode()	0	3	1
A	fetchColumn()	0	10	3
B	fetch()	0	43	11
A	setFetchMode()	0	13	3
A	__construct()	0	11	3
A	columnCount()	0	3	1
A	getIterator()	0	3	1
A	fetchAll()	0	24	6
A	closeCursor()	0	7	2
B	bindParam()	0	29	8
A	castObject()	0	34	5

<?php

namespace Doctrine\DBAL\Driver\SQLAnywhere;

use Doctrine\DBAL\DBALException;
use Doctrine\DBAL\Driver\Statement;
use Doctrine\DBAL\Driver\StatementIterator;
use Doctrine\DBAL\FetchMode;
use Doctrine\DBAL\ParameterType;
use IteratorAggregate;
use ReflectionClass;
use ReflectionObject;
use stdClass;
use const SASQL_BOTH;

The constant SASQL_BOTH was not found. Maybe you did not declare it correctly or list all dependencies?

use function array_key_exists;
use function count;
use function func_get_args;
use function gettype;
use function is_array;
use function is_numeric;
use function is_object;
use function is_resource;
use function is_string;
use function sasql_fetch_array;

The function sasql_fetch_array was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_fetch_assoc;

The function sasql_fetch_assoc was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_fetch_object;

The function sasql_fetch_object was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_fetch_row;

The function sasql_fetch_row was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_prepare;

The function sasql_prepare was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_stmt_affected_rows;

The function sasql_stmt_affected_rows was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_stmt_bind_param_ex;

The function sasql_stmt_bind_param_ex was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_stmt_errno;

The function sasql_stmt_errno was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_stmt_error;

The function sasql_stmt_error was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_stmt_execute;

The function sasql_stmt_execute was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_stmt_field_count;

The function sasql_stmt_field_count was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_stmt_reset;

The function sasql_stmt_reset was not found. Maybe you did not declare it correctly or list all dependencies?

use function sasql_stmt_result_metadata;

The function sasql_stmt_result_metadata was not found. Maybe you did not declare it correctly or list all dependencies?

use function sprintf;

/**
 * SAP SQL Anywhere implementation of the Statement interface.
 */
class SQLAnywhereStatement implements IteratorAggregate, Statement
{
    /** @var resource The connection resource. */
    private $conn;

    /** @var string Name of the default class to instantiate when fetching class instances. */
    private $defaultFetchClass = '\stdClass';

    /** @var mixed[] Constructor arguments for the default class to instantiate when fetching class instances. */
    private $defaultFetchClassCtorArgs = [];

    /** @var int Default fetch mode to use. */
    private $defaultFetchMode = FetchMode::MIXED;

    /** @var resource The result set resource to fetch. */
    private $result;

    /** @var resource The prepared SQL statement to execute. */
    private $stmt;

    /** @var mixed[] The references to bound parameter values. */
    private $boundValues = [];

    /**
     * Prepares given statement for given connection.
     *
     * @param resource $conn The connection resource to use.
     * @param string   $sql  The SQL statement to prepare.
     *
     * @throws SQLAnywhereException
     */
    public function __construct($conn, $sql)
    {
        if (! is_resource($conn)) {
            throw new SQLAnywhereException('Invalid SQL Anywhere connection resource: ' . $conn);
        }

        $this->conn = $conn;
        $this->stmt = sasql_prepare($conn, $sql);

The function sasql_prepare was not found. Maybe you did not declare it correctly or list all dependencies?

        if (! is_resource($this->stmt)) {
            throw SQLAnywhereException::fromSQLAnywhereError($conn);
        }
    }

    /**
     * {@inheritdoc}
     *
     * @throws SQLAnywhereException
     */
    public function bindParam($column, &$variable, $type = ParameterType::STRING, $length = null)
    {
        switch ($type) {
            case ParameterType::INTEGER:
            case ParameterType::BOOLEAN:
                $type = 'i';
                break;

            case ParameterType::LARGE_OBJECT:
                $type = 'b';
                break;

            case ParameterType::NULL:
            case ParameterType::STRING:
            case ParameterType::BINARY:
                $type = 's';
                break;

            default:
                throw new SQLAnywhereException('Unknown type: ' . $type);
        }

        $this->boundValues[$column] =& $variable;

        if (! sasql_stmt_bind_param_ex($this->stmt, $column - 1, $variable, $type, $variable === null)) {

The function sasql_stmt_bind_param_ex was not found. Maybe you did not declare it correctly or list all dependencies?

            throw SQLAnywhereException::fromSQLAnywhereError($this->conn, $this->stmt);
        }

        return true;
    }

    /**
     * {@inheritdoc}
     */
    public function bindValue($param, $value, $type = ParameterType::STRING)
    {
        return $this->bindParam($param, $value, $type);
    }

    /**
     * {@inheritdoc}
     *
     * @throws SQLAnywhereException
     */
    public function closeCursor()
    {
        if (! sasql_stmt_reset($this->stmt)) {

The function sasql_stmt_reset was not found. Maybe you did not declare it correctly or list all dependencies?

            throw SQLAnywhereException::fromSQLAnywhereError($this->conn, $this->stmt);
        }

        return true;
    }

    /**
     * {@inheritdoc}
     */
    public function columnCount()
    {
        return sasql_stmt_field_count($this->stmt);

The function sasql_stmt_field_count was not found. Maybe you did not declare it correctly or list all dependencies?

    }

    /**
     * {@inheritdoc}
     */
    public function errorCode()
    {
        return sasql_stmt_errno($this->stmt);

The function sasql_stmt_errno was not found. Maybe you did not declare it correctly or list all dependencies?

    }

    /**
     * {@inheritdoc}
     */
    public function errorInfo()
    {
        return sasql_stmt_error($this->stmt);

The function sasql_stmt_error was not found. Maybe you did not declare it correctly or list all dependencies?

    }

    /**
     * {@inheritdoc}
     *
     * @throws SQLAnywhereException
     */
    public function execute($params = null)
    {
        if (is_array($params)) {
            $hasZeroIndex = array_key_exists(0, $params);

            foreach ($params as $key => $val) {
                $key = $hasZeroIndex && is_numeric($key) ? $key + 1 : $key;

                $this->bindValue($key, $val);
            }
        }

        if (! sasql_stmt_execute($this->stmt)) {

The function sasql_stmt_execute was not found. Maybe you did not declare it correctly or list all dependencies?

            throw SQLAnywhereException::fromSQLAnywhereError($this->conn, $this->stmt);
        }

        $this->result = sasql_stmt_result_metadata($this->stmt);

The function sasql_stmt_result_metadata was not found. Maybe you did not declare it correctly or list all dependencies?

        return true;
    }

    /**
     * {@inheritdoc}
     *
     * @throws SQLAnywhereException
     */
    public function fetch($fetchMode = null, ...$args)
    {
        if (! is_resource($this->result)) {
            return false;
        }

        $fetchMode = $fetchMode ?: $this->defaultFetchMode;

        switch ($fetchMode) {
            case FetchMode::COLUMN:
                return $this->fetchColumn();

            case FetchMode::ASSOCIATIVE:
                return sasql_fetch_assoc($this->result);

The function sasql_fetch_assoc was not found. Maybe you did not declare it correctly or list all dependencies?

            case FetchMode::MIXED:
                return sasql_fetch_array($this->result, SASQL_BOTH);

The constant SASQL_BOTH was not found. Maybe you did not declare it correctly or list all dependencies?

The function sasql_fetch_array was not found. Maybe you did not declare it correctly or list all dependencies?

            case FetchMode::CUSTOM_OBJECT:
                $className = $this->defaultFetchClass;
                $ctorArgs  = $this->defaultFetchClassCtorArgs;

                if (count($args) > 0) {
                    $className = $args[0];
                    $ctorArgs  = $args[1] ?? [];
                }

                $result = sasql_fetch_object($this->result);

The function sasql_fetch_object was not found. Maybe you did not declare it correctly or list all dependencies?

                if ($result instanceof stdClass) {
                    $result = $this->castObject($result, $className, $ctorArgs);
                }

                return $result;

            case FetchMode::NUMERIC:
                return sasql_fetch_row($this->result);

The function sasql_fetch_row was not found. Maybe you did not declare it correctly or list all dependencies?

            case FetchMode::STANDARD_OBJECT:
                return sasql_fetch_object($this->result);

            default:
                throw new SQLAnywhereException('Fetch mode is not supported: ' . $fetchMode);
        }
    }

    /**
     * {@inheritdoc}
     */
    public function fetchAll($fetchMode = null, ...$args)
    {
        $rows = [];

        switch ($fetchMode) {
            case FetchMode::CUSTOM_OBJECT:
                while (($row = $this->fetch(...func_get_args())) !== false) {
                    $rows[] = $row;
                }
                break;

            case FetchMode::COLUMN:
                while (($row = $this->fetchColumn()) !== false) {
                    $rows[] = $row;
                }
                break;

            default:
                while (($row = $this->fetch($fetchMode)) !== false) {
                    $rows[] = $row;
                }
        }

        return $rows;
    }

    /**
     * {@inheritdoc}
     */
    public function fetchColumn($columnIndex = 0)
    {
        $row = $this->fetch(FetchMode::NUMERIC);

        if ($row === false) {
            return false;
        }

        if (! array_key_exists($columnIndex, $row)) {
            throw DBALException::invalidColumnIndex($columnIndex, count($row));
        }
    }

    /**
     * {@inheritdoc}
     */
    public function getIterator()
    {
        return new StatementIterator($this);
    }

    /**
     * {@inheritdoc}
     */
    public function rowCount() : int
    {
        return sasql_stmt_affected_rows($this->stmt);

The function sasql_stmt_affected_rows was not found. Maybe you did not declare it correctly or list all dependencies?

    }

    /**
     * {@inheritdoc}
     */
    public function setFetchMode($fetchMode, ...$args)
    {
        $this->defaultFetchMode = $fetchMode;

        if (isset($args[0])) {
            $this->defaultFetchClass = $args[0];
        }

        if (! isset($args[1])) {
            return;
        }

        $this->defaultFetchClassCtorArgs = (array) $args[1];
    }

    /**
     * Casts a stdClass object to the given class name mapping its' properties.
     *
     * @param stdClass      $sourceObject     Object to cast from.
     * @param string|object $destinationClass Name of the class or class instance to cast to.
     * @param mixed[]       $ctorArgs         Arguments to use for constructing the destination class instance.
     *
     * @return object
     *
     * @throws SQLAnywhereException
     */
    private function castObject(stdClass $sourceObject, $destinationClass, array $ctorArgs = [])
    {
        if (! is_string($destinationClass)) {
            if (! is_object($destinationClass)) {
                throw new SQLAnywhereException(sprintf(
                    'Destination class has to be of type string or object, %s given.',
                    gettype($destinationClass)
                ));
            }
        } else {
            $destinationClass = new ReflectionClass($destinationClass);
            $destinationClass = $destinationClass->newInstanceArgs($ctorArgs);
        }

        $sourceReflection           = new ReflectionObject($sourceObject);
        $destinationClassReflection = new ReflectionObject($destinationClass);

        foreach ($sourceReflection->getProperties() as $sourceProperty) {
            $sourceProperty->setAccessible(true);

            $name  = $sourceProperty->getName();
            $value = $sourceProperty->getValue($sourceObject);

            if ($destinationClassReflection->hasProperty($name)) {
                $destinationProperty = $destinationClassReflection->getProperty($name);

                $destinationProperty->setAccessible(true);
                $destinationProperty->setValue($destinationClass, $value);
            } else {
                $destinationClass->$name = $value;
            }
        }

        return $destinationClass;
    }
}