|
@@ -4,8 +4,7 @@
|
|
|
package org.dbsyncer.connector.oracle.schema;
|
|
|
|
|
|
import org.dbsyncer.connector.oracle.OracleException;
|
|
|
-import org.dbsyncer.connector.oracle.schema.support.OracleIntType;
|
|
|
-import org.dbsyncer.connector.oracle.schema.support.OracleLongType;
|
|
|
+import org.dbsyncer.connector.oracle.schema.support.*;
|
|
|
import org.dbsyncer.sdk.schema.AbstractSchemaResolver;
|
|
|
import org.dbsyncer.sdk.schema.DataType;
|
|
|
|
|
@@ -21,8 +20,15 @@ public final class OracleSchemaResolver extends AbstractSchemaResolver {
|
|
|
@Override
|
|
|
protected void initDataTypeMapping(Map<String, DataType> mapping) {
|
|
|
Stream.of(
|
|
|
+ new OracleBytesType(),
|
|
|
+ new OracleDateType(),
|
|
|
+ new OracleDecimalType(),
|
|
|
+ new OracleDoubleType(),
|
|
|
+ new OracleFloatType(),
|
|
|
new OracleIntType(),
|
|
|
- new OracleLongType()
|
|
|
+ new OracleLongType(),
|
|
|
+ new OracleStringType(),
|
|
|
+ new OracleTimestampType()
|
|
|
).forEach(t -> t.getSupportedTypeName().forEach(typeName -> {
|
|
|
if (mapping.containsKey(typeName)) {
|
|
|
throw new OracleException("Duplicate type name: " + typeName);
|