()
| 1468 | } |
| 1469 | |
| 1470 | func (qc *AQLQueryContext) initializeNonAggResponse() { |
| 1471 | if qc.IsNonAggregationQuery { |
| 1472 | headers := make([]string, len(qc.Query.Dimensions)) |
| 1473 | for i, dim := range qc.Query.Dimensions { |
| 1474 | headers[i] = dim.Expr |
| 1475 | } |
| 1476 | if qc.ResponseWriter != nil { |
| 1477 | if !qc.DataOnly { |
| 1478 | headersBytes, _ := json.Marshal(headers) |
| 1479 | qc.ResponseWriter.Write([]byte(`{"results":[{"headers":`)) |
| 1480 | qc.ResponseWriter.Write(headersBytes) |
| 1481 | qc.ResponseWriter.Write([]byte(`,"matrixData":[`)) |
| 1482 | } |
| 1483 | } else { |
| 1484 | // non eager flush |
| 1485 | qc.Results = make(queryCom.AQLQueryResult) |
| 1486 | qc.Results.SetHeaders(headers) |
| 1487 | } |
| 1488 | } |
| 1489 | } |
no test coverage detected