AbacaphiliacTest\Doctrine\PsrSqlParamsLoggerTest

Complexity

Total Complexity

7

Size/Duplication

Total Lines	163
Duplicated Lines	36.2 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	6	1
A	getRecordByIndex()	0	8	1
A	testLogsQuery()	0	26	1
A	testLogsDuration()	28	28	1
A	testSharedQueryId()	31	31	1
A	testQueryIdChanges()	0	39	1
A	testInvalidLogLevel()	0	4	1

<?php

namespace AbacaphiliacTest\Doctrine;

use Abacaphiliac\Doctrine\PsrSqlParamsLogger;
use PHPUnit\Framework\TestCase;
use Psr\Log\LogLevel;
use Psr\Log\NullLogger;
use Psr\Log\Test\TestLogger;

/**
 * @covers \Abacaphiliac\Doctrine\PsrSqlParamsLogger
 */
class PsrSqlParamsLoggerTest extends TestCase
{
    /** @var PsrSqlParamsLogger */
    private $sut;

    /** @var TestLogger */
    private $logger;

    /** @var string */
    private $sql = 'SELECT * FROM users WHERE id = :id';

    protected function setUp()
    {
        $this->logger = new TestLogger();

        $this->sut = new PsrSqlParamsLogger($this->logger);
    }

    private function getRecordByIndex(int $index): \stdClass
    {
        $record = $this->logger->records[$index];

        self::assertInternalType('array', $record);

        return (object) $record;
    }

    public function testLogsQuery()
    {
        self::assertCount(0, $this->logger->records);

        $this->sut->startQuery(
            $this->sql,
            [
                ':id' => 1234,
            ],
            [
                ':id' => \PDO::PARAM_INT,
            ]
        );

        self::assertCount(1, $this->logger->records);

        $log = $this->getRecordByIndex(0);

        self::assertInstanceOf(\stdClass::class, $log);
        self::assertSame(LogLevel::INFO, (string) $log->level);
        self::assertSame('Query started', (string) $log->message);
        self::assertNotEmpty($log->context['query_id']);
        self::assertSame($this->sql, $log->context['sql']);
        self::assertSame([':id' => 1234], $log->context['params']);
        self::assertSame([':id' => \PDO::PARAM_INT], $log->context['types']);
    }

    public function testLogsDuration()

This method seems to be duplicated in your project.

    {
        self::assertCount(0, $this->logger->records);

        $this->sut->startQuery(
            $this->sql,
            [
                ':id' => 1234,
            ],
            [
                ':id' => \PDO::PARAM_INT,
            ]
        );

        $this->sut->stopQuery();

        self::assertCount(2, $this->logger->records);

        $log = $this->getRecordByIndex(1);

        self::assertInstanceOf(\stdClass::class, $log);
        self::assertSame(LogLevel::INFO, (string) $log->level);
        self::assertSame('Query finished', (string) $log->message);
        self::assertNotEmpty($log->context['query_id']);
        self::assertInternalType('float', $log->context['start']);
        self::assertInternalType('float', $log->context['stop']);
        self::assertInternalType('float', $log->context['duration_s']);
    }

    public function testSharedQueryId()

This method seems to be duplicated in your project.

    {
        self::assertCount(0, $this->logger->records);

        $this->sut->startQuery(
            $this->sql,
            [
                ':id' => 1234,
            ],
            [
                ':id' => \PDO::PARAM_INT,
            ]
        );

        $this->sut->stopQuery();

        self::assertCount(2, $this->logger->records);

        $startLog = $this->getRecordByIndex(0);

        self::assertInstanceOf(\stdClass::class, $startLog);

        $queryId = $startLog->context['query_id'];
        self::assertNotEmpty($queryId);


        $stopLog = $this->getRecordByIndex(1);

        self::assertInstanceOf(\stdClass::class, $stopLog);
        self::assertSame($queryId, $stopLog->context['query_id']);
    }

    public function testQueryIdChanges()
    {
        self::assertCount(0, $this->logger->records);

        $this->sut->startQuery(
            $this->sql,
            [
                ':id' => 1234,
            ],
            [
                ':id' => \PDO::PARAM_INT,
            ]
        );

        $this->sut->startQuery(
            $this->sql,
            [
                ':id' => 2345,
            ],
            [
                ':id' => \PDO::PARAM_INT,
            ]
        );

        self::assertCount(2, $this->logger->records);

        $firstLog = $this->getRecordByIndex(0);

        self::assertInstanceOf(\stdClass::class, $firstLog);

        $queryId = $firstLog->context['query_id'];
        self::assertNotEmpty($queryId);

        $secondLog = $this->getRecordByIndex(1);

        self::assertInstanceOf(\stdClass::class, $secondLog);
        self::assertNotEmpty($secondLog->context['query_id']);
        self::assertNotEquals($queryId, $secondLog->context['query_id']);
    }

    /**
     * @expectedException \InvalidArgumentException
     */
    public function testInvalidLogLevel()
    {
        new PsrSqlParamsLogger(new NullLogger(), 'InvalidLevel');
    }
}