Yajra\Oci8\Schema\Sequence

Complexity

Total Complexity

15

Size/Duplication

Total Lines	118
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

23.33%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	create()	0	10	3
A	drop()	0	18	3
A	nextValue()	0	8	2
A	currentValue()	0	4	1
A	lastInsertId()	0	9	3
A	exists()	0	10	2

<?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  integer $start
     * @param  boolean $nocache
     * @return boolean
     */
    public function create($name, $start = 1, $nocache = false)
    {
        if (! $name) {
            return false;
        }

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

        return $this->connection->statement("create sequence {$name} start with {$start} {$nocache}");
    }

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

        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 boolean
     */
    public function exists($name)
    {
        if (! $name) {
            return false;
        }

        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 integer
     */
    public function nextValue($name)
    {
        if (! $name) {
            return 0;
        }

        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 integer
     */
    public function currentValue($name)
    {
        return $this->lastInsertId($name);
    }

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

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