Ytake\LaravelCouchbase\Schema\Blueprint

Complexity

Total Complexity

12

Size/Duplication

Total Lines	144
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

82.76%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	connector()	0	4	1
A	setOptions()	0	4	1
A	create()	0	4	1
A	drop()	0	4	1
A	dropPrimary()	0	5	1
A	dropIndex()	0	5	1
A	primaryIndex()	0	9	1
A	index()	0	13	2
A	getTable()	0	4	1
A	detectIndexName()	0	6	2

<?php

/**
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

namespace Ytake\LaravelCouchbase\Schema;

use Ytake\LaravelCouchbase\Database\CouchbaseConnection;

/**
 * Class Blueprint
 *
 * @author Yuuki Takezawa<yuuki.takezawa@comnect.jp.net>
 */
class Blueprint extends \Illuminate\Database\Schema\Blueprint
{
    use NotSupportedTrait;

    /** @var  CouchbaseConnection */
    protected $connection;

    /** @var string[] */
    protected $options = [
        'bucketType'   => 'couchbase',
        'saslPassword' => '',
        'flushEnabled' => true,
    ];

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

    /**
     * @param array $options
     */
    public function setOptions(array $options)
    {
        $this->options = array_merge($this->options, $options);

It seems like array_merge($this->options, $options) of type array is incompatible with the declared type array<integer,string> of property $options.

    }

    /**
     * @return bool
     */
    public function create()
    {
        return $this->connection->manager()->createBucket($this->table, $this->options);
    }

    /**
     * {@inheritdoc}
     */
    public function drop()
    {
        return $this->connection->manager()->removeBucket($this->table);
    }

    /**
     * drop for N1QL primary index
     *
     * @param string $index
     * @param bool   $ignoreIfNotExist
     *
     * @return mixed
     */
    public function dropPrimary($index = null, $ignoreIfNotExist = false)
    {
        return $this->connection->openBucket($this->getTable())
            ->manager()->dropN1qlPrimaryIndex($this->detectIndexName($index), $ignoreIfNotExist);
    }

    /**
     * drop for N1QL secondary index
     *
     * @param string $index
     * @param bool   $ignoreIfNotExist
     *
     * @return mixed
     */
    public function dropIndex($index, $ignoreIfNotExist = false)
    {
        return $this->connection->openBucket($this->getTable())
            ->manager()->dropN1qlIndex($index, $ignoreIfNotExist);
    }

    /**
     * Specify the primary index for the current bucket.
     *
     * @param string|null $name
     * @param boolean     $ignoreIfExist  if a primary index already exists, an exception will be thrown unless this is
     *                                    set to true.
     * @param boolean     $defer          true to defer building of the index until buildN1qlDeferredIndexes()}is
     *                                    called (or a direct call to the corresponding query service API).
     *
     * @return mixed
     */
    public function primaryIndex($name = null, $ignoreIfExist = false, $defer = false)
    {
        return $this->connection->openBucket($this->getTable())
            ->manager()->createN1qlPrimaryIndex(
                $index = $this->detectIndexName($name),
                $ignoreIfExist,
                $defer
            );
    }

    /**
     * Specify a secondary index for the current bucket.
     *
     * @param array   $columns            the JSON fields to index.
     * @param string  $name               the name of the index.
     * @param string  $whereClause        the WHERE clause of the index.
     * @param boolean $ignoreIfExist      if a secondary index already exists with that name, an exception will be
     *                                    thrown unless this is set to true.
     * @param boolean $defer              true to defer building of the index until buildN1qlDeferredIndexes() is
     *                                    called (or a direct call to the corresponding query service API).
     *
     * @return mixed
     */
    public function index($columns, $name = null, $whereClause = '', $ignoreIfExist = false, $defer = false)
    {
        $name = (is_null($name)) ? $this->getTable() . "_secondary_index" : $name;

        return $this->connection->openBucket($this->getTable())
            ->manager()->createN1qlIndex(
                $name,
                $columns,
                $whereClause,
                $ignoreIfExist,
                $defer
            );
    }

    /**
     * Get the table the blueprint describes.
     *
     * @return string
     */
    public function getTable()
    {
        return $this->table;
    }

    /**
     * @param $index
     *
     * @return string
     */
    protected function detectIndexName($index):string
    {
        $index = (is_null($index)) ? "" : $index;

        return $index;
    }
}