fix issue #125

Author: hetao29

composer.json

@@ -17,7 +17,7 @@
     "ext-json": "*",
     "ext-sockets": "*",
     "doctrine/collections": "^2.1",
-    "doctrine/dbal": "^3.8",
+    "doctrine/dbal": "^4.0",
     "psr/log": "^3.0",
     "psr/simple-cache": "^3.0",
     "symfony/event-dispatcher": "^6.0|^7.0"
@@ -26,7 +26,7 @@
     "kubawerlos/php-cs-fixer-custom-fixers": "^3.19",
     "monolog/monolog": "^3.5",
     "phpstan/phpstan": "^1.10",
-    "phpunit/phpunit": "^10.5",
+    "phpunit/phpunit": "^11.0",
     "symplify/easy-coding-standard": "^12.1"
   },
   "license": "MIT",

src/MySQLReplication/BinaryDataReader/BinaryDataReader.php

@@ -114,16 +114,21 @@ public function readUInt24(): int
         return $data[1] + ($data[2] << 8) + ($data[3] << 16);
     }
 
-    public function readUInt64(): string
+    public function readUInt64(): string|int
     {
         return $this->unpackUInt64($this->read(self::UNSIGNED_INT64_LENGTH));
     }
 
-    public function unpackUInt64(string $binary): string
+    public function unpackUInt64(string $binary): string|int
     {
         $data = self::unpack('V*', $binary);
 
-        return bcadd((string)$data[1], bcmul((string)$data[2], bcpow('2', '32')));
+        $num = bcadd((string)$data[1], bcmul((string)$data[2], bcpow('2', '32')));
+		if($num>PHP_INT_MAX || $num<PHP_INT_MIN){
+			return $num;
+		}else{
+			return intval($num);
+		}
     }
 
     public function readInt24(): int
@@ -138,11 +143,16 @@ public function readInt24(): int
         return $res;
     }
 
-    public function readInt64(): string
+    public function readInt64(): string|int
     {
         $data = self::unpack('V*', $this->read(self::UNSIGNED_INT64_LENGTH));
 
-        return bcadd((string)$data[1], (string)($data[2] << 32));
+        $num = bcadd((string)$data[1], (string)($data[2] << 32));
+		if($num>PHP_INT_MAX || $num<PHP_INT_MIN){
+			return $num;
+		}else{
+			return intval($num);
+		}
     }
 
     public function readLengthString(int $size): string
@@ -286,7 +296,7 @@ public function readDouble(): float
 
     public function readTableId(): string
     {
-        return $this->unpackUInt64($this->read(self::UNSIGNED_INT48_LENGTH) . chr(0) . chr(0));
+        return (string)$this->unpackUInt64($this->read(self::UNSIGNED_INT48_LENGTH) . chr(0) . chr(0));
     }
 
     public function isComplete(int $size): bool

src/MySQLReplication/Event/RotateEvent.php

@@ -13,7 +13,7 @@ class RotateEvent extends EventCommon
 {
     public function makeRotateEventDTO(): RotateDTO
     {
-        $binFilePos = $this->binaryDataReader->readUInt64();
+        $binFilePos = (string)$this->binaryDataReader->readUInt64();
         $binFileName = $this->binaryDataReader->read(
             $this->eventInfo->getSizeNoHeader() - $this->getSizeToRemoveByVersion()
         );

src/MySQLReplication/Event/RowEvent/RowEvent.php

@@ -416,7 +416,7 @@ public function makeUpdateRowsDTO(): ?UpdateRowsDTO
 
     protected function findTableMap(): ?TableMap
     {
-        $tableId = $this->binaryDataReader->readTableId();
+        $tableId = (string)$this->binaryDataReader->readTableId();
         $this->binaryDataReader->advance(2);
 
         if (in_array(

src/MySQLReplication/Event/XidEvent.php

@@ -13,6 +13,6 @@ class XidEvent extends EventCommon
 {
     public function makeXidDTO(): XidDTO
     {
-        return new XidDTO($this->eventInfo, $this->binaryDataReader->readUInt64());
+        return new XidDTO($this->eventInfo, (string)$this->binaryDataReader->readUInt64());
     }
 }