Method update_tuple

cpp/deeplake_pg/table_storage.cpp:1058–1089

}

bool table_storage::update_tuple(Oid table_id, ItemPointer tid, HeapTuple new_tuple)
{
    auto& table_data = get_table_data(table_id);
    TupleDesc tupdesc = table_data.get_tuple_descriptor();

    try {
        const auto row_number = utils::tid_to_row_number(tid);

        // Verify row exists
        if (row_number >= table_data.num_rows()) {
            ereport(
                ERROR,
                (errcode(ERRCODE_INTERNAL_ERROR),
                 errmsg("Row number %zu out of range for table %s", row_number, table_data.get_table_name().c_str())));
            return false;
        }

        // Extract values from HeapTuple
        std::vector<Datum> values(tupdesc->natts, 0);
        std::vector<uint8_t> nulls(tupdesc->natts, 0);
        heap_deform_tuple(new_tuple, tupdesc, values.data(), reinterpret_cast<bool*>(nulls.data()));

        icm::string_map<nd::array> row;
        ::convert_pg_to_nd(table_data, values, nulls, new_tuple->t_len, row);
        table_data.add_update_row(row_number, std::move(row));

        return true;
    } catch (const base::exception& e) {
        ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR), errmsg("Failed to update tuple: %s", e.what())));
        return false;
    }
}

bool table_storage::fetch_tuple(Oid table_id, ItemPointer tid, TupleTableSlot* slot)
{