Skip to content

Commit a948dfe

Browse files
committed
fix(influxdb): fixes broken raw query usage
1 parent 9f7d086 commit a948dfe

File tree

4 files changed

+5
-1
lines changed

4 files changed

+5
-1
lines changed

pkg/tsdb/influxdb/model_parser.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ type InfluxdbQueryParser struct{}
1212
func (qp *InfluxdbQueryParser) Parse(model *simplejson.Json, dsInfo *tsdb.DataSourceInfo) (*Query, error) {
1313
policy := model.Get("policy").MustString("default")
1414
rawQuery := model.Get("query").MustString("")
15+
useRawQuery := model.Get("rawQuery").MustBool(false)
1516
alias := model.Get("alias").MustString("")
1617

1718
measurement := model.Get("measurement").MustString("")
@@ -54,6 +55,7 @@ func (qp *InfluxdbQueryParser) Parse(model *simplejson.Json, dsInfo *tsdb.DataSo
5455
RawQuery: rawQuery,
5556
Interval: interval,
5657
Alias: alias,
58+
UseRawQuery: useRawQuery,
5759
}, nil
5860
}
5961

pkg/tsdb/influxdb/models.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ type Query struct {
88
GroupBy []*QueryPart
99
Selects []*Select
1010
RawQuery string
11+
UseRawQuery bool
1112
Alias string
1213

1314
Interval string

pkg/tsdb/influxdb/query_builder.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ var (
1717
type QueryBuilder struct{}
1818

1919
func (qb *QueryBuilder) Build(query *Query, queryContext *tsdb.QueryContext) (string, error) {
20-
if query.RawQuery != "" {
20+
if query.UseRawQuery && query.RawQuery != "" {
2121
q := query.RawQuery
2222

2323
q = strings.Replace(q, "$timeFilter", qb.renderTimeFilter(query, queryContext), 1)

pkg/tsdb/influxdb/query_builder_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,7 @@ func TestInfluxdbQueryBuilder(t *testing.T) {
7979
GroupBy: []*QueryPart{groupBy1, groupBy3},
8080
Interval: "10s",
8181
RawQuery: "Raw query",
82+
UseRawQuery: true,
8283
}
8384

8485
rawQuery, err := builder.Build(query, queryContext)

0 commit comments

Comments
 (0)