Function _BulkInsert_ProcessNodeFile

src/bulk_insert/bulk_insert.c:197–248

}

static int _BulkInsert_ProcessNodeFile
(
	GraphContext* gc,
	const char* data,
	size_t data_len
) {
    uint prop_count;
    size_t data_idx = 0;

    // read the CSV file header labels and update all schemas
    int* label_ids = _BulkInsert_ReadHeaderLabels(gc, SCHEMA_NODE, data, &data_idx);
    uint label_count = array_len(label_ids);
    // read the CSV header properties and collect their indices
    Attribute_ID* prop_indices = _BulkInsert_ReadHeaderProperties(gc, SCHEMA_NODE, data,
	&data_idx, &prop_count);

    // sync each matrix once
    ASSERT(Graph_GetMatrixPolicy(gc->g) == SYNC_POLICY_RESIZE);

	for (uint i = 0; i < label_count; i++) {
		Graph_GetLabelMatrix(gc->g, label_ids[i]);
	}

    // sync node-label matrix
    Graph_GetNodeLabelMatrix(gc->g);
    Graph_SetMatrixPolicy(gc->g, SYNC_POLICY_NOP);

    //--------------------------------------------------------------------------
    // load nodes
    //--------------------------------------------------------------------------

	while (data_idx < data_len) {
		Node n = GE_NEW_NODE();
		GraphEntity* ge;
		Graph_CreateNode(gc->g, &n, label_ids, label_count);
		ge = (GraphEntity*)&n;
		// process entity attributes
		for (uint i = 0; i < prop_count; i++) {
			SIValue value = _BulkInsert_ReadProperty(data, &data_idx);
			// skip invalid attribute values
			if (!(SI_TYPE(value) & SI_VALID_PROPERTY_VALUE))
				continue;
			GraphEntity_AddProperty(ge, prop_indices[i], value);
		}
	}

    Graph_SetMatrixPolicy(gc->g, SYNC_POLICY_RESIZE);
    if (prop_indices) rm_free(prop_indices);
    array_free(label_ids);

    return BULK_OK;
}

static int _BulkInsert_ProcessEdgeFile
(