支持sqlserver float 同步mysql float

Signed-off-by: AE86 <836391306@qq.com>

dbsyncer-connector/src/main/java/org/dbsyncer/connector/mysql/MysqlConnector.java

@@ -33,7 +33,7 @@ public final class MysqlConnector extends AbstractDatabaseConnector {
     public String getPageCursorSql(PageSql config) {
         // 不支持游标查询
         if (!isSupportedCursor(config)) {
-            logger.warn("不支持游标查询，主键包含非数字类型");
+            logger.debug("不支持游标查询，主键包含非数字类型");
             return "";
         }
 

dbsyncer-connector/src/main/java/org/dbsyncer/connector/oracle/OracleConnector.java

@@ -44,7 +44,7 @@ public final class OracleConnector extends AbstractDatabaseConnector {
     public String getPageCursorSql(PageSql config) {
         // 不支持游标查询
         if (!isSupportedCursor(config)) {
-            logger.warn("不支持游标查询，主键包含非数字类型");
+            logger.debug("不支持游标查询，主键包含非数字类型");
             return "";
         }
 

dbsyncer-connector/src/main/java/org/dbsyncer/connector/postgresql/PostgreSQLConnector.java

@@ -43,7 +43,7 @@ public final class PostgreSQLConnector extends AbstractDatabaseConnector {
     public String getPageCursorSql(PageSql config) {
         // 不支持游标查询
         if (!isSupportedCursor(config)) {
-            logger.warn("不支持游标查询，主键包含非数字类型");
+            logger.debug("不支持游标查询，主键包含非数字类型");
             return "";
         }
 

dbsyncer-connector/src/main/java/org/dbsyncer/connector/schema/RealValueMapper.java

@@ -13,6 +13,11 @@ public class RealValueMapper extends AbstractValueMapper<Float> {
 
     @Override
     protected Float convert(ConnectorMapper connectorMapper, Object val) {
+        if (val instanceof Double) {
+            Double dob = (Double) val;
+            return Float.valueOf(dob.floatValue());
+        }
+
         throw new ConnectorException(String.format("%s can not find type [%s], val [%s]", getClass().getSimpleName(), val.getClass(), val));
     }
 }