Function _CommitNodes

src/execution_plan/ops/shared/create_functions.c:56–98

commit nodes

// commit nodes
static void _CommitNodes
(
	PendingCreations *pending
) {
	Node         *n                   = NULL;
	GraphContext *gc                  = QueryCtx_GetGraphCtx();
	Graph        *g                   = gc->g;
	uint         node_count           = array_len(pending->created_nodes);
	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 < node_count; i++) {
		n = pending->created_nodes[i];

		AttributeSet attr        = pending->node_attributes[i];
		int*         labels      = pending->node_labels[i];
		uint         label_count = array_len(labels);

		// introduce node into graph
		CreateNode(gc, n, labels, label_count, attr, true);

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

		if(constraint_violation == false) {
			for(uint j = 0; j < label_count; j++) {
				Schema *s = GraphContext_GetSchemaByID(gc, labels[j], SCHEMA_NODE);
				char *err_msg = NULL;
				if(!Schema_EnforceConstraints(s, (GraphEntity*)n, &err_msg)) {
					// constraint violation
					ASSERT(err_msg != NULL);
					constraint_violation = true;
					ErrorCtx_SetError("%s", err_msg);
					free(err_msg);
					break;
				}
			}
		}
	}
}

// commit edge blueprints
static void _CommitEdgesBlueprint