Blueprint::executeAqlCommand() - Code Metrics - Inspection of "Support for TTL index (introduced in ArangoDB 3.5)" - LaravelFreelancerNL/laravel-arangodb - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Pull Request — master (#6)

unknown
created 2019-11-20 14:36 UTC
Blueprint::executeAqlCommand() A

↳ Parent: Blueprint
Complexity

Conditions	1
Paths	1
Size

Total Lines	3
Code Lines	1
Duplication

Lines	0
Ratio	0 %
Importance

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

namespace LaravelFreelancerNL\Aranguent\Schema;

use Closure;
use Illuminate\Support\Fluent;
use Illuminate\Database\Connection;
use Illuminate\Support\Traits\Macroable;
use Illuminate\Database\Schema\Grammars\Grammar as IlluminateGrammar;

/**
 * Class Blueprint.
 *
 * The Schema blueprint works differently from the standard Illuminate version:
 * 1) ArangoDB is schemaless: we don't need to (and can't) create columns
 * 2) ArangoDB doesn't allow DB schema actions within AQL nor within a transaction.
 *
 * This means that:
 * 1) We catch column related methods silently for backwards compatibility and ease of migrating from one DB type to another
 * 2) We don't need to compile AQL for transactions within the accompanying schema grammar. (for now)
 * 3) We can just execute each command on order. We will gather them first for possible future optimisations.
 */
class Blueprint
{
    use Macroable;


    /**
     * The connection that is used by the blueprint.
     *
     * @var \Illuminate\Database\Connection
     */
    protected $connection;

    /**
     * The grammar that is used by the blueprint.
     *
     * @var \LaravelFreelancerNL\Aranguent\Schema\Grammars\Grammar
filter:
    dependency_paths: ["lib/*"]
     */
    protected $grammar;

    /**
     * The collection the blueprint describes.
     *
     * @var string
     */
    protected $collection;

    /**
     * The handler for collection manipulation.
     */
    protected $collectionHandler;

    /**
     * The prefix of the collection.
     *
     * @var string
     */
    protected $prefix;

    /**
     * The commands that should be run for the collection.
     *
     * @var Fluent[]
     */
    protected $commands = [];

    /**
     * Catching attributes to be able to add fluent indexes.
     *
     * @var array
     */
    protected $attributes = [];

    /**
     * Whether to make the collection temporary.
     *
     * @var bool
     */
    public $temporary = false;

    /**
     * Detect if _key (and thus proxy _id) should autoincrement.
     *
     * @var bool
     */
    protected $autoIncrement = false;

    /**
     * Create a new schema blueprint.
     *
     * Blueprint constructor.
     * @param string $collection
     * @param \ArangoDBClient\CollectionHandler $collectionHandler
     * @param Closure|null $callback
     * @param string $prefix
     */
    public function __construct($collection, $collectionHandler, Closure $callback = null, $prefix = '')
    {
        $this->collection = $collection;

        $this->collectionHandler = $collectionHandler;

        $this->prefix = $prefix;

        if (! is_null($callback)) {
            $callback($this);
        }
    }

    /**
     * Execute the blueprint against the database.
     *
     * @param  \Illuminate\Database\Connection  $connection
     * @param  \Illuminate\Database\Schema\Grammars\Grammar  $grammar
     * @return void
     */
    public function build(Connection $connection, IlluminateGrammar $grammar)
    {
        $this->connection = $connection;
        $this->grammar = $connection->getSchemaGrammar();


        foreach ($this->commands as $command) {
            if ($command->handler == 'aql') {
                $command = $this->compileAqlCommand($command);
            }

            $this->executeCommand($command);
        }
    }

    /**
     * Generate the compilation method name and call it if method exists in the Grammar object.
     *
     * @param $command
     * @return mixed
     */
    public function compileAqlCommand($command)
    {
        $compileMethod = 'compile'.ucfirst($command->name);
        if (method_exists($this->grammar, $compileMethod)) {
            return $this->grammar->$compileMethod($this->collection, $command);
        }
    }

    /**
     * Generate the execution method name and call it if the method exists.
     *
     * @param $command
     */
    public function executeCommand($command)
    {
        $executeNamedMethod = 'execute'.ucfirst($command->name).'Command';
        $executeHandlerMethod = 'execute'.ucfirst($command->handler).'Command';
        if (method_exists($this, $executeNamedMethod)) {
            $this->$executeNamedMethod($command);
        } elseif (method_exists($this, $executeHandlerMethod)) {
            $this->$executeHandlerMethod($command);
        }
    }

    /**
     * Execute an AQL statement.
     *
     * @param $command
     */
    public function executeAqlCommand($command)
    {
        $this->connection->statement($command->aqb->query, $command->aqb->binds);
    }

    public function executeCollectionCommand($command)
    {
        if ($this->connection->pretending()) {
            $this->connection->logQuery('/* '.$command->explanation." */\n", []);

            return;
        }

        if (method_exists($this->collectionHandler, $command->method)) {
            $this->collectionHandler->{$command->method}($command->parameters);
        }
    }

    /**
     * Drop the index by first getting all the indexes on the collection; then selecting the matching one
     * by type and attributes.
     * @param $command
     * @throws \ArangoDBClient\Exception
     */
    public function executeDropIndexCommand($command)
    {
        if ($this->connection->pretending()) {
            $this->connection->logQuery('/* '.$command->explanation." */\n", []);

            return;
        }
        $attributes = $command->attributes;
        if (is_string($attributes)) {
            $attributes = [$attributes];
        }
        $indexId = null;

        $indexData = $this->collectionHandler->getIndexes($this->collection);
        foreach ($indexData['indexes'] as $key => $index) {
            if (
                $index['type'] === $command->type
                && empty(array_diff($index['fields'], $attributes))
                && empty(array_diff($attributes, $index['fields']))
            ) {
                $this->collectionHandler->dropIndex($index['id']);
            }
        }
    }

    /**
     * @param $command
     * @throws \ArangoDBClient\Exception
     */
    public function executeIndexCommand($command)
    {
        if ($this->connection->pretending()) {
            $this->connection->logQuery('/* '.$command->explanation." */\n", []);

            return;
        }

        $this->collectionHandler->index($this->collection, $command->type, $command->attributes, $command->unique, $command->indexOptions);
        /** @scrutinizer ignore-deprecated */ $this->collectionHandler->index($this->collection, $command->type, $command->attributes, $command->unique, $command->indexOptions);
    }

    /**
     * Solely provides feedback to the developer in pretend mode.
     *
     * @param $command
     * @return null
     */
    public function executeIgnoreCommand($command)
    {
        if ($this->connection->pretending()) {
            $this->connection->logQuery('/* '.$command->explanation." */\n", []);

            return;
        }
    }

    /**
     * Determine if the blueprint has a create command.
     *
     * @return bool
     */
    protected function creating()
    {
        return collect($this->commands)->contains(function ($command) {
            return $command->name === 'create';
        });
    }

    /**
     * Indicate that the collection needs to be created.
     *
     * @param array $options
     * @return Fluent
     */
    public function create($options = [])
    {
        $parameters['options'] = $options;

        $parameters['explanation'] = "Create '{$this->collection}' collection.";
        $parameters['handler'] = 'collection';

        return $this->addCommand('create', $parameters);
    }

    public function executeCreateCommand($command)
    {
        if ($this->connection->pretending()) {
            $this->connection->logQuery('/* '.$command->explanation." */\n", []);

            return;
        }
        $options = $command->options;
        if ($this->temporary === true) {
            $options['isVolatile'] = true;
        }
        if ($this->autoIncrement === true) {
            $options['keyOptions']['autoincrement'] = true;
        }

        $collections = $this->collectionHandler->getAllCollections(['excludeSystem' => true]);
        if (! isset($collections[$this->collection])) {
            $this->collectionHandler->create($this->collection, $options);
        }
    }

    /**
     * Indicate that the collection should be dropped.
     *
     * @return Fluent
     */
    public function drop()
    {
        $parameters['explanation'] = "Drop the '{$this->collection}' collection.";

        $parameters['handler'] = 'collection';

        return $this->addCommand('drop', $parameters);
    }

    /**
     * Indicate that the collection should be dropped if it exists.
     *
     * @return Fluent
     */
    public function dropIfExists()
    {
        $parameters['explanation'] = "Drop the '{$this->collection}' collection.";

        $parameters['handler'] = 'collection';

        return $this->addCommand('dropIfExists');
    }

    /**
     * Indicate that the given attribute(s) should be dropped.
     *
     * @param  array|mixed  $attributes
     * @return Fluent
     */
    public function dropColumn($attributes)
    {
        $attributes = is_array($attributes) ? $attributes : func_get_args();

        $parameters['handler'] = 'aql';

        $parameters['attributes'] = $attributes;
        $parameters['explanation'] = 'Drop the following attribute(s): '.implode(',', $attributes).'.';

        return $this->addCommand('dropAttribute', compact('parameters'));
    }

    /**
     * Check if any document within the collection has the attribute.
     *
     * @param string|array $attribute
     * @return Fluent
     */
    public function hasAttribute($attribute)
    {
        $parameters['handler'] = 'aql';

        $parameters['explanation'] = "Checking if any document within the collection has the '".implode(', ', (array) $attribute)."' attribute(s).";
        $parameters['attribute'] = $attribute;

        return $this->addCommand('hasAttribute', $parameters);
    }

    /**
     * Indicate that the given attributes should be renamed.
     *
     * @param  string  $from
     * @param  string  $to
     * @return Fluent
     */
    public function renameColumn($from, $to)
    {
        $parameters['handler'] = 'aql';

        $parameters['explanation'] = "Rename the attribute '$from' to '$to'.";
        $parameters['from'] = $from;
        $parameters['to'] = $to;

        return $this->addCommand('renameAttribute', $parameters);
    }

    /**
     * Indicate that the given index should be dropped.
     *
     * @param  string|array  $attributes
     * @param  string  $type
     * @return Fluent
     */
    public function dropIndex($attributes, $type)
    {
        $parameters['attributes'] = $attributes;

        $parameters['type'] = $type;
        $parameters['explanation'] = "Drop the '".$type."' index on [".implode(', ', (array) $attributes).'].';
        $parameters['handler'] = 'collection';

        return $this->addCommand('dropIndex', $parameters);
    }

    /**
     * Rename the collection to a given name.
     *
     * @param  string  $to
     * @return Fluent
     */
    public function rename($to)
    {
        return $this->addCommand('rename', compact('to'));
    }

    /**
     * Specify an index for the table.
     *
     * @param  string|array  $columns
     * @param  string  $name
     * @param  string|null  $algorithm
     * @return Fluent
     */
    public function index($columns = null, $name = null, $algorithm = null)
    {
        $type = $this->mapIndexType($algorithm);

        return $this->indexCommand($type, $columns);
    }

    /**
     * Create a hash index for fast exact matching.
     * Hash ! has ;).
     *
     * @param null $attributes

     * @param array $indexOptions
     * @return Fluent
     */
    public function hashIndex($attributes = null, $indexOptions = [])
    {
        return $this->indexCommand('hash', $attributes, $indexOptions);
    }

    /**
     * @param null|string $attribute
     * @param array $indexOptions
     * @return Fluent
     */
    public function fulltextIndex($attribute = null, $indexOptions = [])
    {
        return $this->indexCommand('fulltext', $attribute, $indexOptions);
    }

    /**
     *  Specify a spatial index for the collection.
     *
     * @param $attributes
     * @param array $indexOptions
     * @return Fluent
     */
    public function geoIndex($attributes, $indexOptions = [])
    {
        return $this->indexCommand('geo', $attributes, $indexOptions);
    }

    /**
     * Specify a spatial index for the table.
     * Alias for geoIndex().
     * @param  string|array  $columns
     * @param  string  $name
     * @return Fluent
     */
    public function spatialIndex($columns, $name = null)
    {
        return $this->geoIndex($columns);
    }

    public function skiplistIndex($attributes, $indexOptions = [])
    {
        return $this->indexCommand('skiplist', $attributes, $indexOptions);
    }

    /**
     * Create a TTL index for the table.
     * 
     * @param $attributes
     * @param array $indexOptions
     * @return Illuminate\Support\Fluent

     */
    public function ttlIndex($attributes, $indexOptions = [])
    {
        return $this->indexCommand('ttl', $attributes, $indexOptions);

    }

    /**
     * Specify a unique index for the table.
     *
     * @param  string|array  $columns
     * @param  string  $name
     * @param  string|null  $algorithm
     * @return Fluent
     */
    public function unique($columns = null, $name = null, $algorithm = null)
    {
        $type = $this->mapIndexType($algorithm);

        $indexOptions['unique'] = true;


        return $this->indexCommand($type, $columns, $indexOptions);
    }

    /**
     * Add a new index command to the blueprint.
     *
     * @param  string  $type
     * @param  string|array  $attributes
     * @param  array $indexOptions
     * @return Fluent
     */
    protected function indexCommand($type = '', $attributes = [], $indexOptions = [])
    {
        if ($type == '') {
            $type = 'skiplist';
        }

        if ($attributes === null) {

            $attributes = end($this->attributes);
        }

        if (is_string($attributes)) {
            $attributes = [$attributes];
        }

        $unique = false;
        if (isset($indexOptions['unique'])) {
            $unique = $indexOptions['unique'];
            unset($indexOptions['unique']);
        }

        return $this->addCommand('index', compact('type', 'attributes', 'unique', 'indexOptions'));
    }

    /**
     * Add a new command to the blueprint.
     *
     * @param  string  $name
     * @param  array  $parameters
     * @return Fluent
     */
    protected function addCommand($name, array $parameters = [])
    {
        $this->commands[] = $command = $this->createCommand($name, $parameters);

        return $command;
    }

    /**
     * Create a new Fluent command.
     *
     * @param  string  $name
     * @param  array  $parameters
     * @return Fluent
     */
    protected function createCommand($name, array $parameters = [])
    {
        return new Fluent(array_merge(compact('name'), $parameters));
    }

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

    /**
     * Alias for getCollection.
     *
     * @return string
     */
    public function getTable()
    {
        return $this->getCollection();
    }

    /**
     * Get the commands on the blueprint.
     *
     * @return Fluent[]
     */
    public function getCommands()
    {
        return $this->commands;
    }

    /**
     * Silently catch unsupported schema methods. Store attributes for backwards compatible fluent index creation.
     *
     * @param $method
     * @param $args
     * @return Blueprint
     */
    public function __call($method, $args)
    {
        $columnMethods = [
            'bigIncrements', 'bigInteger', 'binary', 'boolean', 'char', 'date', 'dateTime', 'dateTimeTz', 'decimal',
            'double', 'enum', 'float', 'geometry', 'geometryCollection', 'increments', 'integer', 'ipAddress', 'json',
            'jsonb', 'lineString', 'longText', 'macAddress', 'mediumIncrements', 'mediumInteger', 'mediumText',
            'morphs', 'uuidMorphs', 'multiLineString', 'multiPoint', 'multiPolygon',
            'nullableMorphs', 'nullableUuidMorphs', 'nullableTimestamps', 'point', 'polygon', 'rememberToken',
            'set', 'smallIncrements', 'smallInteger', 'softDeletes', 'softDeletesTz', 'string',
            'text', 'time', 'timeTz', 'timestamp', 'timestampTz', 'timestamps', 'tinyIncrements', 'tinyInteger',
            'unsignedBigInteger', 'unsignedDecimal', 'unsignedInteger', 'unsignedMediumInteger', 'unsignedSmallInteger',
            'unsignedTinyInteger', 'uuid', 'year',
        ];

        if (in_array($method, $columnMethods)) {
            if (isset($args)) {
                $this->attributes[] = $args;
            }
        }

        $autoIncrementMethods = ['increments', 'autoIncrement'];
        if (in_array($method, $autoIncrementMethods)) {
            $this->autoIncrement = true;
        }

        $info['method'] = $method;

        $info['explanation'] = "'$method' is ignored; Aranguent Schema Blueprint doesn't support it.";
        $this->addCommand('ignore', $info);

        return $this;
    }

    public function mapIndexType($algorithm)
    {
        $typeConversion = [
            'HASH' => 'hash',
            'BTREE' => 'skiplist',
            'RTREE' => 'geo',
            'TTL' => 'ttl',
        ];
        $algorithm = strtoupper($algorithm);

        return (isset($typeConversion[$algorithm])) ? $typeConversion[$algorithm] : 'skiplist';
    }
}

LaravelFreelancerNL / laravel-arangodb

Pull Request — master (#6)

Blueprint::executeAqlCommand() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
