add log

dbsyncer-connector/src/main/java/org/dbsyncer/connector/AbstractConnector.java

@@ -7,6 +7,8 @@ import org.dbsyncer.connector.config.WriterBatchConfig;
 import org.dbsyncer.connector.constant.ConnectorConstant;
 import org.dbsyncer.connector.model.Field;
 import org.dbsyncer.connector.schema.*;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.sql.Types;
 import java.util.LinkedHashMap;
@@ -15,6 +17,8 @@ import java.util.Map;
 
 public abstract class AbstractConnector {
 
+    private final Logger logger = LoggerFactory.getLogger(getClass());
+
     protected static final Map<Integer, ValueMapper> valueMappers = new LinkedHashMap<>();
 
     static {
@@ -57,7 +61,7 @@ public abstract class AbstractConnector {
      * @param connectorMapper
      * @param config
      */
-    protected void convertProcessBeforeWriter(ConnectorMapper connectorMapper, WriterBatchConfig config) throws Exception {
+    protected void convertProcessBeforeWriter(ConnectorMapper connectorMapper, WriterBatchConfig config) {
         if (CollectionUtils.isEmpty(config.getFields()) || CollectionUtils.isEmpty(config.getData())) {
             return;
         }
@@ -73,7 +77,12 @@ public abstract class AbstractConnector {
                 final ValueMapper valueMapper = valueMappers.get(f.getType());
                 if (null != valueMapper) {
                     // 当数据类型不同时，转换值类型
-                    row.put(f.getName(), valueMapper.convertValue(connectorMapper, row.get(f.getName())));
+                    try {
+                        row.put(f.getName(), valueMapper.convertValue(connectorMapper, row.get(f.getName())));
+                    } catch (Exception e) {
+                        logger.error("convert value error: ({}, {})", f.getName(), row.get(f.getName()));
+                        throw new ConnectorException(e);
+                    }
                 }
             }
         }

dbsyncer-web/src/main/resources/application.properties

@@ -30,8 +30,8 @@ dbsyncer.storage.binlog.recorder.max-processing-seconds=120
 dbsyncer.storage.binlog.recorder.queue-capacity=10000
 dbsyncer.storage.binlog.recorder.writer-period-millisecond=500
 dbsyncer.storage.binlog.recorder.reader-period-millisecond=2000
-dbsyncer.storage.support.mysql.enabled=true
-dbsyncer.storage.support.mysql.config.url=jdbc:mysql://127.0.0.1:3305/dbsyncer?rewriteBatchedStatements=true&seUnicode=true&characterEncoding=UTF8&serverTimezone=Asia/Shanghai&useSSL=false&verifyServerCertificate=false
+dbsyncer.storage.support.mysql.enabled=false
+dbsyncer.storage.support.mysql.config.url=jdbc:mysql://127.0.0.1:3306/dbsyncer?rewriteBatchedStatements=true&seUnicode=true&characterEncoding=UTF8&serverTimezone=Asia/Shanghai&useSSL=false&verifyServerCertificate=false
 dbsyncer.storage.support.mysql.config.username=root
 dbsyncer.storage.support.mysql.config.password=123