Browse Source

支持sqlserver real同步oracle number

AE86 2 năm trước cách đây
mục cha
commit
3b38a90a16

+ 4 - 0
dbsyncer-connector/src/main/java/org/dbsyncer/connector/schema/DecimalValueMapper.java

@@ -33,6 +33,10 @@ public class DecimalValueMapper extends AbstractValueMapper<BigDecimal> {
             Short s = (Short) val;
             return new BigDecimal(s);
         }
+        if (val instanceof Float) {
+            Float f = (Float) val;
+            return new BigDecimal(Float.toString(f));
+        }
         if (val instanceof Boolean) {
             Boolean b = (Boolean) val;
             return new BigDecimal(b ? 1 : 0);

+ 3 - 0
dbsyncer-parser/src/main/java/org/dbsyncer/parser/AbstractWriterBinlog.java

@@ -51,6 +51,9 @@ public abstract class AbstractWriterBinlog extends AbstractBinlogService<WriterR
 
         // 1、获取配置信息
         final TableGroup tableGroup = cacheService.get(message.getTableGroupId(), TableGroup.class);
+        if(tableGroup == null){
+            return null;
+        }
 
         // 2、反序列数据
         Map<String, Object> data = new HashMap<>();

+ 2 - 2
dbsyncer-storage/src/main/java/org/dbsyncer/storage/binlog/AbstractBinlogService.java

@@ -150,9 +150,9 @@ public abstract class AbstractBinlogService<Message> implements BinlogRecorder {
                     doParse();
                 }
             } catch (Exception e) {
-                logger.error(e.getMessage());
+                logger.error(e.getMessage(), e);
             } finally {
-                if (locked) {
+                 if (locked) {
                     running = false;
                     binlogLock.unlock();
                 }