MySQLReplication\Event\QueryEvent::makeQueryDTO()

Complexity

Conditions	1
Paths	1

Size

Total Lines	18
Code Lines	15

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	12
CRAP Score	1

Importance

Changes	6
Bugs	2	Features	0

<?php
    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
        );
}