Function GraphContext_AddExactMatchIndex

src/graph/graphcontext.c:621–676

create an exact match index for the given label and attribute

// create an exact match index for the given label and attribute
bool GraphContext_AddExactMatchIndex
(
	Index *idx,                 // [input/output] index created
	GraphContext *gc,           // graph context
	SchemaType schema_type,     // type of entities to index nodes/edges
	const char *label,          // label of indexed entities
	const char **fields_str,    // fields to index
	uint fields_count,          // number of fields to index
	bool should_reply           // should reply to client
) {
	ASSERT(idx    !=  NULL);
	ASSERT(gc     !=  NULL);
	ASSERT(label  !=  NULL);
	ASSERT(fields_str !=  NULL);
	ASSERT(fields_count > 0);

	// retrieve the schema for this label
	bool      index_changed = false;
	Schema    *s            = GraphContext_GetSchema(gc, label, schema_type);
	ResultSet *result_set   = should_reply ? QueryCtx_GetResultSet() : NULL;

	if(s == NULL) {
		// schema doesn't exists, create it
		s = GraphContext_AddSchema(gc, label, schema_type);
	}

	for(uint i = 0; i < fields_count; i++) {
		// create index field
		const char *field = fields_str[i];
		IndexField idx_field;
		Attribute_ID f_id = GraphContext_FindOrAddAttribute(gc, field, NULL);
		IndexField_Default(&idx_field, f_id, field);
		if(Schema_AddIndex(idx, s, &idx_field, IDX_EXACT_MATCH) == INDEX_OK) {
			index_changed = true;
			if(should_reply) {
				// update result-set
				ResultSet_IndexCreated(result_set, INDEX_OK);
			}
		}
	}

	// disable index if it was created
	// we don't call Index_Disable within Schema_AddIndex as multiple
	// field additions are still considered a "single" modification
	// of the index
	if(index_changed) {
		Index_Disable(*idx);
	} else {
		if(should_reply) {
			// update result-set
			ResultSet_IndexCreated(result_set, INDEX_FAIL);
		}
	}

	return index_changed;
}

// create a full text index for the given label and attribute