Yajra\Oci8\Query\OracleBuilder

Complexity

Total Complexity

11

Size/Duplication

Total Lines	131
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	4

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	insertLob()	0	9	1
A	updateLob()	0	11	1
B	whereIn()	0	20	5
A	runSelect()	0	12	2
A	exists()	0	8	1

<?php

namespace Yajra\Oci8\Query;

use Illuminate\Database\ConnectionInterface;
use Illuminate\Database\Query\Builder;
use Yajra\Oci8\Query\Grammars\OracleGrammar;
use Yajra\Oci8\Query\Processors\OracleProcessor;

class OracleBuilder extends Builder
{
    /**
     * The database query grammar instance.
     *
     * @var OracleGrammar
     */
    protected $grammar;

    /**
     * The database query post processor instance.
     *
     * @var OracleProcessor
     */
    protected $processor;

    /**
     * @param ConnectionInterface $connection
     * @param OracleGrammar $grammar
     * @param OracleProcessor $processor
     */
    public function __construct(
        ConnectionInterface $connection,
        OracleGrammar $grammar,
        OracleProcessor $processor
    ) {
        parent::__construct($connection, $grammar, $processor);
    }

    /**
     * Insert a new record and get the value of the primary key.
     *
     * @param  array $values
     * @param  array $binaries
     * @param  string $sequence
     * @return int
     */
    public function insertLob(array $values, array $binaries, $sequence = 'id')
    {
        $sql = $this->grammar->compileInsertLob($this, $values, $binaries, $sequence);

        $values   = $this->cleanBindings($values);
        $binaries = $this->cleanBindings($binaries);

        return $this->processor->saveLob($this, $sql, $values, $binaries);
    }

    /**
     * Update a new record with blob field.
     *
     * @param  array $values
     * @param  array $binaries
     * @param  string $sequence
     * @return boolean
     */
    public function updateLob(array $values, array $binaries, $sequence = 'id')
    {
        $bindings = array_values(array_merge($values, $this->getBindings()));

        $sql = $this->grammar->compileUpdateLob($this, $values, $binaries, $sequence);

        $values   = $this->cleanBindings($bindings);
        $binaries = $this->cleanBindings($binaries);

        return $this->processor->saveLob($this, $sql, $values, $binaries);
    }

    /**
     * Add a "where in" clause to the query.
     * Split one WHERE IN clause into multiple clauses each
     * with up to 1000 expressions to avoid ORA-01795
     *
     * @param  string $column
     * @param  mixed $values
     * @param  string $boolean
     * @param  bool $not
     * @return $this
     */
    public function whereIn($column, $values, $boolean = 'and', $not = false)
    {
        $type = $not ? 'NotIn' : 'In';

        if (count($values) > 1000) {
            $chunks = array_chunk($values, 1000);

            return $this->where(function ($query) use ($column, $chunks, $type) {
                $firstIteration = true;
                foreach ($chunks as $ch) {
                    $sqlClause = $firstIteration ? 'where' . $type : 'orWhere' . $type;
                    $query->$sqlClause($column, $ch);
                    $firstIteration = false;
                }

            }, null, null, $boolean);
        }

        return parent::whereIn($column, $values, $boolean, $not);
    }

    /**
     * Run the query as a "select" statement against the connection.
     *
     * @return array
     */
    protected function runSelect()
    {
        if ($this->lock) {
            $this->connection->beginTransaction();
            $result = $this->connection->select($this->toSql(), $this->getBindings(), ! $this->useWritePdo);
            $this->connection->commit();

            return $result;
        }

        return $this->connection->select($this->toSql(), $this->getBindings(), ! $this->useWritePdo);
    }

    /**
     * Determine if any rows exist for the current query.
     *
     * @return bool|null
     */
    public function exists()
    {
        $limit = $this->limit;
        $result = $this->limit(1)->count() > 0;
        $this->limit($limit);

        return $result;
    }
}