Преглед изворни кода

支持oracle标准数据类型

穿云 пре 4 месеци
родитељ
комит
33319698f0

+ 1 - 0
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/schema/support/OracleDecimalType.java

@@ -19,6 +19,7 @@ import java.util.stream.Collectors;
 public final class OracleDecimalType extends DecimalType {
 
     private enum TypeEnum {
+        NUMBER("NUMBER"),
         FLOAT("FLOAT");
 
         private final String value;

+ 1 - 2
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/schema/support/OracleFloatType.java

@@ -18,8 +18,7 @@ import java.util.stream.Collectors;
 public final class OracleFloatType extends FloatType {
 
     private enum TypeEnum {
-        BINARY_FLOAT("BINARY_FLOAT"),
-        REAL("REAL");
+        BINARY_FLOAT("BINARY_FLOAT");
 
         private final String value;
 

+ 2 - 19
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/schema/support/OracleIntType.java

@@ -6,9 +6,8 @@ package org.dbsyncer.connector.oracle.schema.support;
 import org.dbsyncer.sdk.model.Field;
 import org.dbsyncer.sdk.schema.support.IntType;
 
-import java.util.Arrays;
+import java.util.Collections;
 import java.util.Set;
-import java.util.stream.Collectors;
 
 /**
  * @Author 穿云
@@ -17,25 +16,9 @@ import java.util.stream.Collectors;
  */
 public final class OracleIntType extends IntType {
 
-    private enum TypeEnum {
-        INT("INT"),
-        INTEGER("INTEGER"),
-        NUMBER("NUMBER9");
-
-        private final String value;
-
-        TypeEnum(String value) {
-            this.value = value;
-        }
-
-        public String getValue() {
-            return value;
-        }
-    }
-
     @Override
     public Set<String> getSupportedTypeName() {
-        return Arrays.stream(TypeEnum.values()).map(TypeEnum::getValue).collect(Collectors.toSet());
+        return Collections.emptySet();
     }
 
     @Override

+ 2 - 17
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/schema/support/OracleLongType.java

@@ -6,9 +6,8 @@ package org.dbsyncer.connector.oracle.schema.support;
 import org.dbsyncer.sdk.model.Field;
 import org.dbsyncer.sdk.schema.support.LongType;
 
-import java.util.Arrays;
+import java.util.Collections;
 import java.util.Set;
-import java.util.stream.Collectors;
 
 /**
  * @Author 穿云
@@ -17,23 +16,9 @@ import java.util.stream.Collectors;
  */
 public final class OracleLongType extends LongType {
 
-    private enum TypeEnum {
-        NUMBER("NUMBER10-18");
-
-        private final String value;
-
-        TypeEnum(String value) {
-            this.value = value;
-        }
-
-        public String getValue() {
-            return value;
-        }
-    }
-
     @Override
     public Set<String> getSupportedTypeName() {
-        return Arrays.stream(TypeEnum.values()).map(TypeEnum::getValue).collect(Collectors.toSet());
+        return Collections.emptySet();
     }
 
     @Override

+ 3 - 2
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/schema/support/OracleStringType.java

@@ -22,10 +22,11 @@ public final class OracleStringType extends StringType {
         NCHAR("NCHAR"),
         VARCHAR2("VARCHAR2"),
         NVARCHAR2("NVARCHAR2"),
-        LONG("LONG"),
         CLOB("CLOB"),
         NCLOB("NCLOB"),
-        ROWID("ROWID");
+        LONG("LONG"),
+        ROWID("ROWID"),
+        UROWID("UROWID");
 
         private final String value;
 

+ 3 - 2
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/schema/support/OracleTimestampType.java

@@ -19,8 +19,9 @@ import java.util.stream.Collectors;
 public final class OracleTimestampType extends TimestampType {
 
     private enum TypeEnum {
-        TIMESTAMP("TIMESTAMP"),
-        TIMESTAMP_WITH_LOCAL_TIME_ZONE("TIMESTAMP WITH LOCAL TIME ZONE");
+        TIMESTAMP("TIMESTAMP(6)"),
+        TIMESTAMP_WITH_TIME_ZONE("TIMESTAMP(6) WITH TIME ZONE"),
+        TIMESTAMP_WITH_LOCAL_TIME_ZONE("TIMESTAMP(6) WITH LOCAL TIME ZONE");
 
         private final String value;