修复JSON无法序列化ByteArrayInputStream类型

dbsyncer-common/pom.xml

@@ -11,11 +11,6 @@
     <artifactId>dbsyncer-common</artifactId>
 
     <dependencies>
-		<!-- json -->
-	    <dependency>
-	      <groupId>org.springframework.boot</groupId>
-	      <artifactId>spring-boot-starter-json</artifactId>
-	    </dependency>
 
         <!-- Log4j2框架的性能是最强的 -->
         <dependency>
@@ -65,6 +60,11 @@
             <groupId>org.json</groupId>
             <artifactId>json</artifactId>
         </dependency>
+        <!-- fastjson -->
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+        </dependency>
 
     </dependencies>
 

dbsyncer-common/src/main/java/org/dbsyncer/common/util/JsonUtil.java

@@ -1,35 +1,15 @@
 package org.dbsyncer.common.util;
 
-import com.fasterxml.jackson.core.JsonGenerationException;
-import com.fasterxml.jackson.databind.JsonMappingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.dbsyncer.common.CommonException;
-
-import java.io.IOException;
+import com.alibaba.fastjson.JSON;
 
 public abstract class JsonUtil {
 
-	private static final ObjectMapper mapper = new ObjectMapper();
-
-	public static String objToJson(Object obj) {
-		try {
-			// 将对象转换成json
-			return mapper.writeValueAsString(obj);
-		} catch (JsonGenerationException e) {
-			throw new CommonException(e);
-		} catch (JsonMappingException e) {
-			throw new CommonException(e);
-		} catch (IOException e) {
-			throw new CommonException(e);
-		}
-	}
+    public static String objToJson(Object obj) {
+        return JSON.toJSONString(obj);
+    }
 
-	public static <T> T jsonToObj(String json, Class<T> valueType) {
-		try {
-			return (T) mapper.readValue(json, valueType);
-		} catch (Exception e) {
-			throw new CommonException(e);
-		}
-	}
+    public static <T> T jsonToObj(String json, Class<T> valueType) {
+        return JSON.parseObject(json, valueType);
+    }
 
 }

dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/impl/IncrementPuller.java

@@ -307,7 +307,7 @@ public class IncrementPuller extends AbstractPuller implements ScheduledTaskJob,
 
         @Override
         public void changedLogEvent(RowChangedEvent rowChangedEvent) {
-            logger.info(rowChangedEvent.toString());
+            logger.info("Table[{}] {}", rowChangedEvent.getTableName(), rowChangedEvent.getEvent());
 
             // 处理过程有异常向上抛
             List<FieldPicker> pickers = tablePicker.get(rowChangedEvent.getTableName());

pom.xml

@@ -49,6 +49,7 @@
         <mysql-binlog.version>0.21.0</mysql-binlog.version>
         <sqljdbc.version>1.2</sqljdbc.version>
         <json.version>20090211</json.version>
+        <fastjson.version>1.2.68</fastjson.version>
         <junit.version>4.12</junit.version>
     </properties>
 
@@ -121,6 +122,12 @@
                 <artifactId>json</artifactId>
                 <version>${json.version}</version>
             </dependency>
+            <!-- fastjson -->
+            <dependency>
+                <groupId>com.alibaba</groupId>
+                <artifactId>fastjson</artifactId>
+                <version>${fastjson.version}</version>
+            </dependency>
 
             <!-- 全文检索 -->
             <dependency>