Function create_drop_table

datafusion/core/tests/sql/create_drop.rs:71–91

()

#[tokio::test]
async fn create_drop_table() -> Result<()> {
    let ctx = SessionContext::new();

    let sql = "CREATE TABLE dt (a_id integer, a_str string, a_bool boolean);";
    ctx.sql(sql).await.unwrap();

    let cat = ctx.catalog("datafusion").unwrap();
    let schema = cat.schema("public").unwrap();

    let exists = schema.table_exist("dt");
    assert!(exists, "Table should have been created!");

    // Drop the table
    let sql = "DROP TABLE dt;";
    ctx.sql(sql).await.unwrap();

    let exists = schema.table_exist("dt");
    assert!(!exists, "Table should have been dropped!");

    Ok(())
}