Function _CreateEdges

src/execution_plan/ops/op_create.c:85–129

prepare to create all edges for the current Record

// prepare to create all edges for the current Record
static void _CreateEdges
(
	OpCreate *op,
	Record r,
	GraphContext *gc
) {
	uint edges_to_create_count = array_len(op->pending.edges_to_create);
	for(uint i = 0; i < edges_to_create_count; i++) {
		// get specified edge to create
		EdgeCreateCtx *e = op->pending.edges_to_create + i;

		// retrieve source and dest nodes
		GraphEntity *src_node  = (GraphEntity*)Record_GetNode(r, e->src_idx);
		GraphEntity *dest_node = (GraphEntity*)Record_GetNode(r, e->dest_idx);

		// verify edge endpoints resolved properly, fail otherwise
		if(unlikely(!src_node                       ||
					!dest_node                      ||
					GraphEntity_IsDeleted(src_node) ||
					GraphEntity_IsDeleted(dest_node))) {
			ErrorCtx_RaiseRuntimeException(
					"Failed to create relationship; endpoint was not found.");
		}

		// create the actual edge
		Edge newEdge = {0};
		newEdge.relationship = e->relation;
		Edge_SetSrcNodeID(&newEdge, ENTITY_GET_ID(src_node));
		Edge_SetDestNodeID(&newEdge, ENTITY_GET_ID(dest_node));
		Edge *edge_ref = Record_AddEdge(r, e->edge_idx, newEdge);

		// convert query-level properties
		PropertyMap *map = op->pending.edges_to_create[i].properties;
		AttributeSet converted_attr = NULL;
		if(map != NULL) {
			ConvertPropertyMap(gc, &converted_attr, r, map, false);
		}

		// save edge for later insertion
		array_append(op->pending.created_edges, edge_ref);

		// save attributes to insert with node
		array_append(op->pending.edge_attributes, converted_attr);
	}
}

// Return mode, emit a populated Record.
static Record _handoff