MySQLReplication\Event\QueryEvent

Complexity

Total Complexity

1

Size/Duplication

Total Lines	26
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	3
Bugs	2	Features	0

1 Method

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

<?php

namespace MySQLReplication\Event;

use MySQLReplication\BinaryDataReader\BinaryDataReaderException;
use MySQLReplication\BinLog\BinLogServerInfo;
use MySQLReplication\Event\DTO\QueryDTO;

/**
 * Class QueryEvent
 * @package MySQLReplication\Event
 * @see https://dev.mysql.com/doc/internals/en/query-event.html
 */
class QueryEvent extends EventCommon
{
    /**
     * @return QueryDTO
     * @throws BinaryDataReaderException
     */
    public function makeQueryDTO()
    {
        $this->binaryDataReader->advance(4);
        $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
        );
    }
}