Function CommitUpdates

src/execution_plan/ops/shared/update_functions.c:42–118

commits delayed updates

// commits delayed updates
void CommitUpdates
(
	GraphContext *gc,
	dict *updates,
	EntityType type
) {
	ASSERT(gc      != NULL);
	ASSERT(updates != NULL);
	ASSERT(type    != ENTITY_UNKNOWN);

	uint update_count         = HashTableElemCount(updates);
	bool constraint_violation = false;

	// return early if no updates are enqueued
	if(update_count == 0) return;

	dictEntry *entry;
	dictIterator *it = HashTableGetIterator(updates);
	MATRIX_POLICY policy = Graph_GetMatrixPolicy(gc->g);
	Graph_SetMatrixPolicy(gc->g, SYNC_POLICY_NOP);

	while((entry = HashTableNext(it)) != NULL) {
		PendingUpdateCtx *update = HashTableGetVal(entry);

		// if entity has been deleted, perform no updates
		if(GraphEntity_IsDeleted(update->ge)) continue;

		AttributeSet_PersistValues(update->attributes);
		
		// update the attributes on the graph entity
		UpdateEntityProperties(gc, update->ge, update->attributes,
				type == ENTITY_NODE ? GETYPE_NODE : GETYPE_EDGE, true);
		update->attributes = NULL;

		if(type == ENTITY_NODE) {
			UpdateNodeLabels(gc, (Node*)update->ge, update->add_labels,
				update->remove_labels, array_len(update->add_labels),
				array_len(update->remove_labels), true);
		}

		//----------------------------------------------------------------------
		// enforce constraints
		//----------------------------------------------------------------------

		if(constraint_violation == false) {
			// retrieve labels/rel-type
			uint label_count = 1;
			if (type == ENTITY_NODE) {
				label_count = Graph_LabelTypeCount(gc->g);
			}
			LabelID labels[label_count];
			if (type == ENTITY_NODE) {
				label_count = Graph_GetNodeLabels(gc->g, (Node*)update->ge, labels,
						label_count);
			} else {
				labels[0] = Edge_GetRelationID((Edge*)update->ge);
			}