|
79 | 79 | import org.apache.gravitino.meta.TopicEntity;
|
80 | 80 | import org.apache.gravitino.meta.UserEntity;
|
81 | 81 | import org.apache.gravitino.storage.RandomIdGenerator;
|
| 82 | +import org.apache.gravitino.storage.relational.mapper.CatalogMetaMapper; |
82 | 83 | import org.apache.gravitino.storage.relational.mapper.GroupMetaMapper;
|
83 | 84 | import org.apache.gravitino.storage.relational.mapper.UserMetaMapper;
|
84 | 85 | import org.apache.gravitino.storage.relational.service.MetalakeMetaService;
|
@@ -759,6 +760,13 @@ public void testMetaLifeCycleFromCreationToDeletion() throws IOException {
|
759 | 760 | backend.list(catalog.namespace(), Entity.EntityType.CATALOG, true);
|
760 | 761 | assertTrue(catalogs.contains(catalog));
|
761 | 762 |
|
| 763 | + assertEquals( |
| 764 | + 1, |
| 765 | + SessionUtils.doWithCommitAndFetchResult( |
| 766 | + CatalogMetaMapper.class, |
| 767 | + mapper -> mapper.listCatalogPOsByMetalakeName(metalake.name())) |
| 768 | + .size()); |
| 769 | + |
762 | 770 | List<SchemaEntity> schemas = backend.list(schema.namespace(), Entity.EntityType.SCHEMA, true);
|
763 | 771 | assertTrue(schemas.contains(schema));
|
764 | 772 |
|
@@ -856,6 +864,13 @@ public void testMetaLifeCycleFromCreationToDeletion() throws IOException {
|
856 | 864 | // meta data soft delete
|
857 | 865 | backend.delete(metalake.nameIdentifier(), Entity.EntityType.METALAKE, true);
|
858 | 866 |
|
| 867 | + assertEquals( |
| 868 | + 0, |
| 869 | + SessionUtils.doWithCommitAndFetchResult( |
| 870 | + CatalogMetaMapper.class, |
| 871 | + mapper -> mapper.listCatalogPOsByMetalakeName(metalake.name())) |
| 872 | + .size()); |
| 873 | + |
859 | 874 | // check existence after soft delete
|
860 | 875 | assertFalse(backend.exists(metalake.nameIdentifier(), Entity.EntityType.METALAKE));
|
861 | 876 | assertTrue(backend.exists(anotherMetaLake.nameIdentifier(), Entity.EntityType.METALAKE));
|
|
0 commit comments