Function EvalEntityUpdates

src/execution_plan/ops/shared/update_functions.c:123–398

build pending updates in the 'updates' array to match all AST-level updates described in the context NULL values are allowed in SET clauses but not in MERGE clauses

// AST-level updates described in the context
// NULL values are allowed in SET clauses but not in MERGE clauses
void EvalEntityUpdates
(
	GraphContext *gc,
	dict *node_updates,
	dict *edge_updates,
	const Record r,
	const EntityUpdateEvalCtx *ctx,
	bool allow_null
) {
	Schema *s = NULL;

	//--------------------------------------------------------------------------
	// validate entity type
	//--------------------------------------------------------------------------

	// get the type of the entity to update
	// if the expected entity was not found, make no updates but do not error
	RecordEntryType t = Record_GetType(r, ctx->record_idx);
	if(unlikely(t == REC_TYPE_UNKNOWN)) {
		return;
	}

	// make sure we're updating either a node or an edge
	if(unlikely(t != REC_TYPE_NODE && t != REC_TYPE_EDGE)) {
		ErrorCtx_RaiseRuntimeException(
			"Update error: alias '%s' did not resolve to a graph entity",
			ctx->alias);
	}

	// label(s) update can only be performed on nodes
	if(unlikely((ctx->add_labels != NULL || ctx->remove_labels != NULL) &&
			t != REC_TYPE_NODE)) {
		ErrorCtx_RaiseRuntimeException(
				"Type mismatch: expected Node but was Relationship");
	}

	GraphEntity *entity = Record_GetGraphEntity(r, ctx->record_idx);

	// if the entity is marked as deleted, make no updates but do not error
	if(unlikely(Graph_EntityIsDeleted(entity))) {
		return;
	}

	dict *updates;
	GraphEntityType entity_type;
	if(t == REC_TYPE_NODE) {
		updates = node_updates;
		entity_type = GETYPE_NODE;
	} else {
		updates = edge_updates;
		entity_type = GETYPE_EDGE;
	}

	PendingUpdateCtx *update;
	dictEntry *entry = HashTableFind(updates, (void *)ENTITY_GET_ID(entity));
	if(entry == NULL) {
		// create a new update context
		update = rm_malloc(sizeof(PendingUpdateCtx));