MySQLReplication\Event\QueryEvent

Complexity

Total Complexity

1

Size/Duplication

Total Lines	20
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	6
Bugs	2	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	makeQueryDTO()	0	18	1

<?php
declare(strict_types=1);

namespace MySQLReplication\Event;

use MySQLReplication\Event\DTO\QueryDTO;

/**
 * @see https://dev.mysql.com/doc/internals/en/query-event.html
 */
class QueryEvent extends EventCommon
{
    public function makeQueryDTO(): QueryDTO
    {
        $threadId = $this->binaryDataReader->readUInt32();
        $executionTime = $this->binaryDataReader->readUInt32();
        $schemaLength = $this->binaryDataReader->readUInt8();
        $this->binaryDataReader->advance(2);
        $statusVarsLength = $this->binaryDataReader->readUInt16();
        $this->binaryDataReader->advance($statusVarsLength);
        $schema = $this->binaryDataReader->read($schemaLength);
        $this->binaryDataReader->advance(1);
        $query = $this->binaryDataReader->read($this->eventInfo->getSizeNoHeader() - 13 - $statusVarsLength - $schemaLength - 1);

        return new QueryDTO(
            $this->eventInfo,
            $schema,
            $executionTime,
            $query,
            $threadId
        );
    }
}