Method HandleSQL

api/sql_query_handler.go:39–82

HandleSQL swagger:route POST /query/sql querySQL query in SQL Consumes: - application/json - application/hll Produces: - application/json Responses: default: errorResponse 200: aqlResponse 400: aqlResponse

(w http.ResponseWriter, r *http.Request)

//        200: aqlResponse
//        400: aqlResponse
func (handler *QueryHandler) HandleSQL(w http.ResponseWriter, r *http.Request) {
	sqlRequest := common.SQLRequest{Device: -1}

	if err := common.ReadRequest(r, &sqlRequest); err != nil {
		common.RespondWithBadRequest(w, err)
		utils.GetLogger().With(
			"error", err,
			"statusCode", http.StatusBadRequest,
		).Error("failed to parse query")
		return
	}

	var aqlQueries []queryCom.AQLQuery
	if sqlRequest.Body.Queries != nil {
		aqlQueries = make([]queryCom.AQLQuery, len(sqlRequest.Body.Queries))
		startTs := utils.Now()
		for i, sqlQuery := range sqlRequest.Body.Queries {
			parsedAQLQuery, err := sql.Parse(sqlQuery, utils.GetLogger())
			if err != nil {
				common.RespondWithBadRequest(w, err)
				return
			}
			aqlQueries[i] = *parsedAQLQuery
		}
		sqlParseTimer := utils.GetRootReporter().GetTimer(utils.QuerySQLParsingLatency)
		duration := utils.Now().Sub(startTs)
		sqlParseTimer.Record(duration)

	}

	aqlRequest := common.AQLRequest{
		Device:                sqlRequest.Device,
		Verbose:               sqlRequest.Verbose + sqlRequest.Debug,
		Debug:                 sqlRequest.Debug,
		Profiling:             sqlRequest.Profiling,
		DeviceChoosingTimeout: sqlRequest.DeviceChoosingTimeout,
		Accept:                sqlRequest.Accept,
		Origin:                sqlRequest.Origin,
		Body: queryCom.AQLRequest{
			Queries: aqlQueries,
		},
	}
	handler.handleAQLInternal(aqlRequest, w, r)
}