Added INTVAR deserializer

Author: shyiko

src/main/java/com/github/shyiko/mysql/binlog/event/IntVarEventData.java

@@ -0,0 +1,56 @@
+/*
+ * Copyright 2015 Stanley Shyiko
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.github.shyiko.mysql.binlog.event;
+
+/**
+ * @author <a href="mailto:stanley.shyiko@gmail.com">Stanley Shyiko</a>
+ */
+public class IntVarEventData implements EventData {
+
+    /**
+     * Type indicating whether the value is meant to be used for the LAST_INSERT_ID() invocation (should be equal 1) or
+     * AUTO_INCREMENT column (should be equal 2).
+     */
+    private int type;
+    private long value;
+
+    public int getType() {
+        return type;
+    }
+
+    public void setType(int type) {
+        this.type = type;
+    }
+
+    public long getValue() {
+        return value;
+    }
+
+    public void setValue(long value) {
+        this.value = value;
+    }
+
+    @Override
+    public String toString() {
+        final StringBuilder sb = new StringBuilder();
+        sb.append("IntVarEventData");
+        sb.append("{type=").append(type);
+        sb.append(", value=").append(value);
+        sb.append('}');
+        return sb.toString();
+    }
+
+}

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventDeserializer.java

@@ -84,6 +84,8 @@ private void registerDefaultEventDataDeserializers() {
                 new FormatDescriptionEventDataDeserializer());
         eventDataDeserializers.put(EventType.ROTATE,
                 new RotateEventDataDeserializer());
+        eventDataDeserializers.put(EventType.INTVAR,
+            new IntVarEventDataDeserializer());
         eventDataDeserializers.put(EventType.QUERY,
                 new QueryEventDataDeserializer());
         eventDataDeserializers.put(EventType.TABLE_MAP,

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/IntVarEventDataDeserializer.java

@@ -0,0 +1,35 @@
+/*
+ * Copyright 2015 Stanley Shyiko
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.github.shyiko.mysql.binlog.event.deserialization;
+
+import com.github.shyiko.mysql.binlog.event.IntVarEventData;
+import com.github.shyiko.mysql.binlog.io.ByteArrayInputStream;
+
+import java.io.IOException;
+
+/**
+ * @author <a href="mailto:stanley.shyiko@gmail.com">Stanley Shyiko</a>
+ */
+public class IntVarEventDataDeserializer implements EventDataDeserializer<IntVarEventData> {
+
+    @Override
+    public IntVarEventData deserialize(ByteArrayInputStream inputStream) throws IOException {
+        IntVarEventData event = new IntVarEventData();
+        event.setType(inputStream.readInteger(1));
+        event.setValue(inputStream.readLong(8));
+        return event;
+    }
+}