Added support for MySQL JSON type

Author: rhauch

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

@@ -15,10 +15,6 @@
  */
 package com.github.shyiko.mysql.binlog.event.deserialization;
 
-import com.github.shyiko.mysql.binlog.event.EventData;
-import com.github.shyiko.mysql.binlog.event.TableMapEventData;
-import com.github.shyiko.mysql.binlog.io.ByteArrayInputStream;
-
 import java.io.IOException;
 import java.io.Serializable;
 import java.math.BigDecimal;
@@ -27,6 +23,10 @@
 import java.util.Map;
 import java.util.TimeZone;
 
+import com.github.shyiko.mysql.binlog.event.EventData;
+import com.github.shyiko.mysql.binlog.event.TableMapEventData;
+import com.github.shyiko.mysql.binlog.io.ByteArrayInputStream;
+
 /**
  * Whole class is basically a mix of <a href="https://code.google.com/p/open-replicator">open-replicator</a>'s
  * AbstractRowEventParser and MySQLUtils. Main purpose here is to ease rows deserialization.<p>
@@ -170,6 +170,8 @@ protected Serializable deserializeCell(ColumnType type, int meta, int length, By
                 return deserializeSet(length, inputStream);
             case GEOMETRY:
                 return deserializeGeometry(meta, inputStream);
+            case JSON:
+                return deserializeJson(meta, inputStream);
             default:
                 throw new IOException("Unsupported type " + type);
         }
@@ -329,6 +331,11 @@ protected byte[] deserializeGeometry(int meta, ByteArrayInputStream inputStream)
         return inputStream.read(dataLength);
     }
 
+    protected byte[] deserializeJson(int meta, ByteArrayInputStream inputStream) throws IOException {
+        int blobLength = inputStream.readInteger(meta);
+        return inputStream.read(blobLength);
+    }
+
     // checkstyle, please ignore ParameterNumber for the next line
     private static Long asUnixTime(int year, int month, int day, int hour, int minute, int second, int millis) {
         // https://dev.mysql.com/doc/refman/5.0/en/datetime.html

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

@@ -45,6 +45,7 @@ public enum ColumnType {
     TIMESTAMP_V2(17),
     DATETIME_V2(18),
     TIME_V2(19),
+    JSON(245),
     NEWDECIMAL(246),
     ENUM(247),
     SET(248),