TBolier\RethinkConnect\Test\Connection\DatabaseTest

Complexity

Total Complexity

7

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	10	1
A	testTableList()	0	9	1
A	testCreateTable()	0	9	1
A	testDropTable()	0	9	1
A	assertObStatus()	0	22	3

<?php
declare(strict_types=1);

namespace TBolier\RethinkConnect\Test\Connection;

use ArrayObject;
use TBolier\RethinkQL\Connection\ConnectionInterface;
use TBolier\RethinkQL\Rethink;
use TBolier\RethinkQL\RethinkInterface;
use TBolier\RethinkQL\Test\BaseTestCase;

class DatabaseTest extends BaseTestCase
{
    /**
     * @var RethinkInterface
     */
    private $r;

    public function setUp()
    {
        parent::setUp();

        /** @var ConnectionInterface $connection */
        $connection = $this->createConnection('phpunit_default')->connect();
        $connection->connect()->use('test');

        $this->r = new Rethink($connection);
    }

    /**
     * @throws \Exception
     */
    public function testTableList()
    {
        $res = $this->r
            ->db()
            ->tableList()
            ->run();

        $this->assertInternalType('array', $res[0]);
    }

    /**
     * @throws \Exception
     */
    public function testCreateTable()
    {
        $res = $this->r
            ->db()
            ->tableCreate('en')
            ->run();

        $this->assertObStatus(['tables_created' => 1], $res[0]);
    }

    /**
     * @throws \Exception
     */
    public function testDropTable()
    {
        $res = $this->r
            ->db()
            ->tableDrop('en')
            ->run();

        $this->assertObStatus(['tables_dropped' => 1], $res[0]);
    }

    /**
     * @param $status
     * @param $data
     * @throws \Exception
     */
    protected function assertObStatus($status, $data)
    {
        $res = [];
        $statuses = [
            'tables_created',
            'tables_dropped',
            'errors',
        ];
        $data = new ArrayObject($data);

        foreach ($statuses as $s) {
            $status[$s] = $status[$s] ?? 0;
        }

        $data->setFlags($data::ARRAY_AS_PROPS);

        foreach ($statuses as $s) {
            $res[$s] = $data[$s] ?? 0;
        }

        $this->assertEquals($status, $res);
    }
}