项目初始化

datax-common/datax-common-database/src/main/java/cn/datax/common/database/core/DbColumn.java

@@ -18,17 +18,17 @@ public class DbColumn {
     /**
      * 数据长度
      */
-    private Integer dataLength;
+    private String dataLength;
 
     /**
      * 数据精度
      */
-    private Integer dataPrecision;
+    private String dataPrecision;
 
     /**
      * 数据小数位
      */
-    private Integer dataScale;
+    private String dataScale;
 
     /**
      * 是否主键

datax-common/datax-common-database/src/main/java/cn/datax/common/database/dialect/MySqlDialect.java

@@ -20,9 +20,9 @@ public class MySqlDialect extends AbstractDbDialect {
             DbColumn entity = new DbColumn();
             entity.setColName(rs.getString("COLNAME"));
             entity.setDataType(rs.getString("DATATYPE"));
-            entity.setDataLength(rs.getInt("DATALENGTH"));
-            entity.setDataPrecision(rs.getInt("DATAPRECISION"));
-            entity.setDataScale(rs.getInt("DATASCALE"));
+            entity.setDataLength(rs.getString("DATALENGTH"));
+            entity.setDataPrecision(rs.getString("DATAPRECISION"));
+            entity.setDataScale(rs.getString("DATASCALE"));
             entity.setColKey("PRI".equals(rs.getString("COLKEY")) ? true : false);
             entity.setNullable("YES".equals(rs.getString("NULLABLE")) ? true : false);
             entity.setColPosition(rs.getInt("COLPOSITION"));

datax-common/datax-common-database/src/main/java/cn/datax/common/database/dialect/OracleDialect.java

@@ -48,9 +48,9 @@ public class OracleDialect extends AbstractDbDialect {
             DbColumn entity = new DbColumn();
             entity.setColName(rs.getString("COLNAME"));
             entity.setDataType(rs.getString("DATATYPE"));
-            entity.setDataLength(rs.getInt("DATALENGTH"));
-            entity.setDataPrecision(rs.getInt("DATAPRECISION"));
-            entity.setDataScale(rs.getInt("DATASCALE"));
+            entity.setDataLength(rs.getString("DATALENGTH"));
+            entity.setDataPrecision(rs.getString("DATAPRECISION"));
+            entity.setDataScale(rs.getString("DATASCALE"));
             entity.setColKey("1".equals(rs.getString("COLKEY")) ? true : false);
             entity.setNullable("Y".equals(rs.getString("NULLABLE")) ? true : false);
             entity.setColPosition(rs.getInt("COLPOSITION"));

datax-common/datax-common-database/src/main/java/cn/datax/common/database/dialect/PostgreDialect.java

@@ -47,9 +47,9 @@ public class PostgreDialect extends AbstractDbDialect {
             DbColumn entity = new DbColumn();
             entity.setColName(rs.getString("COLNAME"));
             entity.setDataType(rs.getString("DATATYPE"));
-            entity.setDataLength(rs.getInt("DATALENGTH"));
-            entity.setDataPrecision(rs.getInt("DATAPRECISION"));
-            entity.setDataScale(rs.getInt("DATASCALE"));
+            entity.setDataLength(rs.getString("DATALENGTH"));
+            entity.setDataPrecision(rs.getString("DATAPRECISION"));
+            entity.setDataScale(rs.getString("DATASCALE"));
             entity.setColKey("1".equals(rs.getString("COLKEY")) ? true : false);
             entity.setNullable("YES".equals(rs.getString("NULLABLE")) ? true : false);
             entity.setColPosition(rs.getInt("COLPOSITION"));

datax-common/datax-common-database/src/main/java/cn/datax/common/database/dialect/SQLServer2008Dialect.java

@@ -82,9 +82,9 @@ public class SQLServer2008Dialect extends AbstractDbDialect {
             DbColumn entity = new DbColumn();
             entity.setColName(rs.getString("COLNAME"));
             entity.setDataType(rs.getString("DATATYPE"));
-            entity.setDataLength(rs.getInt("DATALENGTH"));
-            entity.setDataPrecision(rs.getInt("DATAPRECISION"));
-            entity.setDataScale(rs.getInt("DATASCALE"));
+            entity.setDataLength(rs.getString("DATALENGTH"));
+            entity.setDataPrecision(rs.getString("DATAPRECISION"));
+            entity.setDataScale(rs.getString("DATASCALE"));
             entity.setColKey("1".equals(rs.getString("COLKEY")) ? true : false);
             entity.setNullable("1".equals(rs.getString("NULLABLE")) ? true : false);
             entity.setColPosition(rs.getInt("COLPOSITION"));

datax-modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/async/AsyncTask.java

@@ -72,9 +72,9 @@ public class AsyncTask {
                             metadataColumn.setColumnNullable(column.getNullable() ? "1" : "0");
                             metadataColumn.setColumnPosition(column.getColPosition().toString());
                             metadataColumn.setDataType(column.getDataType());
-                            metadataColumn.setDataLength(column.getDataLength().toString());
-                            metadataColumn.setDataPrecision(column.getDataPrecision().toString());
-                            metadataColumn.setDataScale(column.getDataScale().toString());
+                            metadataColumn.setDataLength(column.getDataLength());
+                            metadataColumn.setDataPrecision(column.getDataPrecision());
+                            metadataColumn.setDataScale(column.getDataScale());
                             metadataColumn.setDataDefault(column.getDataDefault());
                             return metadataColumn;
                         }).collect(Collectors.toList());