Bdf\Prime\Query\CustomQueriesBench

Complexity

Total Complexity

21

Size/Duplication

Total Lines	223
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	bench_search_keyValue()	0	6	1
A	bench_builder_get()	0	3	1
A	bench_delete_keyValue()	0	4	1
A	setUp()	0	12	1
A	bench_countKeyValue()	0	3	1
A	bench_update_keyValue()	0	4	1
A	bench_update_builder()	0	4	1
A	bench_insert_bulk()	0	19	2
A	bench_insert_builder()	0	15	2
A	bench_update_keyValue_cached()	0	10	2
A	bench_delete_builder()	0	4	1
A	bench_insert_transaction()	0	19	2
A	bench_count()	0	3	1
A	bench_delete_keyValue_cached()	0	10	2
A	bench_findById()	0	3	1
A	bench_search_builder()	0	6	1

<?php

namespace Bdf\Prime\Query;

require_once __DIR__ . '/../_files/BenchData.php';

use Bdf\Prime\Bench\BenchData;
use Bdf\Prime\Bench\User;
use Bdf\Prime\Cache\ArrayCache;
use Bdf\Prime\Connection\ConnectionConfig;

The type Bdf\Prime\Connection\ConnectionConfig was not found. Maybe you did not declare it correctly or list all dependencies?

use Bdf\Prime\ConnectionManager;
use Bdf\Prime\Locatorizable;
use Bdf\Prime\Query\Custom\BulkInsert\BulkInsertQuery;
use Bdf\Prime\Repository\EntityRepository;
use Bdf\Prime\ServiceLocator;
use Bdf\Prime\Types\ArrayType;
use BenchCaseAdapter;

/**
 * Bench custom queries
 *
 * @Revs(10)
 * @Warmup(1)
 */
class CustomQueriesBench extends BenchCaseAdapter
{
    /**
     * @var ServiceLocator
     */
    protected $prime;

    /**
     * @var BenchData
     */
    protected $data;

    /**
     * @var ArrayCache
     */
    protected $cache;

    /**
     * @var EntityRepository
     */
    protected $repository;


    public function setUp()
    {
        $this->cache = new ArrayCache();
        $this->prime = new ServiceLocator();
        $this->prime->connections()->declareConnection('test', BENCH_CONNECTION);
        $this->prime->connection('test')->getConfiguration()->getTypes()->register(ArrayType::class, 'array');

The method getConfiguration() does not exist on Bdf\Prime\Connection\ConnectionInterface. Since it exists in all sub-types, consider adding an abstract or default implementation to Bdf\Prime\Connection\ConnectionInterface.

        Locatorizable::configure($this->prime);

$this->prime of type Bdf\Prime\ServiceLocator is incompatible with the type Closure expected by parameter $locator of Bdf\Prime\Locatorizable::configure().

        $this->data = new BenchData($this->prime);
        $this->data->addBulkUsers();

        $this->repository = $this->prime->repository(User::class);
    }

    /**
     * @Groups({"count"})
     */
    public function bench_count()
    {
        return $this->repository->count(['id' => '23000123']) > 0;
    }

    /**
     * @Groups({"count"})
     */
    public function bench_countKeyValue()
    {
        return $this->repository->queries()->countKeyValue(['id' => '23000123']) > 0;
    }

    /**
     * @Groups({"findById"})
     */
    public function bench_findById()
    {
        return $this->repository->queries()->findById('23000123');
    }

    /**
     * @Groups({"findById"})
     */
    public function bench_builder_get()
    {
        return $this->repository->builder()->get('23000123');

The method get() does not exist on Bdf\Prime\Query\QueryInterface. It seems like you code against a sub-type of said class. However, the method does not exist in Bdf\Prime\Query\SqlQueryInterface. Are you sure you never get one of those?

    }

    /**
     * @Groups({"search"})
     */
    public function bench_search_keyValue()
    {
        return $this->repository->keyValue([

The method keyValue() does not exist on Bdf\Prime\Repository\EntityRepository. Since you implemented __call, consider adding a @method annotation.

            'name'        => 'user Common 123',
            'customer.id' => '330000',
        ])->first();
    }

    /**
     * @Groups({"search"})
     */
    public function bench_search_builder()
    {
        return $this->repository->builder()->where([
            'name'        => 'user Common 123',
            'customer.id' => '330000',
        ])->first();
    }

    /**
     * @Groups({"delete"})
     */
    public function bench_delete_keyValue()
    {
        $id = '23000'.str_pad(rand(1, 500), 3, '0', STR_PAD_LEFT);
        return $this->repository->keyValue('id', $id)->delete();
    }

    /**
     * @Groups({"delete"})
     */
    public function bench_delete_keyValue_cached()
    {
        static $query;

        if (!$query) {
            $query = $this->repository->keyValue();
        }

        $id = '23000'.str_pad(rand(1, 500), 3, '0', STR_PAD_LEFT);
        return $query->where('id', $id)->delete();
    }

    /**
     * @Groups({"delete"})
     */
    public function bench_delete_builder()
    {
        $id = '23000'.str_pad(rand(1, 500), 3, '0', STR_PAD_LEFT);
        return $this->repository->builder()->where('id', $id)->delete();
    }

    /**
     * @Groups({"update"})
     */
    public function bench_update_builder()
    {
        $id = '23000'.str_pad(rand(1, 500), 3, '0', STR_PAD_LEFT);
        return $this->repository->builder()->where('id', $id)->update(['name' => 'Bob']);
    }

    /**
     * @Groups({"update"})
     */
    public function bench_update_keyValue()
    {
        $id = '23000'.str_pad(rand(1, 500), 3, '0', STR_PAD_LEFT);
        return $this->repository->keyValue('id', $id)->update(['name' => 'Bob']);
    }

    /**
     * @Groups({"update"})
     */
    public function bench_update_keyValue_cached()
    {
        static $query;

        if (!$query) {
            $query = $this->repository->keyValue();
        }

        $id = '23000'.str_pad(rand(1, 500), 3, '0', STR_PAD_LEFT);
        return $query->where('id', $id)->update(['name' => 'Bob']);
    }

    /**
     * @Groups({"insert"})
     */
    public function bench_insert_bulk()
    {
        /** @var BulkInsertQuery $insert */
        $insert = $this->repository->queries()->make(BulkInsertQuery::class);
        $insert->bulk();

        for ($i = 0; $i < 100; ++$i) {
            $insert->values([
                'id'          => 6000000 + $i,
                'name'        => 'bulk user '.$i,
                'roles'       => ['2'],
                'customer.id' => 1,
            ]);
        }

        $insert->execute();

        // Clear data set
        $this->repository->where('id', 'between', [6000000, 7000000])->delete();
    }

    /**
     * @Groups({"insert"})
     */
    public function bench_insert_transaction()
    {
        $this->repository->transaction(function () {
            /** @var BulkInsertQuery $insert */
            $insert = $this->repository->queries()->make(BulkInsertQuery::class);

            for ($i = 0; $i < 100; ++$i) {
                $insert->values([
                    'id'          => 6000000 + $i,
                    'name'        => 'bulk user '.$i,
                    'roles'       => ['2'],
                    'customer.id' => 1,
                ]);
                $insert->execute();
            }
        });

        // Clear data set
        $this->repository->where('id', 'between', [6000000, 7000000])->delete();
    }

    /**
     * @Groups({"insert"})
     */
    public function bench_insert_builder()
    {
        $this->repository->transaction(function () {
            for ($i = 0; $i < 100; ++$i) {
                $this->repository->builder()->insert([
                    'id'          => 6000000 + $i,
                    'name'        => 'bulk user '.$i,
                    'roles'       => ['2'],
                    'customer.id' => 1,
                ]);
            }
        });

        // Clear data set
        $this->repository->where('id', 'between', [6000000, 7000000])->delete();
    }
}