Tarantool\Client\Tests\Integration\Requests\ExecuteTest

Complexity

Total Complexity

5

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	4
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	testExecuteUpdate()	0	10	2
A	testExecuteQuery()	0	5	1
A	provideExecuteQueryData()	0	7	1
A	provideExecuteUpdateData()	0	8	1

<?php

/**
 * This file is part of the Tarantool Client package.
 *
 * (c) Eugene Leonovich <gen.work@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Tarantool\Client\Tests\Integration\Requests;

use Tarantool\Client\Tests\Integration\TestCase;

/**
 * @requires Tarantool 2
 */
final class ExecuteTest extends TestCase
{
    /**
     * @dataProvider provideExecuteUpdateData
     */
    public function testExecuteUpdate(string $sql, array $params, $expectedCount, ?array $expectedAutoincrementIds) : void
    {
        $result = $this->client->executeUpdate($sql, ...$params);

        is_array($expectedCount)
            ? self::assertContains($result->count(), $expectedCount)
            : self::assertSame($expectedCount, $result->count())
        ;

        self::assertSame($expectedAutoincrementIds, $result->getAutoincrementIds());
    }

    public function provideExecuteUpdateData() : iterable
    {
        return [
            ['DROP TABLE IF EXISTS table_exec', [], [0, 1], null],
            ['CREATE TABLE table_exec (column1 INTEGER PRIMARY KEY AUTOINCREMENT, column2 VARCHAR(100))', [], 1, null],
            ['INSERT INTO table_exec VALUES (1, :val1), (2, :val2)', [[':val1' => 'A'], [':val2' => 'B']], 2, null],
            ['UPDATE table_exec SET column2 = ? WHERE column1 = 2', ['BB'], 1, null],
            ["INSERT INTO table_exec VALUES (100, 'a'), (null, 'b'), (120, 'c'), (null, 'd')", [], 4, [101, 121]],
        ];
    }

    /**
     * @dataProvider provideExecuteQueryData
     *
     * @depends testExecuteUpdate
     */
    public function testExecuteQuery(string $sql, array $params, array $expectedData) : void
    {
        $result = $this->client->executeQuery($sql, ...$params);

        self::assertSame($expectedData, $result->getData());
    }

    public function provideExecuteQueryData() : iterable
    {
        return [
            ['SELECT * FROM table_exec WHERE column1 = 1', [], [[1, 'A']]],
            ['SELECT column2 FROM table_exec WHERE column1 = 1', [], [['A']]],
            ['SELECT * FROM table_exec WHERE column1 = 2', [], [[2, 'BB']]],
            ['SELECT * FROM table_exec WHERE column1 = 3', [], []],
        ];
    }
}