支持mysql数据类型 tinyint unsigned & tinyint unsigned zerofill

dbsyncer-connector/dbsyncer-connector-mysql/src/main/java/org/dbsyncer/connector/mysql/deserializer/DeleteDeserializer.java

@@ -20,10 +20,17 @@ public class DeleteDeserializer extends DeleteRowsEventDataDeserializer {
         super(tableMapEventByTableId);
     }
 
+    @Override
+    protected Serializable deserializeTiny(ByteArrayInputStream inputStream) throws IOException {
+        return inputStream.readInteger(1);
+    }
+
+    @Override
     protected Serializable deserializeDatetimeV2(int meta, ByteArrayInputStream inputStream) throws IOException {
         return datetimeV2Deserialize.deserializeDatetimeV2(meta, inputStream);
     }
 
+    @Override
     protected byte[] deserializeJson(int meta, ByteArrayInputStream inputStream) throws IOException {
         return jsonBinaryDeserialize.deserializeJson(meta, inputStream);
     }

dbsyncer-connector/dbsyncer-connector-mysql/src/main/java/org/dbsyncer/connector/mysql/deserializer/UpdateDeserializer.java

@@ -20,10 +20,17 @@ public class UpdateDeserializer extends UpdateRowsEventDataDeserializer {
         super(tableMapEventByTableId);
     }
 
+    @Override
+    protected Serializable deserializeTiny(ByteArrayInputStream inputStream) throws IOException {
+        return inputStream.readInteger(1);
+    }
+
+    @Override
     protected Serializable deserializeDatetimeV2(int meta, ByteArrayInputStream inputStream) throws IOException {
         return datetimeV2Deserialize.deserializeDatetimeV2(meta, inputStream);
     }
 
+    @Override
     protected byte[] deserializeJson(int meta, ByteArrayInputStream inputStream) throws IOException {
         return jsonBinaryDeserialize.deserializeJson(meta, inputStream);
     }

dbsyncer-connector/dbsyncer-connector-mysql/src/main/java/org/dbsyncer/connector/mysql/deserializer/WriteDeserializer.java

@@ -20,10 +20,17 @@ public class WriteDeserializer extends WriteRowsEventDataDeserializer {
         super(tableMapEventByTableId);
     }
 
+    @Override
+    protected Serializable deserializeTiny(ByteArrayInputStream inputStream) throws IOException {
+        return inputStream.readInteger(1);
+    }
+
+    @Override
     protected Serializable deserializeDatetimeV2(int meta, ByteArrayInputStream inputStream) throws IOException {
         return datetimeV2Deserialize.deserializeDatetimeV2(meta, inputStream);
     }
 
+    @Override
     protected byte[] deserializeJson(int meta, ByteArrayInputStream inputStream) throws IOException {
         return jsonBinaryDeserialize.deserializeJson(meta, inputStream);
     }