diff --git a/src/MySQLReplication/BinLog/BinLogSocketConnect.php b/src/MySQLReplication/BinLog/BinLogSocketConnect.php index 5524efc..ca8fafe 100644 --- a/src/MySQLReplication/BinLog/BinLogSocketConnect.php +++ b/src/MySQLReplication/BinLog/BinLogSocketConnect.php @@ -300,7 +300,6 @@ private function setBinLogDump(): void $data .= $binFileName; $this->socket->writeToSocket($data); - $this->getResponse(); $binLogCurrent->setBinLogPosition($binFilePos); $binLogCurrent->setBinFileName($binFileName); diff --git a/tests/Integration/BaseTest.php b/tests/Integration/BaseTest.php index 9d00dcd..61f5a5b 100644 --- a/tests/Integration/BaseTest.php +++ b/tests/Integration/BaseTest.php @@ -12,6 +12,7 @@ use MySQLReplication\Event\DTO\EventDTO; use MySQLReplication\Event\DTO\FormatDescriptionEventDTO; use MySQLReplication\Event\DTO\QueryDTO; +use MySQLReplication\Event\DTO\RotateDTO; use MySQLReplication\Event\DTO\TableMapDTO; use MySQLReplication\MySQLReplicationFactory; use PHPUnit\Framework\TestCase; @@ -61,6 +62,7 @@ protected function setUp(): void $this->connect(); + self::assertInstanceOf(RotateDTO::class, $this->getEvent()); self::assertInstanceOf(FormatDescriptionEventDTO::class, $this->getEvent()); self::assertInstanceOf(QueryDTO::class, $this->getEvent()); self::assertInstanceOf(QueryDTO::class, $this->getEvent()); diff --git a/tests/Integration/BasicTest.php b/tests/Integration/BasicTest.php index 58edd19..e1dc3b1 100644 --- a/tests/Integration/BasicTest.php +++ b/tests/Integration/BasicTest.php @@ -401,6 +401,7 @@ private function connectWithProvidedEventDispatcher(EventDispatcherInterface $ev $this->connection->executeStatement('USE ' . $this->database); $this->connection->executeStatement('SET SESSION sql_mode = \'\';'); + self::assertInstanceOf(RotateDTO::class, $this->getEvent()); self::assertInstanceOf(FormatDescriptionEventDTO::class, $this->getEvent()); self::assertInstanceOf(QueryDTO::class, $this->getEvent()); self::assertInstanceOf(QueryDTO::class, $this->getEvent());