Function _BulkInsert_ReadHeaderProperties

src/bulk_insert/bulk_insert.c:89–120

read the property keys from a header

// read the property keys from a header
static Attribute_ID* _BulkInsert_ReadHeaderProperties
(
	GraphContext* gc,
	SchemaType t,
	const char* data,
	size_t* data_idx,
	uint* prop_count
) {
	ASSERT(gc          !=  NULL);
	ASSERT(data        !=  NULL);
	ASSERT(data_idx    !=  NULL);
	ASSERT(prop_count  !=  NULL);

    // next 4 bytes are property count
    *prop_count = *(uint*)&data[*data_idx];
    *data_idx += sizeof(unsigned int);

    if (*prop_count == 0) return NULL;

    Attribute_ID* prop_indices = rm_malloc(*prop_count * sizeof(Attribute_ID));

    // the rest of the line is [char *prop_key] * prop_count
	for (uint j = 0; j < *prop_count; j++) {
		char* prop_key = (char*)data + *data_idx;
		*data_idx += strlen(prop_key) + 1;

		// add properties to schemas
		prop_indices[j] = GraphContext_FindOrAddAttribute(gc, prop_key, NULL);
	}

    return prop_indices;
}

// read an SIValue from the data stream and update the index appropriately
static SIValue _BulkInsert_ReadProperty