add testDeserializationOfIntegerAsByteArray in BinaryLogClientIntegrationTest.

Author: zzt93

src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java

@@ -421,6 +421,44 @@ public void testDeserializationOfDateAndTimeAsLong() throws Exception {
         }
     }
 
+    @Test
+    public void testDeserializationOfIntegerAsByteArray() throws Exception {
+        final BinaryLogClient client = new BinaryLogClient(slave.hostname, slave.port,
+            slave.username, slave.password);
+        EventDeserializer eventDeserializer = new EventDeserializer();
+        eventDeserializer.setCompatibilityMode(CompatibilityMode.INTEGER_AS_BYTE_ARRAY);
+        client.setEventDeserializer(eventDeserializer);
+        client.connect(DEFAULT_TIMEOUT);
+        try {
+            assertEquals(writeAndCaptureRow("tinyint unsigned", "0", "1", "255"),
+                new Serializable[]{new byte[]{0}, new byte[]{1}, new byte[]{-1}});
+            assertEquals(writeAndCaptureRow("tinyint", "-128", "-1", "0", "1", "127"),
+                new Serializable[]{new byte[]{-0x80}, new byte[]{-1}, new byte[]{0}, new byte[]{1}, new byte[]{0x7f}});
+
+            assertEquals(writeAndCaptureRow("smallint unsigned", "0", "1", "65535"),
+                new Serializable[]{new byte[]{0, 0}, new byte[]{0, 1}, new byte[]{-1, -1}});
+            assertEquals(writeAndCaptureRow("smallint", "-32768", "-1", "0", "1", "32767"),
+                new Serializable[]{new byte[]{-0x80, 0}, new byte[]{-1, -1}, new byte[]{0, 0}, new byte[]{0, 1}, new byte[]{0x7f, -1}});
+
+            assertEquals(writeAndCaptureRow("mediumint unsigned", "0", "1", "16777215"),
+                new Serializable[]{new byte[]{0, 0, 0}, new byte[]{0, 0, 1}, new byte[]{-1, -1, -1}});
+            assertEquals(writeAndCaptureRow("mediumint", "-8388608", "-1", "0", "1", "8388607"),
+                new Serializable[]{new byte[]{-0x80, 0, 0}, new byte[]{-1, -1, -1}, new byte[]{0, 0, 0}, new byte[]{0, 0, 1}, new byte[]{0x7f, -1, -1}});
+
+            assertEquals(writeAndCaptureRow("int unsigned", "0", "1", "4294967295"),
+                new Serializable[]{new byte[]{0, 0, 0, 0}, new byte[]{0, 0, 0, 1}, new byte[]{-1, -1, -1, -1}});
+            assertEquals(writeAndCaptureRow("int", "-2147483648", "-1", "0", "1", "2147483647"),
+                new Serializable[]{new byte[]{-0x80, 0, 0, 0}, new byte[]{-1, -1, -1, -1}, new byte[]{0, 0, 0, 0}, new byte[]{0, 0, 0, 1}, new byte[]{0x7f, -1, -1, -1}});
+
+            assertEquals(writeAndCaptureRow("bigint unsigned", "0", "1", "18446744073709551615"),
+                new Serializable[]{new byte[]{0, 0, 0, 0, 0, 0, 0, 0}, new byte[]{0, 0, 0, 0, 0, 0, 0, 1}, new byte[]{-1, -1, -1, -1, -1, -1, -1, -1}});
+            assertEquals(writeAndCaptureRow("bigint", "-9223372036854775808", "-1", "0", "1", "9223372036854775807"),
+                new Serializable[]{new byte[]{-0x80, 0, 0, 0, 0, 0, 0, 0}, new byte[]{-1, -1, -1, -1, -1, -1, -1, -1}, new byte[]{0, 0, 0, 0, 0, 0, 0, 0}, new byte[]{0, 0, 0, 0, 0, 0, 0, 1},  new byte[]{0x7f, -1, -1, -1, -1, -1, -1, -1}});
+        } finally {
+            client.disconnect();
+        }
+    }
+
     @Test
     public void testDeserializationOfDateAndTimeAsLongMicrosecondsPrecision() throws Exception {
         final BinaryLogClient client = new BinaryLogClient(slave.hostname, slave.port,

src/test/onetimeserver

@@ -5,9 +5,9 @@ PLATFORM=${_PLATFORM/ /-}
 
 OS=`uname -s | tr '[:upper:]' '[:lower:]'`
 
-THIS_URL="https://raw.githubusercontent.com/osheroff/onetimeserver/master/onetimeserver"
-WRAPPER_URL="https://raw.githubusercontent.com/osheroff/onetimeserver/master/wrapper/wrapper.c"
-ONETIMESERVER_URL="https://raw.githubusercontent.com/osheroff/onetimeserver-binaries/master/onetimeserver-go/$OS/onetimeserver-go"
+THIS_URL="https://gitee.com/zengzetang/onetimeserver/raw/master/onetimeserver"
+WRAPPER_URL="https://gitee.com/zengzetang/onetimeserver/raw/master/wrapper/wrapper.c"
+ONETIMESERVER_URL="http://localhost:8888/Desktop/onetimeserver-go.txt"
 CACHE_DIR=$HOME/.onetimeserver/$PLATFORM
 
 function usage() {