Function _BulkInsert_ProcessEdgeFile

src/bulk_insert/bulk_insert.c:250–313

}

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

    // read the CSV file header
    // and commit all labels and properties it introduces
    int* type_ids = _BulkInsert_ReadHeaderLabels(gc, SCHEMA_EDGE, data, &data_idx);
    uint type_count = array_len(type_ids);

    // edges can only have one type
    ASSERT(type_count == 1);

    int type_id = type_ids[0];
    Attribute_ID* prop_indices = _BulkInsert_ReadHeaderProperties(gc, SCHEMA_EDGE,
	data, &data_idx, &prop_count);

    // sync matrix once
    ASSERT(Graph_GetMatrixPolicy(gc->g) == SYNC_POLICY_RESIZE);
    Graph_GetRelationMatrix(gc->g, type_id, false);
    Graph_GetAdjacencyMatrix(gc->g, false);
    Graph_SetMatrixPolicy(gc->g, SYNC_POLICY_NOP);

    //--------------------------------------------------------------------------
    // load edges
    //--------------------------------------------------------------------------

	while (data_idx < data_len) {
		Edge e;
		GraphEntity* ge;

		// next 8 bytes are source ID
		NodeID src = *(NodeID*)&data[data_idx];
		data_idx += sizeof(NodeID);
		// next 8 bytes are destination ID
		NodeID dest = *(NodeID*)&data[data_idx];
		data_idx += sizeof(NodeID);

		Graph_CreateEdge(gc->g, src, dest, type_id, &e);
		ge = (GraphEntity*)&e;

		// 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);
		}
	}