This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new a0a0446 [improve]Oracle entire database synchronization supports
xmltype (#356)
a0a0446 is described below
commit a0a0446e297757e6b98009b4f454f97e92222852
Author: caoliang-web <[email protected]>
AuthorDate: Tue Apr 2 17:56:08 2024 +0800
[improve]Oracle entire database synchronization supports xmltype (#356)
---
.../main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java | 2 ++
.../org/apache/doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java | 1 +
2 files changed, 3 insertions(+)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java
index b6d2bae..304f21f 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java
@@ -42,6 +42,7 @@ public class OracleType {
private static final String NCLOB = "NCLOB";
private static final String BLOB = "BLOB";
private static final String BFILE = "BFILE";
+ private static final String XMLTYPE = "XMLTYPE";
public static String toDorisType(String oracleType, Integer precision,
Integer scale) {
oracleType = oracleType.toUpperCase();
@@ -100,6 +101,7 @@ public class OracleType {
case BLOB:
case CLOB:
case NCLOB:
+ case XMLTYPE:
return DorisType.STRING;
case BFILE:
case BINARY_FLOAT:
diff --git
a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java
index 312345c..7bfa747 100644
---
a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java
+++
b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/CdcOraclelSyncDatabaseCase.java
@@ -56,6 +56,7 @@ public class CdcOraclelSyncDatabaseCase {
//
sourceConfig.put("debezium.database.tablename.case.insensitive","false");
sourceConfig.put("debezium.log.mining.strategy", "online_catalog");
sourceConfig.put("debezium.log.mining.continuous.mine", "true");
+
sourceConfig.put("debezium.database.history.store.only.captured.tables.ddl",
"true");
Configuration config = Configuration.fromMap(sourceConfig);
Map<String, String> sinkConfig = new HashMap<>();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
