Method tuple_update

cpp/deeplake_pg/table_am.cpp:1096–1133

}

TM_Result deeplake_table_am_routine::tuple_update(Relation rel,
                                                  ItemPointer otid,
                                                  TupleTableSlot* slot,
                                                  CommandId cid,
                                                  Snapshot snapshot,
                                                  Snapshot crosscheck,
                                                  bool wait,
                                                  TM_FailureData* tmfd,
                                                  LockTupleMode* lockmode,
                                                  TU_UpdateIndexes* update_indexes)
{
    const auto table_id = RelationGetRelid(rel);

    // Convert slot to HeapTuple
    HeapTuple tuple = ExecFetchSlotHeapTuple(slot, true, nullptr);
    if (tuple == nullptr) {
        ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR), errmsg("Failed to fetch tuple from slot")));
    }

    // Update the tuple in our storage
    try {
        if (!table_storage::instance().update_tuple(table_id, otid, tuple)) {
            ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR), errmsg("Failed to update tuple")));
        }
    } catch (const std::exception& e) {
        ereport(ERROR, (errcode(ERRCODE_INTERNAL_ERROR), errmsg("Failed to update tuple: %s", e.what())));
    }

    // Report to statistics collector
    // Deeplake has no HOT updates (columnar storage), so hot_update = false
    // newpage_update also false for columnar storage simplification
    pgstat_count_heap_update(rel, false, false);

    // Increment version to notify other backends
    table_version_tracker::increment_version(table_id);

    return TM_Ok;
}

void deeplake_table_am_routine::relation_set_new_node(
    Relation rel, const RelFileLocator* newrnode, char persistence, TransactionId* freezeXid, MultiXactId* minmulti)