Merge pull request shyiko#168 from stevenczp/master

add XA_PREPARE Deserializer

Author: shyiko

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

@@ -0,0 +1,95 @@
+/*
+ * 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;
+
+import java.util.Arrays;
+
+/**
+ * @author <a href="https://github.com/stevenczp">Steven Cheng</a>
+ */
+public class XAPrepareEventData implements EventData {
+    private boolean onePhase;
+    private int formatID;
+    private int gtridLength;
+    private int bqualLength;
+    private byte[] data;
+    private String gtrid;
+    private String bqual;
+
+    public boolean isOnePhase() {
+        return onePhase;
+    }
+
+    public void setOnePhase(boolean onePhase) {
+        this.onePhase = onePhase;
+    }
+
+    public int getFormatID() {
+        return formatID;
+    }
+
+    public void setFormatID(int formatID) {
+        this.formatID = formatID;
+    }
+
+    public int getGtridLength() {
+        return gtridLength;
+    }
+
+    public void setGtridLength(int gtridLength) {
+        this.gtridLength = gtridLength;
+    }
+
+    public int getBqualLength() {
+        return bqualLength;
+    }
+
+    public void setBqualLength(int bqualLength) {
+        this.bqualLength = bqualLength;
+    }
+
+    public byte[] getData() {
+        return data;
+    }
+
+    public void setData(byte[] data) {
+        this.data = data;
+        gtrid = new String(data, 0, gtridLength);
+        bqual = new String(data, gtridLength, bqualLength);
+    }
+
+    public String getGtrid() {
+        return gtrid;
+    }
+
+    public String getBqual() {
+        return bqual;
+    }
+
+    @Override
+    public String toString() {
+        final StringBuilder sb = new StringBuilder("XAPrepareEventData{");
+        sb.append("onePhase=").append(onePhase);
+        sb.append(", formatID=").append(formatID);
+        sb.append(", gtridLength=").append(gtridLength);
+        sb.append(", bqualLength=").append(bqualLength);
+        sb.append(", data=").append(Arrays.toString(data));
+        sb.append(", gtrid='").append(gtrid).append('\'');
+        sb.append(", bqual='").append(bqual).append('\'');
+        sb.append('}');
+        return sb.toString();
+    }
+}

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

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

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

@@ -0,0 +1,47 @@
+/*
+ * 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 com.github.shyiko.mysql.binlog.event.XAPrepareEventData;
+import com.github.shyiko.mysql.binlog.io.ByteArrayInputStream;
+
+import java.io.IOException;
+
+/**
+ * https://github.com/mysql/mysql-server/blob/5.7/libbinlogevents/src/control_events.cpp#L590
+ * <p>
+ * onePhase : boolean, 1byte
+ * formatID : int, 4byte
+ * gtridLength : int, 4byte
+ * bqualLength : int, 4byte
+ * data : String, gtrid + bqual, (gtridLength + bqualLength)byte
+ * <p>
+ * @author <a href="https://github.com/stevenczp">Steven Cheng</a>
+ */
+public class XAPrepareEventDataDeserializer implements EventDataDeserializer<XAPrepareEventData> {
+    @Override
+    public XAPrepareEventData deserialize(ByteArrayInputStream inputStream) throws IOException {
+        XAPrepareEventData xaPrepareEventData = new XAPrepareEventData();
+        xaPrepareEventData.setOnePhase(inputStream.read() == 0x00 ? false : true);
+        xaPrepareEventData.setFormatID(inputStream.readInteger(4));
+        xaPrepareEventData.setGtridLength(inputStream.readInteger(4));
+        xaPrepareEventData.setBqualLength(inputStream.readInteger(4));
+        xaPrepareEventData.setData(inputStream.read(
+            xaPrepareEventData.getGtridLength() + xaPrepareEventData.getBqualLength()));
+
+        return xaPrepareEventData;
+    }
+}

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

@@ -0,0 +1,49 @@
+/*
+ * 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 com.github.shyiko.mysql.binlog.event.XAPrepareEventData;
+import com.github.shyiko.mysql.binlog.io.ByteArrayInputStream;
+import org.testng.annotations.Test;
+
+import java.io.IOException;
+
+import static org.testng.Assert.assertEquals;
+
+/**
+ * @author <a href="https://github.com/stevenczp">Steven Cheng</a>
+ */
+public class XAPrepareEventDataDeserializerTest {
+    private static final byte[] DATA =
+        {0, 123, 0, 0, 0, 5, 0, 0, 0, 5, 0, 0, 0, 103, 116, 114, 105, 100, 98, 113, 117, 97, 108};
+
+    private static final boolean ONEPHASE = false;
+    private static final int FORMATID = 123;
+    private static final String GTRID = "gtrid";
+    private static final String BQUAL = "bqual";
+
+    @Test
+    public void deserialize() throws IOException {
+        XAPrepareEventDataDeserializer deserializer = new XAPrepareEventDataDeserializer();
+        XAPrepareEventData xaPrepareEventData =
+            deserializer.deserialize(new ByteArrayInputStream(DATA));
+
+        assertEquals(ONEPHASE, xaPrepareEventData.isOnePhase());
+        assertEquals(FORMATID, xaPrepareEventData.getFormatID());
+        assertEquals(GTRID, xaPrepareEventData.getGtrid());
+        assertEquals(BQUAL, xaPrepareEventData.getBqual());
+    }
+}