Merge pull request #35 from chenyun/master

Updated EventType.QUERY description / Fixed EventHeaderV4.eventLength deserialization
shyiko · Apr 3, 2015 · f1fb18b · f1fb18b
2 parents fa49dd2 + a7da41c
commit f1fb18b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/com/github/shyiko/mysql/binlog/event/EventType.java b/src/main/java/com/github/shyiko/mysql/binlog/event/EventType.java
@@ -33,7 +33,7 @@ public enum EventType {
      */
     START_V3,
     /**
-     * Represents query statement.
+     * Written when an updating statement is done.
      */
     QUERY,
     /**

diff --git a/.../java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java b/.../java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java
@@ -34,7 +34,7 @@ public EventHeaderV4 deserialize(ByteArrayInputStream inputStream) throws IOExce
         header.setTimestamp(inputStream.readLong(4) * 1000L);
         header.setEventType(getEventType(inputStream.readInteger(1)));
         header.setServerId(inputStream.readLong(4));
-        header.setEventLength(inputStream.readInteger(4));
+        header.setEventLength(inputStream.readLong(4));
         header.setNextPosition(inputStream.readLong(4));
         header.setFlags(inputStream.readInteger(2));
         return header;