PDOSqlsrvStatement::__construct() - Code Metrics - Inspection of "add test for issue 3516 - invalid last inserted id..." - doctrine/dbal - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — 2.9 (#3517)

unknown

created 2019-04-18 17:56 UTC

PDOSqlsrvStatement::__construct() A

↳ Parent: PDOSqlsrvStatement

Complexity

Conditions	2
Paths	2

Size

Total Lines	11
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	6
dl	0
loc	11
rs	10
c	0
b	0
f	0
cc	2
nc	2
nop	3

<?php

namespace Doctrine\DBAL\Driver\PDOSqlsrv;

use Doctrine\DBAL\Driver\PDOConnection;
use Doctrine\DBAL\Driver\PDOStatement;
use Doctrine\DBAL\Driver\Statement;
use Doctrine\DBAL\Driver\StatementIterator;
use Doctrine\DBAL\ParameterType;
use IteratorAggregate;
use PDO;
use function array_key_exists;
use function is_numeric;
use function stripos;

/**
 * PDO SQL Server Statement
 */
class PDOSqlsrvStatement implements IteratorAggregate, Statement
{
    /**
     * The PDO Connection.
     *
     * @var PDOConnection
     */
    private $conn;

    /**
     * The SQL statement to execute.
     *
     * @var string
     */
    private $sql;

    /**
     * The PDO statement.
     *
     * @var PDOStatement|null
     */
    private $stmt;

    /**
     * The last insert ID.
     *
     * @var LastInsertId|null
     */
    private $lastInsertId;

    /**
     * The affected number of rows
     *
     * @var int|null
     */
    private $rowCount;

    /**
     * Append to any INSERT query to retrieve the last insert id.
     */
    public const LAST_INSERT_ID_SQL = ';SELECT SCOPE_IDENTITY() AS LastInsertId;';

    /**
     * @param string $sql
     */
    public function __construct(PDOConnection $conn, $sql, ?LastInsertId $lastInsertId = null)
    {
        $this->conn = $conn;
        $this->sql  = $sql;

        if (stripos($sql, 'INSERT INTO ') === 0) {
            $this->sql         .= self::LAST_INSERT_ID_SQL;
            $this->lastInsertId = $lastInsertId;
        }

        $this->stmt = $this->prepare();
    }

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

    /**
     * {@inheritdoc}
     */
    public function bindParam($column, &$variable, $type = ParameterType::STRING, $length = null, $driverOptions = null)
    {
        if (($type === ParameterType::LARGE_OBJECT || $type === ParameterType::BINARY)
            && $driverOptions === null
        ) {
            $driverOptions = PDO::SQLSRV_ENCODING_BINARY;
        }

        return $this->stmt->bindParam($column, $variable, $type, $length, $driverOptions);
        return $this->stmt->/** @scrutinizer ignore-call */ bindParam($column, $variable, $type, $length, $driverOptions);
    }

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

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

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

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

    /**
     * {@inheritdoc}
     */
    public function execute($params = null)
    {
        if ($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 (! $this->stmt) {
            $this->stmt = $this->prepare();
        }

        $this->stmt->execute($params);
        $this->rowCount = $this->rowCount();

        if (! $this->lastInsertId) {
            return;
        }

        $id = null;
        $this->stmt->nextRowset();

        if ($this->columnCount() > 0) {
            $id = $this->fetchColumn();
        }

        if (! $id) {
            while ($this->stmt->nextRowset()) {
                if ($this->columnCount() === 0) {
                    continue;
                }

                $id = $this->fetchColumn();
            }
        }

        $this->lastInsertId->setId($id);
    }

    /**
     * Prepares PDO statement resource
     *
     * @return PDOStatement
     */
    private function prepare()
    {
        return $this->conn->prepare($this->sql);

    }

    /**
     * {@inheritdoc}
     */
    public function setFetchMode($fetchMode, $arg2 = null, $arg3 = null)
    {
        return $this->stmt->setFetchMode($fetchMode, $arg2, $arg3);
    }

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

    /**
     * {@inheritdoc}
     */
    public function fetch($fetchMode = null, $cursorOrientation = PDO::FETCH_ORI_NEXT, $cursorOffset = 0)
    {
        return $this->stmt->fetch($fetchMode, $cursorOrientation, $cursorOffset);
    }

    /**
     * {@inheritdoc}
     */
    public function fetchAll($fetchMode = null, $fetchArgument = null, $ctorArgs = null)
    {
        return $this->stmt->fetchAll($fetchMode, $fetchArgument, $ctorArgs);
    }

    /**
     * {@inheritdoc}
     */
    public function fetchColumn($columnIndex = 0)
    {
        return $this->stmt->fetchColumn($columnIndex);
    }

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


doctrine / dbal

Pull Request — 2.9 (#3517)

PDOSqlsrvStatement::__construct() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like