Function _CommitEdges

src/execution_plan/ops/shared/create_functions.c:134–175

commit edges

// commit edges
static void _CommitEdges
(
	PendingCreations *pending
) {
	Edge         *e                   = NULL;
	GraphContext *gc                  = QueryCtx_GetGraphCtx();
	Graph        *g                   = gc->g;
	uint         edge_count           = array_len(pending->created_edges);
	bool         constraint_violation = false;

	// sync policy should be set to NOP, no need to sync/resize
	ASSERT(Graph_GetMatrixPolicy(g) == SYNC_POLICY_NOP);

	for(int i = 0; i < edge_count; i++) {
		e = pending->created_edges[i];
		NodeID src_id  = Edge_GetSrcNodeID(e);
		NodeID dest_id = Edge_GetDestNodeID(e);
		AttributeSet attr = pending->edge_attributes[i];

		Schema *s = GraphContext_GetSchema(gc, e->relationship, SCHEMA_EDGE);
		// all schemas have been created in the edge blueprint loop or earlier
		ASSERT(s != NULL);
		int relation_id = Schema_GetID(s);

		CreateEdge(gc, e, src_id, dest_id, relation_id, attr, true);

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

		if(constraint_violation == false) {
			char *err_msg = NULL;
			if(!Schema_EnforceConstraints(s, (GraphEntity*)e, &err_msg)) {
				// constraint violated!
				ASSERT(err_msg != NULL);
				constraint_violation = true;
				ErrorCtx_SetError("%s", err_msg);
				free(err_msg);
			}
		}
	}
}

// Initialize all variables for storing pending creations.
void NewPendingCreationsContainer