Skip to content

Commit a9994d4

Browse files
committed
feat(catalog): Implement register_table for glue catalog
1 parent 7726ce0 commit a9994d4

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
@@ -498,3 +498,32 @@ async fn test_update_table() -> Result<()> {
498498

499499
Ok(())
500500
}
501+
502+
#[tokio::test]
503+
async fn test_register_table() -> Result<()> {
504+
let catalog = get_catalog().await;
505+
let namespace = NamespaceIdent::new("test_register_table".into());
506+
set_test_namespace(&catalog, &namespace).await?;
507+
508+
let creation = set_table_creation(Some("s3a://warehouse/hive/test_register_table".into()), "my_table")?;
509+
let table = catalog.create_table(&namespace, creation).await?;
510+
let metadata_location = table
511+
.metadata_location()
512+
.expect("Expected metadata location to be set")
513+
.to_string();
514+
515+
catalog.drop_table(table.identifier()).await?;
516+
let ident = TableIdent::new(namespace.clone(), "my_table".to_string());
517+
518+
let registered = catalog
519+
.register_table(&ident, metadata_location.clone())
520+
.await?;
521+
522+
assert_eq!(registered.identifier(), &ident);
523+
assert_eq!(
524+
registered.metadata_location().as_deref(),
525+
Some(metadata_location.as_str())
526+
);
527+
528+
Ok(())
529+
}

0 commit comments

Comments
 (0)