compatibility

Author: krowinski

src/MySQLReplication/BinLog/BinLogConnect.php

@@ -112,6 +112,7 @@ public function connectToStream()
     private function serverInfo()
     {
         BinLogServerInfo::parsePackage($this->getPacket(false));
+        BinLogServerInfo::parseVersion($this->mySQLRepository->getVersion());
     }
 
     /**

src/MySQLReplication/BinLog/BinLogServerInfo.php

@@ -3,11 +3,15 @@
 namespace MySQLReplication\BinLog;
 
 /**
+ * todo ugly class, for refactoring
  * Class BinLogServerInfo
  * @package MySQLReplication\BinLog
  */
 class BinLogServerInfo
 {
+    const MYSQL_VERSION_MARIADB = 'MariaDB';
+    const MYSQL_VERSION_PERCONA = 'Percona';
+    const MYSQL_VERSION_GENERIC = 'MySQL';
     /**
      * @var array
      */
@@ -91,6 +95,7 @@ public static function parsePackage($pack)
         {
             self::$serverInfo['auth_plugin_name'] .= $pack[$j];
         }
+        self::$serverInfo['version_name'] = self::MYSQL_VERSION_GENERIC;
     }
 
     /**
@@ -100,4 +105,31 @@ public static function getSalt()
     {
         return self::$serverInfo['salt'];
     }
+
+    /**
+     * @see http://stackoverflow.com/questions/37317869/determine-if-mysql-or-percona-or-mariadb
+     * @param string $version
+     */
+    public static function parseVersion($version)
+    {
+        if ('' !== $version)
+        {
+            if (false !== strpos($version, self::MYSQL_VERSION_MARIADB))
+            {
+                self::$serverInfo['version_name'] = self::MYSQL_VERSION_MARIADB;
+            }
+            else if (false !== strpos($version, self::MYSQL_VERSION_PERCONA))
+            {
+                self::$serverInfo['version_name'] = self::MYSQL_VERSION_PERCONA;
+            }
+        }
+    }
+
+    /**
+     * @return string
+     */
+    public static function getVersion()
+    {
+        return self::$serverInfo['version_name'];
+    }
 }

src/MySQLReplication/Definitions/ConstEventType.php

@@ -5,6 +5,7 @@
 /**
  * Class ConstEventType
  * @package MySQLReplication\Definitions
+ * @see https://dev.mysql.com/doc/internals/en/binlog-event-type.html
  */
 class ConstEventType
 {

src/MySQLReplication/Event/QueryEvent.php

@@ -3,11 +3,13 @@
 namespace MySQLReplication\Event;
 
 use MySQLReplication\BinaryDataReader\Exception\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
 {
@@ -26,7 +28,7 @@ public function makeQueryDTO()
         $schema = $this->binaryDataReader->read($schemaLength);
         $this->binaryDataReader->advance(1);
         $query = $this->binaryDataReader->read(
-            $this->eventInfo->getSize() - 13 - $statusVarsLength - $schemaLength - 1
+            $this->eventInfo->getSize() - $this->getSizeToRemoveByVersion() - $statusVarsLength - $schemaLength - 1
         );
 
         return new QueryDTO(
@@ -36,4 +38,16 @@ public function makeQueryDTO()
             $query
         );
     }
+
+    /**
+     * @return int
+     */
+    private function getSizeToRemoveByVersion()
+    {
+        if (BinLogServerInfo::MYSQL_VERSION_MARIADB === BinLogServerInfo::getVersion())
+        {
+            return 13;
+        }
+        return 36;
+    }
 }

src/MySQLReplication/Event/RotateEvent.php

@@ -2,22 +2,26 @@
 
 namespace MySQLReplication\Event;
 
+use MySQLReplication\BinaryDataReader\Exception\BinaryDataReaderException;
+use MySQLReplication\BinLog\BinLogServerInfo;
 use MySQLReplication\Event\DTO\RotateDTO;
 
 /**
  * Class RotateEvent
  * @package MySQLReplication\Event
+ * @see https://dev.mysql.com/doc/internals/en/rotate-event.html
  */
-class RotateEvent  extends EventCommon
+class RotateEvent extends EventCommon
 {
     /**
+     * @throws BinaryDataReaderException
      * @return RotateDTO
      */
     public function makeRotateEventDTO()
     {
         $pos = $this->binaryDataReader->readUInt64();
         $binFileName = $this->binaryDataReader->read(
-            $this->eventInfo->getSizeNoHeader() - 8
+            $this->eventInfo->getSizeNoHeader() - $this->getSizeToRemoveByVersion()
         );
 
         return new RotateDTO(
@@ -26,4 +30,16 @@ public function makeRotateEventDTO()
             $binFileName
         );
     }
+
+    /**
+     * @return int
+     */
+    private function getSizeToRemoveByVersion()
+    {
+        if (BinLogServerInfo::MYSQL_VERSION_MARIADB !== BinLogServerInfo::getVersion())
+        {
+            return 8;
+        }
+        return 0;
+    }
 }

src/MySQLReplication/Repository/MySQLRepository.php

@@ -56,7 +56,8 @@ public function getFields($schema, $table)
      */
     public function getConnection()
     {
-        if (false === $this->connection->ping()) {
+        if (false === $this->connection->ping())
+        {
             $this->connection->close();
             $this->connection->connect();
         }
@@ -74,6 +75,19 @@ public function isCheckSum()
         return isset($res['Value']);
     }
 
+    /**
+     * @return string
+     */
+    public function getVersion()
+    {
+        $res = $this->getConnection()->fetchAssoc('SHOW VARIABLES LIKE "version_comment"');
+        if (!empty($res['Value']))
+        {
+            return $res['Value'];
+        }
+        return '';
+    }
+
     /**
      * File
      * Position
@@ -87,4 +101,4 @@ public function getMasterStatus()
     {
         return $this->getConnection()->fetchAssoc('SHOW MASTER STATUS');
     }
-}
+}