for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?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
);
}
krowinski /
php-mysql-replication
