Function _index_operation_create

src/commands/cmd_query.c:174–239

create index structure

// create index structure
static void _index_operation_create
(
	RedisModuleCtx *ctx,
	GraphContext *gc,
	AST *ast
) {
	ASSERT(gc  != NULL);
	ASSERT(ctx != NULL);
	ASSERT(ast != NULL);

	uint nprops            = 0;            // number of fields indexed
	const char *label      = NULL;         // label being indexed
	SchemaType schema_type = SCHEMA_NODE;  // type of entities being indexed

	const cypher_astnode_t *index_op = ast->root;
	cypher_astnode_type_t t = cypher_astnode_type(index_op);

	//--------------------------------------------------------------------------
	// retrieve label and attributes from AST
	//--------------------------------------------------------------------------

	if(t == CYPHER_AST_CREATE_NODE_PROPS_INDEX) {
		// old format
		// CREATE INDEX ON :N(name)
		nprops = cypher_ast_create_node_props_index_nprops(index_op);
		label  = cypher_ast_label_get_name(
				cypher_ast_create_node_props_index_get_label(index_op));
	} else {
		// new format
		// CREATE INDEX FOR (n:N) ON n.name
		nprops = cypher_ast_create_pattern_props_index_nprops(index_op);
		label  = cypher_ast_label_get_name(
				cypher_ast_create_pattern_props_index_get_label(index_op));

		// determine if index is created over node label or edge relationship
		// default to node
		if(cypher_ast_create_pattern_props_index_pattern_is_relation(index_op)) {
			schema_type = SCHEMA_EDGE;
		}
	}

	ASSERT(nprops > 0);
	ASSERT(label != NULL);

	const char *fields[nprops];
	for(uint i = 0; i < nprops; i++) {
		const cypher_astnode_t *prop_name =
			(t == CYPHER_AST_CREATE_NODE_PROPS_INDEX) ?
			cypher_ast_create_node_props_index_get_prop_name(index_op, i) :
			cypher_ast_property_operator_get_prop_name
			(cypher_ast_create_pattern_props_index_get_property_operator(index_op, i));

		fields[i] = cypher_ast_prop_name_get_value(prop_name);
	}

	// lock
	QueryCtx_LockForCommit();