Oracle::lastInsertId() - Code Metrics - Inspection of "kw_mapper - changes for MSSQL and Oracle, separate..." - alex-kalanis/kw_mapper - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 5d8af1...e44bd6 )

by Petr

created 2025-05-11 16:15 UTC

Oracle::lastInsertId() A

↳ Parent: Oracle

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	1
eloc	1
c	1
b	0
f	0
nc	1
nop	0
dl	0
loc	3
rs	10

<?php

namespace kalanis\kw_mapper\Storage\Database\Raw;


use kalanis\kw_mapper\MapperException;
use kalanis\kw_mapper\Storage\Database\ASQL;
use kalanis\kw_mapper\Storage\Database\Dialects;
use kalanis\kw_mapper\Storage\Database\TBindNames;


/**
 * Class Oracle
 * @package kalanis\kw_mapper\Storage\Database\Raw
 * Secondary connector to Oracle DB; use when the primary one under PDO has problems
 * @codeCoverageIgnore remote connection
 */
class Oracle extends ASQL
{
    use TBindNames;

    protected string $extension = 'oci8';
    /** @var resource|null */
    protected $connection = null;
    /** @var resource|null */
    protected $lastStatement = null;

    protected bool $autoCommit = true;

    public function disconnect(): void
    {
        if ($this->isConnected()) {
            \oci_close($this->connection);
            \oci_close(/** @scrutinizer ignore-type */ $this->connection);
        }
        $this->connection = null;
    }

    public function languageDialect(): string
    {
        return Dialects\Oracle::class;
    }

    public function query(string $query, array $params): array
    {
        if (empty($query)) {
            return [];
        }

        $this->connect();

        $statement = \oci_parse($this->connection, $query);
        $statement = \oci_parse(/** @scrutinizer ignore-type */ $this->connection, $query);
        if (false === $statement) {
            $err = \oci_error();
            throw new MapperException('oci8 parse error: ' . (!empty($err['message']) ? strval($err['message']) : 'error also has error'));
        }
        foreach ($params as $paramName => $paramValue) {
            \oci_bind_by_name($statement, $paramName, $params[$paramName], -1, $this->getType($paramValue));
        }
        if (!\oci_execute($statement, $this->getExecMode())) {
            $err = \oci_error($statement);
            throw new MapperException('oci8 connection error: ' . (!empty($err['message']) ? strval($err['message']) : 'error also has error'));
        };
        $results = [];
        \oci_fetch_all($statement, $results, 0, -1, OCI_ASSOC);

        $this->lastStatement = $statement;

        return $results;
    }

    public function exec(string $query, array $params): bool
    {
        if (empty($query)) {
            return false;
        }

        $this->connect();

        $statement = \oci_parse($this->connection, $query);
        $statement = \oci_parse(/** @scrutinizer ignore-type */ $this->connection, $query);
        if (false === $statement) {
            $err = \oci_error();
            throw new MapperException('oci8 parse error: ' . (!empty($err['message']) ? strval($err['message']) : 'error also has error'));
        }
        foreach ($params as $paramName => $paramValue) {
            \oci_bind_by_name($statement, $paramName, $params[$paramName], -1, $this->getType($paramValue));
        }
        $this->lastStatement = $statement;

        if (!\oci_execute($statement, $this->getExecMode())) {
            $err = \oci_error($statement);
            throw new MapperException('oci8 connection error: ' . (!empty($err['message']) ? strval($err['message']) : 'error also has error'));
        }
        return true;
    }

    /**
     * @param mixed $var
     * @return int
     */
    protected function getType($var): int
    {
        if (is_bool($var)) {
            return OCI_B_BOL;
        } elseif (is_int($var)) {
            return OCI_B_INT;
        } elseif (is_float($var)) {
            return OCI_B_NUM;
        } else {
            return SQLT_CHR;
        }
    }

    protected function getExecMode(): int
    {
        return $this->autoCommit ? OCI_COMMIT_ON_SUCCESS : OCI_NO_AUTO_COMMIT;
    }

    /**
     * @throws MapperException
     */
    public function connect(): void
    {
        if (!$this->isConnected()) {
            $this->connection = $this->connectToServer();
        }
    }

    /**
     * @throws MapperException
     * @return resource
     */
    protected function connectToServer()
    {
        $connection = \oci_connect(
            $this->config->getUser(),
            $this->config->getPassword(),
            $this->config->getLocation(),
        );
        if (false === $connection) {
            $err = \oci_error();
            throw new MapperException('oci8 connection error: ' . (!empty($err['message']) ? strval($err['message']) : 'error also has error'));
        }

        return $connection;
    }

    public function lastInsertId(): ?string
    {
        return null;
    }

    public function rowCount(): ?int
    {
        return $this->lastStatement ? intval(\oci_num_rows($this->lastStatement)) : null ;
    }

    public function beginTransaction(): bool
    {
        if (!$this->isConnected()) {
            $this->connection = $this->connectToServer();
        }

        $this->autoCommit = false;
        return true;
    }

    public function commit(): bool
    {
        $result = \oci_commit($this->connection);
        $this->autoCommit = true;
        return $result;
    }

    public function rollBack(): bool
    {
        $result = \oci_rollback($this->connection);
        $this->autoCommit = true;
        return $result;
    }
}


alex-kalanis / kw_mapper

Push — master ( 5d8af1...e44bd6 )

Oracle::lastInsertId() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like