add timestap,binInt parse 增加对mysql5.1的支持

Author: fengxiangyun

bin/BinLogPack.php

@@ -50,7 +50,7 @@ public function init($pack, $checkSum = true) {
  self::$EVENT_INFO['time'] = $timestamp = unpack('L', $this->read(4))[1];
  self::$EVENT_INFO['type'] = self::$EVENT_TYPE = unpack('C', $this->read(1))[1];
  self::$EVENT_INFO['id'] = $server_id = unpack('L', $this->read(4))[1];
- self::$EVENT_INFO['sivize'] = $event_size = unpack('L', $this->read(4))[1];
+ self::$EVENT_INFO['size'] = $event_size = unpack('L', $this->read(4))[1];
  //position of the next event
  self::$EVENT_INFO['pos'] = $log_pos = unpack('L', $this->read(4))[1];//
  self::$EVENT_INFO['flag'] = $flags = unpack('S', $this->read(2))[1];
@@ -87,9 +87,9 @@ public function init($pack, $checkSum = true) {
  //gtid event
 
  }elseif(self::$EVENT_TYPE == 15) {
- $pack = self::getInstance();
+ //$pack = self::getInstance();
 
- $pack->read(4);
+ //$pack->read(4);
 
 
  } elseif(self::$EVENT_TYPE == ConstEventType::QUERY_EVENT) {

pack/RowEvent.php

@@ -232,7 +232,6 @@ private static function _read_column_data($cols_bitmap, $len)
  if ($unsigned) {
  $values[$name] = unpack("I", self::$PACK->read(4))[1];
  } else {
-
  $values[$name] = unpack("i", self::$PACK->read(4))[1];
 
  }
@@ -256,7 +255,6 @@ private static function _read_column_data($cols_bitmap, $len)
  //$values[$name] = self.__read_new_decimal(column)
  } elseif ($column['type'] == ConstFieldType::BLOB) {
  //ok
- //echo 'length_size->>>> '.($column['length_size'])."\n";
  $values[$name] = self::_read_string($column['length_size'], $column);
 
  }
@@ -284,7 +282,7 @@ private static function _read_column_data($cols_bitmap, $len)
  $values[$name] = self.__read_date()
  */
  elseif ($column['type'] == ConstFieldType::TIMESTAMP) {
- $values[$name] = self::$PACK->readUint32();
+ $values[$name] = date('Y-m-d H:i:s', self::$PACK->readUint32());
  }
 
  # For new date format:
@@ -297,10 +295,12 @@ private static function _read_column_data($cols_bitmap, $len)
  self::$PACK->read_int_be_by_size(4)), column)
  */
  elseif ($column['type'] == ConstFieldType::LONGLONG) {
- if ($unsigned)
+ if ($unsigned) {
  $values[$name] = self::$PACK->readUint64();
- else
+ } else {
  $values[$name] = self::$PACK->readInt64();
+ }
+
  }
  /*
  elseif ($column['type'] == ConstFieldType::YEAR: