Skip to content

Commit fcfc8e3

Browse files
committed
feat(catalog): Implement register_table for glue catalog
1 parent 4aacad7 commit fcfc8e3

File tree

1 file changed

+29
-0
lines changed

1 file changed

+29
-0
lines changed

crates/catalog/glue/tests/glue_catalog_test.rs

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -469,3 +469,32 @@ async fn test_update_table() -> Result<()> {
469469

470470
Ok(())
471471
}
472+
473+
#[tokio::test]
474+
async fn test_register_table() -> Result<()> {
475+
let catalog = get_catalog().await;
476+
let namespace = NamespaceIdent::new("test_register_table".into());
477+
set_test_namespace(&catalog, &namespace).await?;
478+
479+
let creation = set_table_creation(Some("s3a://warehouse/hive/test_register_table".into()), "my_table")?;
480+
let table = catalog.create_table(&namespace, creation).await?;
481+
let metadata_location = table
482+
.metadata_location()
483+
.expect("Expected metadata location to be set")
484+
.to_string();
485+
486+
catalog.drop_table(table.identifier()).await?;
487+
let ident = TableIdent::new(namespace.clone(), "my_table".to_string());
488+
489+
let registered = catalog
490+
.register_table(&ident, metadata_location.clone())
491+
.await?;
492+
493+
assert_eq!(registered.identifier(), &ident);
494+
assert_eq!(
495+
registered.metadata_location().as_deref(),
496+
Some(metadata_location.as_str())
497+
);
498+
499+
Ok(())
500+
}

0 commit comments

Comments
 (0)