From 4a76d5b0cefae51cb3a139796eb377cecca78a68 Mon Sep 17 00:00:00 2001 From: winteen Date: Tue, 31 Mar 2015 13:39:31 +0800 Subject: [PATCH 1/3] Fix EventType comment. --- .../java/com/github/shyiko/mysql/binlog/event/EventType.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 index 20807056..447bb4c6 100644 --- 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 donw. */ QUERY, /** From 66c7a7ccc9b6d093a5102c5b2afb6674341bf5d0 Mon Sep 17 00:00:00 2001 From: winteen Date: Tue, 31 Mar 2015 13:40:49 +0800 Subject: [PATCH 2/3] fix typo --- .../java/com/github/shyiko/mysql/binlog/event/EventType.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 index 447bb4c6..11ae79cf 100644 --- 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, /** - * Written when an updating statement is donw. + * Written when an updating statement is done. */ QUERY, /** From a7da41cbc0c51c1ce0530b94c9a5ccb4f8dd29d5 Mon Sep 17 00:00:00 2001 From: winteen Date: Wed, 1 Apr 2015 10:27:11 +0800 Subject: [PATCH 3/3] fix EventHeaderV4Deserializer type bug --- .../binlog/event/deserialization/EventHeaderV4Deserializer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java b/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java index a3384df5..2d8bcdd8 100644 --- a/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java +++ b/src/main/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;