Method clear

cpp/deeplake_pg/table_storage.cpp:1128–1163

}

void table_storage::clear()
{
    auto creds = session_credentials::get_credentials();
    // Clean up all datasets and metadata
    for (auto& [table_id, table_data] : tables_) {
        try {
            table_data.commit(); // Ensure all changes are committed before deletion
            auto creds_for_delete = creds;
            deeplake_api::delete_dataset(table_data.get_dataset_path(), std::move(creds_for_delete)).get_future().get();
            FreeTupleDesc(table_data.get_tuple_descriptor());
        } catch (const base::exception& e) {
            // Log error but continue cleaning up other tables
            ereport(
                WARNING,
                (errcode(ERRCODE_INTERNAL_ERROR),
                 errmsg("Failed to delete dataset for table %s: %s", table_data.get_table_name().c_str(), e.what())));
        }
    }
    table_version_tracker::clear_all_versions();
    tables_.clear();
    views_.clear();
    up_to_date_ = false;

    if (!pg::utils::check_table_exists("pg_deeplake_tables") || !pg::utils::check_table_exists("pg_deeplake_views")) {
        return;
    }
    // Clean up metadata table
    pg::utils::memory_context_switcher context_switcher;
    pg::utils::spi_connector connector;
    if (SPI_execute("DELETE FROM public.pg_deeplake_tables", false, 0) != SPI_OK_DELETE) {
        ereport(WARNING, (errcode(ERRCODE_INTERNAL_ERROR), errmsg("Failed to clear metadata table")));
    }
    if (SPI_execute("DELETE FROM public.pg_deeplake_views", false, 0) != SPI_OK_DELETE) {
        ereport(WARNING, (errcode(ERRCODE_INTERNAL_ERROR), errmsg("Failed to clear views metadata table")));
    }
}

table_data& table_storage::get_table_data(Oid table_id)
{