Function process_utility

cpp/deeplake_pg/extension_init.cpp:488–1214

}

static void process_utility(PlannedStmt* pstmt,
                            const char* queryString,
                            bool readOnlyTree,
                            ProcessUtilityContext context,
                            ParamListInfo params,
                            QueryEnvironment* queryEnv,
                            DestReceiver* dest,
                            QueryCompletion* completionTag)
{
    pg::runtime_printer printer("Process Utility Hook");
    pg::init_deeplake();
    if (nodeTag(pstmt->utilityStmt) == T_DropStmt) {
        DropStmt* stmt = (DropStmt*)pstmt->utilityStmt;
        if (stmt->removeType == OBJECT_EXTENSION) {
            // Extension is being dropped, clean up all tables and indexes
            pg::pg_index::clear();
            pg::table_storage::instance().clear();
        } else if (stmt->removeType == OBJECT_INDEX) {
            ListCell* lc = nullptr;
            foreach (lc, stmt->objects) {
                List* object = (List*)lfirst(lc);
                const char* index_name = strVal(linitial(object));
                if (!pg::pg_index::has_indexes()) {
                    pg::load_index_metadata();
                }
                pg::pg_index::erase_info(index_name);
                pg::erase_indexer_data(std::string{}, std::string{}, index_name);
            }
        } else if (stmt->removeType == OBJECT_TABLE) {
            ListCell* lc = nullptr;
            foreach (lc, stmt->objects) {
                List* table_name_list = (List*)lfirst(lc);
                std::string table_name;
                if (list_length(table_name_list) == 2) {
                    auto* sname = strVal(linitial(table_name_list));
                    auto* tname = strVal(lsecond(table_name_list));
                    table_name = std::string(sname) + "." + std::string(tname);
                } else if (list_length(table_name_list) == 1) {
                    table_name = std::string("public.") + strVal(linitial(table_name_list));
                }
                // Handle both index and table cleanup
                if (pg::pg_index::has_index_created_on_table(table_name)) {
                    pg::pg_index::erase_table_info(table_name);
                    pg::erase_indexer_data(table_name, std::string{}, std::string{});
                }
                pg::table_storage::instance().drop_table(table_name);
            }
        } else if (stmt->removeType == OBJECT_VIEW) {
            ListCell* lc = nullptr;
            foreach (lc, stmt->objects) {
                List* view_name_list = (List*)lfirst(lc);
                std::string view_name;
                if (list_length(view_name_list) == 2) {
                    auto* sname = strVal(linitial(view_name_list));
                    auto* vname = strVal(lsecond(view_name_list));
                    view_name = std::string(sname) + "." + std::string(vname);
                } else if (list_length(view_name_list) == 1) {
                    view_name = std::string(strVal(linitial(view_name_list)));