Moss\Storage\Query\DeleteQuery

Complexity

Total Complexity

5

Size/Duplication

Total Lines	75
Duplicated Lines	9.33 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes	17
Bugs	2	Features	2

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	7	7	1
A	setQuery()	0	5	1
A	execute()	0	15	2
A	reset()	0	11	1

<?php

/*
* This file is part of the moss-storage package
*
* (c) Michal Wachowski <wachowski.michal@gmail.com>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/

namespace Moss\Storage\Query;

use Doctrine\DBAL\Connection;
use Moss\Storage\GetTypeTrait;
use Moss\Storage\Model\ModelInterface;
use Moss\Storage\Query\Accessor\AccessorInterface;
use Moss\Storage\Query\EventDispatcher\EventDispatcherInterface;
use Moss\Storage\Query\Relation\RelationFactoryInterface;

/**
 * Query used to delete data from table
 *
 * @author  Michal Wachowski <wachowski.michal@gmail.com>
 * @package Moss\Storage
 */
class DeleteQuery extends AbstractEntityQuery implements DeleteQueryInterface
{
    const EVENT_BEFORE = 'delete.before';
    const EVENT_AFTER = 'delete.after';

    use GetTypeTrait;

    protected $instance;

    /**
     * Constructor
     *
     * @param Connection               $connection
     * @param mixed                    $entity
     * @param ModelInterface           $model
     * @param RelationFactoryInterface $factory
     * @param AccessorInterface        $accessor
     * @param EventDispatcherInterface $dispatcher
     */
    public function __construct(Connection $connection, $entity, ModelInterface $model, RelationFactoryInterface $factory, AccessorInterface $accessor, EventDispatcherInterface $dispatcher)

This method seems to be duplicated in your project.

    {
        parent::__construct($connection, $entity, $model, $factory, $accessor, $dispatcher);

        $this->setQuery();
        $this->setPrimaryKeyConditions();
    }

    /**
     * Sets query instance with delete operation and table
     */
    protected function setQuery()
    {
        $this->builder = $this->connection->createQueryBuilder();
        $this->builder->delete($this->connection->quoteIdentifier($this->model->table()));
    }

    /**
     * Executes query
     * After execution query is reset
     *
     * @return mixed
     */
    public function execute()
    {
        foreach ($this->relations as $relation) {
            $relation->delete($this->instance);
        }

        $this->dispatcher->fire(self::EVENT_BEFORE, $this->instance);

        $this->builder->execute();
        $this->accessor->identifyEntity($this->model, $this->instance, null);

        $this->dispatcher->fire(self::EVENT_AFTER, $this->instance);

        return $this->instance;
    }

    /**
     * Resets adapter
     *
     * @return $this
     */
    public function reset()
    {
        $this->builder->resetQueryParts();
        $this->relations = [];
        $this->resetBinds();

        $this->setQuery();
        $this->setPrimaryKeyConditions();

        return $this;
    }
}