Function _BulkInsert_ReadHeaderLabels

src/bulk_insert/bulk_insert.c:32–86

read the label strings from a header, update schemas, and retrieve the label IDs

// read the label strings from a header, update schemas, and retrieve the label IDs
static int* _BulkInsert_ReadHeaderLabels
(
	GraphContext* gc,
	SchemaType t,
	const char* data,
	size_t* data_idx
) {
	ASSERT(gc        !=  NULL);
	ASSERT(data      !=  NULL);
	ASSERT(data_idx  !=  NULL);

    // first sequence is entity label(s)
    const char* labels = data + *data_idx;
    int labels_len = strlen(labels);
    *data_idx += labels_len + 1;

    // array of all label IDs
    int* label_ids = array_new(int, 1);
    // stack variable to contain a single label
    char label[labels_len + 1];

	while (true) {
		// look for a colon delimiting another label
		char* found = strchr(labels, ':');
		if (found) {
			ASSERT(t == SCHEMA_NODE); // only nodes can have multiple labels
			// this entity file describes multiple labels, copy the current one
			size_t len = found - labels;
			memcpy(label, labels, len);
			label[len] = '\0';
			// update the labels pointer for the next seek
			labels += len + 1;
		} else {
			// reached the last (or only) label; copy it
			size_t len = strlen(labels);
			// Also copy the terminating NULL character.
			memcpy(label, labels, len + 1);
		}

		// try to retrieve the label's schema
		Schema* s = GraphContext_GetSchema(gc, label, t);
		// create the schema if it does not already exist
		if (s == NULL) {
			s = GraphContext_AddSchema(gc, label, t);
		}

		// store the label ID
		array_append(label_ids, Schema_GetID(s));

		// break if we've exhausted all labels
		if (!found) break;
	}

    return label_ids;
}

// read the property keys from a header
static Attribute_ID* _BulkInsert_ReadHeaderProperties