add configs for oracle

vesoft-inc · Aug 23, 2022 · 218b859 · 218b859
1 parent 1e8ad19
commit 218b859
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/exchange-common/src/main/scala/com/vesoft/exchange/common/config/Configs.scala b/exchange-common/src/main/scala/com/vesoft/exchange/common/config/Configs.scala
@@ -572,6 +572,7 @@ object Configs {
       case "MAXCOMPUTE" => SourceCategory.MAXCOMPUTE
       case "CLICKHOUSE" => SourceCategory.CLICKHOUSE
       case "POSTGRESQL" => SourceCategory.POSTGRESQL
+      case "ORACLE"     => SourceCategory.ORACLE
       case _            => throw new IllegalArgumentException(s"${category} not support")
     }
   }
@@ -671,6 +672,16 @@ object Configs {
           config.getString("password"),
           getOrElse(config, "sentence", null)
         )
+      case SourceCategory.ORACLE =>
+        OracleConfigEntry(
+          SourceCategory.ORACLE,
+          config.getString("url"),
+          config.getString("driver"),
+          config.getString("user"),
+          config.getString("passwd"),
+          config.getString("table"),
+          getOrElse(config, "sentence", null)
+        )
       case SourceCategory.KAFKA =>
         val intervalSeconds =
           if (config.hasPath("interval.seconds")) config.getInt("interval.seconds")