Merge pull request #9 from kobi97/some_bug_fixs

 fix - some bugs (query event, timestamp, comment/enum types)

Author: krowinski

src/MySQLReplication/Event/QueryEvent.php

@@ -24,7 +24,7 @@ public function makeQueryDTO()
         $schema = $this->binaryDataReader->read($schema_length);
         $this->binaryDataReader->advance(1);
         $query = $this->binaryDataReader->read(
-            $this->eventInfo->getSize() - 36 - $status_vars_length - $schema_length - 1
+            $this->eventInfo->getSize() - 13 - $status_vars_length - $schema_length - 1
         );
 
         return new QueryDTO(
@@ -34,4 +34,4 @@ public function makeQueryDTO()
             $query
         );
     }
-}
+}

src/MySQLReplication/Event/RowEvent/RowEvent.php

@@ -351,6 +351,10 @@ private function getColumnData($colsBitmap)
             {
                 $values[$name] = $this->getDatetime2($column);
             }
+            elseif ($column['type'] == ConstFieldType::TIMESTAMP)
+			{
+				$values[$name] = date('c', $this->binaryDataReader->readUInt32());
+			}
             elseif ($column['type'] === ConstFieldType::TIME2)
             {
                 $values[$name] = $this->getTime2($column);

src/MySQLReplication/MySQLReplicationFactory.php

@@ -75,6 +75,7 @@ public function __construct(Config $config)
             'host' => $config->getIp(),
             'port' => $config->getPort(),
             'driver' => 'pdo_mysql',
+			'charset' => $config->getCharset() ? $config->getCharset() : 'utf8'
         ]);
         $this->binLogAuth = new BinLogAuth();
         $this->MySQLRepository = new MySQLRepository($this->connection);
@@ -110,4 +111,4 @@ public function binLogEvent()
     {
         $this->event->consume();
     }
-}
+}