compatibility

Author: krowinski

src/MySQLReplication/Event/QueryEvent.php

@@ -44,6 +44,8 @@ public function makeQueryDTO()
      */
     private function getSizeToRemoveByVersion()
     {
+
+        var_dump(BinLogServerInfo::getVersion());
         if (BinLogServerInfo::MYSQL_VERSION_MARIADB === BinLogServerInfo::getVersion())
         {
             return 13;

src/MySQLReplication/Repository/MySQLRepository.php

@@ -80,12 +80,16 @@ public function isCheckSum()
      */
     public function getVersion()
     {
-        $res = $this->getConnection()->fetchAssoc('SHOW VARIABLES LIKE "version_comment"');
-        if (!empty($res['Value']))
+        $r = '';
+        $versions = $this->getConnection()->fetchAll('SHOW VARIABLES LIKE "version%"');
+        if (is_array($versions) && 0 !== count($versions))
         {
-            return $res['Value'];
+            foreach ($versions as $version)
+            {
+                $r .= $version['Value'];
+            }
         }
-        return '';
+        return $r;
     }
 
     /**