From cc23b2b9aba8e8edbfef0bda50f2a3df480ee11c Mon Sep 17 00:00:00 2001
From: zhanggougou <15651908511@163.com>
Date: Wed, 10 Jun 2026 16:51:59 +0800
Subject: [PATCH 1/2] =?UTF-8?q?[fire-1323]=20=E6=94=AF=E6=8C=81ob=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E6=BA=90=E8=A7=A3=E6=9E=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/zto/fire/common/enu/Datasource.java       | 2 +-
 fire-core/src/main/resources/fire.properties                    | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/fire-common/src/main/java/com/zto/fire/common/enu/Datasource.java b/fire-common/src/main/java/com/zto/fire/common/enu/Datasource.java
index 24fbf586..612fd4dc 100644
--- a/fire-common/src/main/java/com/zto/fire/common/enu/Datasource.java
+++ b/fire-common/src/main/java/com/zto/fire/common/enu/Datasource.java
@@ -34,7 +34,7 @@ public enum Datasource {
     // TODO: 添加新的数据源时务必在static代码块中添加与DatasourceDesc子类的映射关系
     HIVE("hive"), HBASE("hbase"), KAFKA("kafka"), UPSERT_KAFKA("upsert-kafka"),
     ROCKETMQ("rocketmq"), REDIS("redis"), KINESIS("kinesis"),
-    MYSQL("mysql"), TIDB("tidb"), ORACLE("oracle"), ADB("adb"),
+    MYSQL("mysql"), TIDB("tidb"), ORACLE("oracle"), ADB("adb"),OCEANBASE("oceanbase"),
     SQLSERVER("sqlserver"), DB2("db2"), CLICKHOUSE("clickhouse"),
     PRESTO("presto"), KYLIN("kylin"), DERBY("derby"),
     VIEW("view"), JDBC("jdbc"), FIRE_ROCKETMQ("fire_rocketmq"),
diff --git a/fire-core/src/main/resources/fire.properties b/fire-core/src/main/resources/fire.properties
index 9ae20d93..9e3e0f6e 100644
--- a/fire-core/src/main/resources/fire.properties
+++ b/fire-core/src/main/resources/fire.properties
@@ -126,6 +126,7 @@ fire.lineage.active.stage.threshold                                           =
 fire.lineage.datasource.map.tidb                                              =       4000
 fire.lineage.datasource.map.doris                                             =       9030,8030
 fire.lineage.datasource.map.presto                                            =       7890
+fire.lineage.datasource.map.oceanbase                                         =       2883
 # \u662F\u5426\u5F00\u542F\u914D\u7F6E\u81EA\u9002\u5E94\u524D\u7F00\uFF0C\u81EA\u52A8\u4E3A\u914D\u7F6E\u52A0\u4E0A\u5F15\u64CE\u524D\u7F00\uFF08spark.|flink.\uFF09
 fire.conf.adaptive.prefix                                                     =       true
 # \u7528\u6237\u7EDF\u4E00\u914D\u7F6E\u6587\u4EF6\uFF0C\u5141\u8BB8\u7528\u6237\u5728\u8BE5\u914D\u7F6E\u6587\u4EF6\u4E2D\u5B58\u653E\u516C\u5171\u7684\u914D\u7F6E\u4FE1\u606F\uFF0C\u4F18\u5148\u7EA7\u4F4E\u4E8E\u4EFB\u52A1\u914D\u7F6E\u6587\u4EF6\uFF08\u591A\u4E2A\u4EE5\u9017\u53F7\u5206\u9694\uFF09
-- 
Gitee


From 7c2a9264e9981fb2a60b7d042071227940555c20 Mon Sep 17 00:00:00 2001
From: zhanggougou <15651908511@163.com>
Date: Thu, 11 Jun 2026 09:07:08 +0800
Subject: [PATCH 2/2] =?UTF-8?q?[fire-1323]=20=E6=94=AF=E6=8C=81ob=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E6=BA=90=E8=A7=A3=E6=9E=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/zto/fire/common/enu/Datasource.java        | 1 +
 1 file changed, 1 insertion(+)

diff --git a/fire-common/src/main/java/com/zto/fire/common/enu/Datasource.java b/fire-common/src/main/java/com/zto/fire/common/enu/Datasource.java
index 612fd4dc..05710306 100644
--- a/fire-common/src/main/java/com/zto/fire/common/enu/Datasource.java
+++ b/fire-common/src/main/java/com/zto/fire/common/enu/Datasource.java
@@ -57,6 +57,7 @@ public enum Datasource {
         datasourceMap.put(TIDB, DBDatasource.class);
         datasourceMap.put(ORACLE, DBDatasource.class);
         datasourceMap.put(ADB, DBDatasource.class);
+        datasourceMap.put(OCEANBASE, DBDatasource.class);
         datasourceMap.put(SQLSERVER, DBDatasource.class);
         datasourceMap.put(DB2, DBDatasource.class);
         datasourceMap.put(CLICKHOUSE, DBDatasource.class);
-- 
Gitee