Function ExecutionCtx_FromQuery

src/commands/execution_ctx.c:97–201

returns the objects and information required for query execution if the query contains error, a ExecutionCtx struct with the AST and Execution plan objects will be NULL and EXECUTION_TYPE_INVALID is returned returns ExecutionCtx populated with the current execution relevant objects

// and EXECUTION_TYPE_INVALID is returned
// returns ExecutionCtx populated with the current execution relevant objects
ExecutionCtx *ExecutionCtx_FromQuery
(
	const char *q  // string representing the query
) {
	ASSERT(q != NULL);

	ExecutionCtx *ret;
	const char *q_str;  // query string excluding query parameters

	if(unlikely(strlen(q) == 0)) {
		ErrorCtx_SetError("Error: empty query.");
		return NULL;
	}

	// parse and validate parameters only
	// extract query string
	// return invalid execution context if failed to parse params
	cypher_parse_result_t *params_parse_result = parse_params(q, &q_str);

	// parameter parsing failed, return NULL
	if(params_parse_result == NULL) {
		return NULL;
	}

	// seems like we should be able to free 'params_parse_result'
	// at this point but this messes up the parsing of the actual query

	// query included only params e.g. 'cypher a=1' was provided
	if(unlikely(strlen(q_str) == 0)) {
		parse_result_free(params_parse_result);
		ErrorCtx_SetError("Error: empty query.");
		return NULL;
	}

	// update query context with the query without params
	// (here the QueryInfo is created as well, starting the stage timer)
	QueryCtx *ctx = QueryCtx_GetQueryCtx();
	ctx->query_data.query_no_params = q_str;

	// get cache
	Cache *cache = GraphContext_GetCache(QueryCtx_GetGraphCtx());

	// see if we already have a cached execution-ctx for given query
	ret = Cache_GetValue(cache, q_str);

	//--------------------------------------------------------------------------
	// cache hit
	//--------------------------------------------------------------------------

	if(ret != NULL) {
		parse_result_free(params_parse_result);  // free parsed params
		ret->cached = true;                      // mark cached execution
		return ret;
	}

	//--------------------------------------------------------------------------
	// cache miss
	//--------------------------------------------------------------------------