impl namespace_exists

crates/catalog/glue/src/catalog.rs

@@ -140,8 +140,27 @@ impl Catalog for GlueCatalog {
         }
     }
 
-    async fn namespace_exists(&self, _namespace: &NamespaceIdent) -> Result<bool> {
-        todo!()
+    async fn namespace_exists(&self, namespace: &NamespaceIdent) -> Result<bool> {
+        let db_name = validate_namespace(namespace)?;
+
+        let builder = self.client.0.get_database().name(&db_name);
+        let builder = with_catalog_id!(builder, self.config);
+
+        let resp = builder.send().await;
+
+        match resp {
+            Ok(_) => Ok(true),
+            Err(err) => {
+                if err
+                    .as_service_error()
+                    .map(|e| e.is_entity_not_found_exception())
+                    == Some(true)
+                {
+                    return Ok(false);
+                }
+                Err(from_sdk_error(err))
+            }
+        }
     }
 
     async fn update_namespace(

crates/catalog/glue/tests/glue_catalog_test.rs

@@ -80,6 +80,27 @@ async fn set_test_fixture(func: &str) -> TestFixture {
     }
 }
 
+#[tokio::test]
+async fn test_namespace_exists() -> Result<()> {
+    let fixture = set_test_fixture("test_namespace_exists").await;
+
+    let properties = HashMap::new();
+    let namespace = NamespaceIdent::new("my_database".into());
+
+    let exists = fixture.glue_catalog.namespace_exists(&namespace).await?;
+    assert!(!exists);
+
+    fixture
+        .glue_catalog
+        .create_namespace(&namespace, properties)
+        .await?;
+
+    let exists = fixture.glue_catalog.namespace_exists(&namespace).await?;
+    assert!(exists);
+
+    Ok(())
+}
+
 #[tokio::test]
 async fn test_get_namespace() -> Result<()> {
     let fixture = set_test_fixture("test_get_namespace").await;