Yajra\Oci8\Schema\Sequence

Complexity

Total Complexity

18

Size/Duplication

Total Lines	147
Duplicated Lines	22.45 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

23.33%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	create()	0	16	4
A	wrap()	0	8	2
A	drop()	0	20	3
A	exists()	12	12	2
A	nextValue()	10	10	2
A	currentValue()	0	4	1
A	lastInsertId()	11	11	3

<?php

namespace Yajra\Oci8\Schema;

use Illuminate\Database\Connection;

class Sequence
{
    /**
     * @var \Illuminate\Database\Connection|\Yajra\Oci8\Oci8Connection
     */
    protected $connection;

    /**
     * @param Connection $connection
     */
    public function __construct(Connection $connection)
    {
        $this->connection = $connection;
    }

    /**
     * function to create oracle sequence.
     *
     * @param  string $name
     * @param  int $start
     * @param  bool $nocache
     * @return bool
     */
    public function create($name, $start = 1, $nocache = false, $min = 1, $max = false, $increment = 1)
    {
        if (! $name) {
            return false;
        }

        $name = $this->wrap($name);

        $nocache = $nocache ? 'nocache' : '';

        $max = $max ? " maxvalue {$max}" : '';

        $sequence_stmt = "create sequence {$name} minvalue {$min} {$max} start with {$start} increment by {$increment} {$nocache}";

        return $this->connection->statement($sequence_stmt);
    }

    /**
     * Wrap sequence name with schema prefix.
     *
     * @param string $name
     * @return string
     */
    public function wrap($name)
    {
        if ($this->connection->getConfig('prefix_schema')) {
            return $this->connection->getConfig('prefix_schema') . '.' . $name;
        }

        return $name;
    }

    /**
     * function to safely drop sequence db object.
     *
     * @param  string $name
     * @return bool
     */
    public function drop($name)
    {
        // check if a valid name and sequence exists
        if (! $name || ! $this->exists($name)) {
            return false;
        }

        $name = $this->wrap($name);

        return $this->connection->statement("
            declare
                e exception;
                pragma exception_init(e,-02289);
            begin
                execute immediate 'drop sequence {$name}';
            exception
            when e then
                null;
            end;");
    }

    /**
     * function to check if sequence exists.
     *
     * @param  string $name
     * @return bool
     */
    public function exists($name)
    {
        if (! $name) {
            return false;
        }

        $name = $this->wrap($name);

        return $this->connection->selectOne(
            "select * from all_sequences where sequence_name=upper('{$name}') and sequence_owner=upper(user)"
        );
    }

    /**
     * get sequence next value.
     *
     * @param  string $name
     * @return int
     */
    public function nextValue($name)
    {
        if (! $name) {
            return 0;
        }

        $name = $this->wrap($name);

        return $this->connection->selectOne("SELECT $name.NEXTVAL as id FROM DUAL")->id;
    }

    /**
     * same function as lastInsertId. added for clarity with oracle sql statement.
     *
     * @param  string $name
     * @return int
     */
    public function currentValue($name)
    {
        return $this->lastInsertId($name);
    }

    /**
     * function to get oracle sequence last inserted id.
     *
     * @param  string $name
     * @return int
     */
    public function lastInsertId($name)
    {
        // check if a valid name and sequence exists
        if (! $name || ! $this->exists($name)) {
            return 0;
        }

        $name = $this->wrap($name);

        return $this->connection->selectOne("select {$name}.currval as id from dual")->id;
    }
}