[feature][catalog] add test from check catalogtype To db

apache · Aug 7, 2024 · 3e4e6e2 · 3e4e6e2
1 parent 9ecc242
commit 3e4e6e2
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/...ole-service/src/main/java/org/apache/streampark/console/core/bean/FlinkCatalogParams.java b/...ole-service/src/main/java/org/apache/streampark/console/core/bean/FlinkCatalogParams.java
@@ -30,6 +30,7 @@
 import javax.validation.constraints.NotBlank;
 
 import java.io.Serializable;
+import java.util.Date;
 
 @Data
 @Slf4j
@@ -46,6 +47,10 @@ public class FlinkCatalogParams implements Serializable {
     /** creator */
     private Long userId;
 
+    private Date createTime;
+
+    private Date updateTime;
+
     private FlinkJDBCCatalog flinkJDBCCatalog;
 
     private FlinkHiveCatalog flinkHiveCatalog;

diff --git a/...-service/src/test/java/org/apache/streampark/console/core/service/CatalogServiceTest.java b/...-service/src/test/java/org/apache/streampark/console/core/service/CatalogServiceTest.java
@@ -91,6 +91,8 @@ public void update() {
             catalogResult.getRecords().get(0).getFlinkJDBCCatalog().getBaseUrl().contains("url2"))
                 .isTrue();
         assertThat(catalogResult.getRecords().get(0).getUserId().equals(2L)).isTrue();
+        assertThat(catalogResult.getRecords().get(0).getCatalogType().equals(CatalogType.JDBC))
+            .isTrue();
     }
 
     @Test