test namespace for SparkUnifiedCatalog

apache · Dec 17, 2024 · 85d811f · 85d811f
1 parent 1c0e574
commit 85d811f
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/...-3-common/src/test/java/org/apache/amoro/spark/test/unified/UnifiedCatalogTestSuites.java b/...-3-common/src/test/java/org/apache/amoro/spark/test/unified/UnifiedCatalogTestSuites.java
@@ -91,6 +91,9 @@ public void testTableFormats(TableFormat format, boolean sessionCatalog) {
     long count = sql(sqlText).count();
     Assertions.assertEquals(expect, count);
 
+    // create and drop namespace
+    testNamespaceWithSql();
+
     // visit sub tables.
     testVisitSubTable(format, sessionCatalog);
 
@@ -108,6 +111,17 @@ public void testTableFormats(TableFormat format, boolean sessionCatalog) {
     Assertions.assertFalse(unifiedCatalog().tableExists(target().database, target().table));
   }
 
+  private void testNamespaceWithSql() {
+    // Use SparkTestBase::sql method to test SparkUnifiedCatalog instead of CommonUnifiedCatalog.
+    String createDatabase = "CREATE DATABASE test_unified_catalog";
+    sql(createDatabase);
+    Assertions.assertTrue(unifiedCatalog().databaseExists("test_unified_catalog"));
+
+    String dropDatabase = "DROP DATABASE test_unified_catalog";
+    sql(dropDatabase);
+    Assertions.assertFalse(unifiedCatalog().databaseExists("test_unified_catalog"));
+  }
+
   private String pkDDL(TableFormat format) {
     if (TableFormat.MIXED_HIVE.equals(format) || TableFormat.MIXED_ICEBERG.equals(format)) {
       return ", primary key(id)";