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

Author: fengxiangyun

Connect.php

@@ -1,5 +1,4 @@
 <?php
-
 require_once ROOT . "config/Config.php";
 require_once ROOT . 'db/TimeDate.php';
 require_once ROOT . 'db/DBMysql.php';
@@ -285,6 +284,8 @@ public static function analysisBinLog($flag = false) {
  // 校验数据包格式
  PackAuth::success($pack);
 
+ //todo eof pack 0xfe
+
  $binlog = BinLogPack::getInstance();
  $result = $binlog->init($pack, self::$_CHECKSUM);
 

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['size'] = $event_size = unpack('L', $this->read(4))[1];
+ self::$EVENT_INFO['sivize'] = $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,6 +87,10 @@ public function init($pack, $checkSum = true) {
  //gtid event
 
  }elseif(self::$EVENT_TYPE == 15) {
+ $pack = self::getInstance();
+
+ $pack->read(4);
+
 
  } elseif(self::$EVENT_TYPE == ConstEventType::QUERY_EVENT) {
 
@@ -95,8 +99,8 @@ public function init($pack, $checkSum = true) {
  if(DEBUG) {
  $msg = self::$_FILE_NAME;
  $msg .= '-- next pos -> '.$log_pos;
-$msg .= ' -- typeEvent -> '.self::$EVENT_TYPE;
-Log::out($msg);
+ $msg .= ' -- typeEvent -> '.self::$EVENT_TYPE;
+ Log::out($msg);
  }
 
  return $data;
@@ -250,15 +254,18 @@ public function readUint56()
  /*
  * 不支持unsigned long long，溢出
  */
- public function readUint64()
- {
+ public function readUint64() {
  $d = $this->read(8);
- $unpackArr = unpack('I2', $d);
+ $data = unpack('V*', $d);
+ $bigInt = bcadd($data[1], bcmul($data[2], bcpow(2, 32)));
+ return $bigInt;
+
+// $unpackArr = unpack('I2', $d);
  //$data = unpack("C*", $d);
  //$r = $data[1] + ($data[2] << 8) + ($data[3] << 16) + ($data[4] << 24);//+
  //$r2= ($data[5]) + ($data[6] << 8) + ($data[7] << 16) + ($data[8] << 24);
 
- return $unpackArr[1] + ($unpackArr[2] << 32);
+// return $unpackArr[1] + ($unpackArr[2] << 32);
  }
 
  public function readInt64()

pack/RowEvent.php

@@ -282,12 +282,13 @@ private static function _read_column_data($cols_bitmap, $len)
  $values[$name] = self.__read_time()
  elseif ($column['type'] == ConstFieldType::DATE:
  $values[$name] = self.__read_date()
- elseif ($column['type'] == ConstFieldType::TIMESTAMP:
- $values[$name] = datetime.datetime.fromtimestamp(
- self::$PACK->read_uint32())
+ */
+ elseif ($column['type'] == ConstFieldType::TIMESTAMP) {
+ $values[$name] = self::$PACK->readUint32();
+ }
 
  # For new date format:
-
+/*
  elseif ($column['type'] == ConstFieldType::TIME2:
  $values[$name] = self.__read_time2(column)
  elseif ($column['type'] == ConstFieldType::TIMESTAMP2: