Percy\Store\SqlStore

Complexity

Total Complexity

11

Size/Duplication

Total Lines	134
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	1	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	create()	0	6	1
A	insertEntity()	0	8	1
A	read()	0	5	1
A	update()	0	6	1
A	updateEntity()	0	9	1
A	delete()	0	6	1
A	deleteEntity()	0	8	1
A	collectionIterator()	0	16	3

<?php

namespace Percy\Store;

use Aura\Filter\FilterFactory;
use Aura\SqlQuery\QueryFactory;
use Aura\Sql\ExtendedPdo;
use PDOException;
use Percy\Entity\Collection;
use Percy\Entity\EntityInterface;

class SqlStore extends AbstractStore
{
    /**
     * @var \Aura\Sql\ExtendedPdo
     */
    protected $dbal;

    /**
     * Construct.
     *
     * @param \Aura\Sql\ExtendedPdo      $dbal
     * @param \Aura\Filter\FilterFactory $filter
     */
    public function __construct(ExtendedPdo $dbal, FilterFactory $filter)
    {
        $this->dbal  = $dbal;
        $this->query = new QueryFactory('mysql');

The property query does not exist. Did you maybe forget to declare it?

        parent::__construct($filter);
    }

    /**
     * {@inheritdoc}
     */
    public function create(Collection $collection, array $scopes = [])
    {
        $this->validate($collection);
        $this->decorate($collection, StoreInterface::ON_CREATE);
        return $this->collectionIterator($collection, 'insertEntity');

$collection is of type object<Percy\Entity\Collection>, but the function expects a object<Percy\Store\EntityCollection>.

    }

    /**
     * Insert an entity to the database.
     *
     * @param \Percy\Entity\EntityInterface $entity
     *
     * @return void
     */
    protected function insertEntity(EntityInterface $entity)
    {
        $insert = $this->query->newInsert();
        $insert->into($entity->getDataSource());
        $insert->cols($entity->toArray(false));

false is of type boolean, but the function expects a array.

        $this->dbal->perform($insert->getStatement(), $insert->getBindValues());
    }

    /**
     * {@inheritdoc}
     */
    public function read(Collection $collection, array $scopes = [])
    {
        // mysql need do nothing with the data on a read request
        return true;
    }

    /**
     * {@inheritdoc}
     */
    public function update(Collection $collection, array $scopes = [])
    {
        $this->validate($collection);
        $this->decorate($collection, StoreInterface::ON_UPDATE);
        return $this->collectionIterator($collection, 'updateEntity');

$collection is of type object<Percy\Entity\Collection>, but the function expects a object<Percy\Store\EntityCollection>.

    }

    /**
     * Update an entity in the database.
     *
     * @param \Percy\Entity\EntityInterface $entity
     *
     * @return void
     */
    protected function updateEntity(EntityInterface $entity)
    {
        $update = $this->query->newUpdate();
        $update->table($entity->getDataSource());
        $update->cols($entity->toArray(false));

false is of type boolean, but the function expects a array.

        $update->where(sprintf('%s = ?', $entity->getPrimary()), $entity[$entity->getPrimary()]);

        $this->dbal->perform($update->getStatement(), $update->getBindValues());
    }

    /**
     * {@inheritdoc}
     */
    public function delete(Collection $collection, array $scopes = [])
    {
        $this->validate($collection);
        $this->decorate($collection, StoreInterface::ON_DELETE);
        return $this->collectionIterator($collection, 'deleteEntity');

$collection is of type object<Percy\Entity\Collection>, but the function expects a object<Percy\Store\EntityCollection>.

    }

    /**
     * Delete an entity from the database. Be aware, this handles hard deletes.
     * To handle soft deletes, extend this class and overload this method.
     *
     * @param \Percy\Entity\EntityInterface $entity
     *
     * @return void
     */
    protected function deleteEntity(EntityInterface $entity)
    {
        $delete = $this->query->newDelete();
        $delete->from($entity->getDataSource());
        $delete->where(sprintf('%s = ?', $entity->getPrimary()), $entity[$entity->getPrimary()]);

        $this->dbal->perform($delete->getStatement(), $delete->getBindValues());
    }

    /**
     * Iterate a collection with the correct callback.
     *
     * @param \Percy\Entity\Collection $collection
     * @param string                   $callable
     *
     * @return boolean
     */
    protected function collectionIterator(EntityCollection $collection, $callable)
    {
        $this->dbal->beginEntity();

The method beginEntity() does not seem to exist on object<Aura\Sql\ExtendedPdo>.

        try {
            foreach ($collection->getIterator() as $entity) {
                call_user_func_array([$this, $callable], [$entity]);
            }
        } catch (PDOException $e) {
            $this->dbal->rollBack();
            return false;
        }

        $this->dbal->commit();
        return true;
    }
}