Merge pull request #159 from jolivares/master

Added PREVIOUS_GTIDS deserializer

Author: shyiko

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

@@ -0,0 +1,39 @@
+/*
+ * Copyright 2013 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 PreviousGtidSetEventData implements EventData {
+    private static final long serialVersionUID = 1L;
+
+    private final String gtidSet;
+
+    public PreviousGtidSetEventData(String gtidSet) {
+        this.gtidSet = gtidSet;
+    }
+
+    public String getGtidSet() {
+        return gtidSet;
+    }
+
+    @Override
+    public String toString() {
+        return "PreviousGtidSetEventData {gtidSet='" + gtidSet + "'}";
+    }
+
+}

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

@@ -113,6 +113,8 @@ private void registerDefaultEventDataDeserializers() {
                 new RowsQueryEventDataDeserializer());
         eventDataDeserializers.put(EventType.GTID,
                 new GtidEventDataDeserializer());
+       eventDataDeserializers.put(EventType.PREVIOUS_GTIDS,
+               new PreviousGtidSetDeserializer());
     }
 
     public void setEventDataDeserializer(EventType eventType, EventDataDeserializer eventDataDeserializer) {

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

@@ -0,0 +1,79 @@
+/*
+ * Copyright 2013 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 static java.lang.String.format;
+
+import java.io.IOException;
+
+import com.github.shyiko.mysql.binlog.event.PreviousGtidSetEventData;
+import com.github.shyiko.mysql.binlog.io.ByteArrayInputStream;
+
+/**
+ * @author <a href="mailto:stanley.shyiko@gmail.com">Stanley Shyiko</a>
+ */
+public class PreviousGtidSetDeserializer
+        implements
+            EventDataDeserializer<PreviousGtidSetEventData> {
+
+    @Override
+    public PreviousGtidSetEventData deserialize(
+            ByteArrayInputStream inputStream) throws IOException {
+        int nUuids = inputStream.readInteger(8);
+        String[] gtids = new String[nUuids];
+        for (int i = 0; i < nUuids; i++) {
+            String uuid = formatUUID(inputStream.read(16));
+
+            int nIntervals = inputStream.readInteger(8);
+            String[] intervals = new String[nIntervals];
+            for (int j = 0; j < nIntervals; j++) {
+                long start = inputStream.readLong(8);
+                long end = inputStream.readLong(8);
+                intervals[j] = start + "-" + (end - 1);
+            }
+
+            gtids[i] = format("%s:%s", uuid, join(intervals, ":"));
+        }
+        return new PreviousGtidSetEventData(join(gtids, ","));
+    }
+
+    private String formatUUID(byte[] bytes) {
+        return format("%s-%s-%s-%s-%s", byteArrayToHex(bytes, 0, 4),
+                byteArrayToHex(bytes, 4, 2), byteArrayToHex(bytes, 6, 2),
+                byteArrayToHex(bytes, 8, 2), byteArrayToHex(bytes, 10, 6));
+
+    }
+
+    private static String byteArrayToHex(byte[] a, int offset, int len) {
+        StringBuilder sb = new StringBuilder();
+        for (int idx = offset; idx < (offset + len) && idx < a.length; idx++) {
+            sb.append(format("%02x", a[idx] & 0xff));
+        }
+        return sb.toString();
+    }
+
+    private static String join(String[] values, String separator) {
+        StringBuilder sb = new StringBuilder();
+        for (int i = 0; i < values.length; i++) {
+            if (i > 0) {
+                sb.append(separator);
+            }
+            sb.append(values[i]);
+        }
+        return sb.toString();
+    }
+
+}

src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/PreviousGtidSetDeserializerTest.java

@@ -0,0 +1,51 @@
+/*
+ * Copyright 2013 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 static junit.framework.Assert.assertEquals;
+
+import java.io.IOException;
+
+import org.junit.Test;
+
+import com.github.shyiko.mysql.binlog.event.PreviousGtidSetEventData;
+import com.github.shyiko.mysql.binlog.io.ByteArrayInputStream;
+
+/**
+ * @author <a href="mailto:stanley.shyiko@gmail.com">Stanley Shyiko</a>
+ */
+public class PreviousGtidSetDeserializerTest {
+
+    private static final byte[] DATA = {2, 0, 0, 0, 0, 0, 0, 0, -75, -51, 22,
+            36, 95, 48, 17, -28, -76, -23, 16, 81, 114, 27, -46, 65, 1, 0, 0, 0,
+            0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, -15, 15, 108, 0, 0, 0, 0, 0,
+            -69, 66, 29, 38, 95, 48, 17, -28, -76, -23, -40, -99, 103, 43, 46,
+            -8, 1, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, -47, 97, 119, 0,
+            0, 0, 0, 0};
+
+    private static final String GTID_SET = "b5cd1624-5f30-11e4-b4e9-1051721bd241:1-7081968," +
+            "bb421d26-5f30-11e4-b4e9-d89d672b2ef8:1-7823824";
+
+    @Test
+    public void deserialize() throws IOException {
+        PreviousGtidSetDeserializer deserializer = new PreviousGtidSetDeserializer();
+        PreviousGtidSetEventData previousGtidSetData = deserializer
+                .deserialize(new ByteArrayInputStream(DATA));
+
+        assertEquals(GTID_SET, previousGtidSetData.getGtidSet());
+    }
+
+}