port and version check

Author: krowinski

docker-compose.yml

@@ -2,7 +2,7 @@ services:
   replication-test-mysql-percona:
     container_name: replication-test-mysql-percona
     hostname: replication-test-mysql-percona
-    image: mysql:8.2
+    image: mysql:8.0
     platform: linux/amd64
     command: [
       '--character-set-server=utf8mb4',
@@ -18,5 +18,5 @@ services:
       - MYSQL_ROOT_PASSWORD=root
       - MYSQL_DATABASE=mysqlreplication_test
     ports:
-      - "3322:3306/tcp"
+      - "3306:3306/tcp"
     restart: unless-stopped

example/benchmark.php

@@ -25,7 +25,7 @@ class benchmark
     private const DB_USER = 'root';
     private const DB_PASS = 'root';
     private const DB_HOST = '127.0.0.1';
-    private const DB_PORT = 3322;
+    private const DB_PORT = 3306;
 
     private MySQLReplicationFactory $binLogStream;
 

example/dump_events.php

@@ -24,7 +24,7 @@
         ->withUser('root')
         ->withHost('0.0.0.0')
         ->withPassword('root')
-        ->withPort(3322)
+        ->withPort(3306)
         ->withHeartbeatPeriod(60)
         ->withEventsIgnore([ConstEventType::HEARTBEAT_LOG_EVENT->value])
         ->build(),

tests/Integration/BaseCase.php

@@ -40,12 +40,12 @@ protected function setUp(): void
             ->withUser('root')
             ->withHost('0.0.0.0')
             ->withPassword('root')
-            ->withPort(3322)
+            ->withPort(3306)
             ->withEventsIgnore([ConstEventType::GTID_LOG_EVENT->value]);
 
         $this->connect();
 
-        if ($this->checkForVersion(8.4) && $this->mySQLReplicationFactory?->getServerInfo()->isGeneric()) {
+        if ($this->mySQLReplicationFactory?->getServerInfo()->versionRevision >= 8 && $this->mySQLReplicationFactory?->getServerInfo()->isGeneric()) {
             self::assertInstanceOf(RotateDTO::class, $this->getEvent());
         }
         self::assertInstanceOf(FormatDescriptionEventDTO::class, $this->getEvent());

tests/Integration/BasicTest.php

@@ -366,7 +366,7 @@ private function connectWithProvidedEventDispatcher(EventDispatcherInterface $ev
         $this->connection->executeStatement('USE ' . $this->database);
         $this->connection->executeStatement('SET SESSION sql_mode = \'\';');
 
-        if ($this->checkForVersion(8.4) && $this->mySQLReplicationFactory->getServerInfo()->isGeneric()) {
+        if ($this->mySQLReplicationFactory->getServerInfo()->versionRevision >= 8 && $this->mySQLReplicationFactory->getServerInfo()->isGeneric()) {
             self::assertInstanceOf(RotateDTO::class, $this->getEvent());
         }