[incubator-inlong] branch master updated: [INLONG-4466][Manager] Fix the oracle data source could not be parsed (#4467)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new f9ebb4cd9 [INLONG-4466][Manager] Fix the oracle data source could not 
be parsed  (#4467)
f9ebb4cd9 is described below

commit f9ebb4cd9f58d05c3ac618d30098675a8738c91c
Author: jiancheng Lv <635617...@qq.com>
AuthorDate: Wed Jun 1 11:27:53 2022 +0800

    [INLONG-4466][Manager] Fix the oracle data source could not be parsed  
(#4467)
---
 .../apache/inlong/manager/client/api/util/InlongParser.java   | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongParser.java
 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongParser.java
index 212f4741f..2e661b8c3 100644
--- 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongParser.java
+++ 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongParser.java
@@ -53,6 +53,8 @@ import 
org.apache.inlong.manager.common.pojo.source.kafka.KafkaSource;
 import 
org.apache.inlong.manager.common.pojo.source.kafka.KafkaSourceListResponse;
 import org.apache.inlong.manager.common.pojo.source.mysql.MySQLBinlogSource;
 import 
org.apache.inlong.manager.common.pojo.source.mysql.MySQLBinlogSourceListResponse;
+import org.apache.inlong.manager.common.pojo.source.oracle.OracleSource;
+import 
org.apache.inlong.manager.common.pojo.source.oracle.OracleSourceListResponse;
 import org.apache.inlong.manager.common.pojo.source.postgres.PostgresSource;
 import 
org.apache.inlong.manager.common.pojo.source.postgres.PostgresSourceListResponse;
 import org.apache.inlong.manager.common.pojo.stream.FullStreamResponse;
@@ -173,6 +175,11 @@ public class InlongParser {
                         PostgresSource postgresSource = 
GsonUtils.fromJson(sourceJson.toString(), PostgresSource.class);
                         sourceInfos.add(postgresSource);
                         break;
+                    case ORACLE:
+                        OracleSource oracleSource = 
GsonUtils.fromJson(sourceJson.toString(),
+                                OracleSource.class);
+                        sourceInfos.add(oracleSource);
+                        break;
                     default:
                         throw new RuntimeException(String.format("Unsupported 
sourceType=%s", sourceType));
                 }
@@ -248,6 +255,10 @@ public class InlongParser {
                     return GsonUtils.fromJson(pageInfoJson,
                             new 
TypeToken<PageInfo<PostgresSourceListResponse>>() {
                             }.getType());
+                case ORACLE:
+                    return GsonUtils.fromJson(pageInfoJson,
+                            new 
TypeToken<PageInfo<OracleSourceListResponse>>() {
+                            }.getType());
                 default:
                     throw new IllegalArgumentException(
                             String.format("Unsupported sourceType=%sg", 
sourceType));