Merge pull request #57 from quickwit-oss/ddelemeny-default-and

Use AND as default operator, fixes #54

Author: ddelemeny

pkg/quickwit/client/models.go

@@ -102,14 +102,16 @@ type QueryStringFilter struct {
 	Filter
 	Query           string
 	AnalyzeWildcard bool
+	DefaultOperator string
 }
 
 // MarshalJSON returns the JSON encoding of the query string filter.
 func (f *QueryStringFilter) MarshalJSON() ([]byte, error) {
 	// FIXME: readd analyze_wildcard when quickwit supports it.
 	root := map[string]interface{}{
 		"query_string": map[string]interface{}{
-			"query": f.Query,
+			"query":            f.Query,
+			"default_operator": f.DefaultOperator,
 			//			"analyze_wildcard": f.AnalyzeWildcard,
 		},
 	}

pkg/quickwit/client/search_request.go

@@ -257,14 +257,15 @@ func (b *FilterQueryBuilder) AddDateRangeFilter(timeField string, lteMillisecs i
 }
 
 // AddQueryStringFilter adds a new query string filter
-func (b *FilterQueryBuilder) AddQueryStringFilter(querystring string, analyseWildcard bool) *FilterQueryBuilder {
+func (b *FilterQueryBuilder) AddQueryStringFilter(querystring string, analyseWildcard bool, defaultOperator string) *FilterQueryBuilder {
 	if len(strings.TrimSpace(querystring)) == 0 {
 		return b
 	}
 
 	b.filters = append(b.filters, &QueryStringFilter{
 		Query:           querystring,
 		AnalyzeWildcard: analyseWildcard,
+		DefaultOperator: defaultOperator,
 	})
 	return b
 }

pkg/quickwit/client/search_request_test.go

@@ -48,7 +48,7 @@ func TestSearchRequest(t *testing.T) {
 		b.Sort(SortOrderDesc, timeField, "epoch_nanos_int")
 		filters := b.Query().Bool().Filter()
 		filters.AddDateRangeFilter(timeField, 1684398201000, 1684308201000)
-		filters.AddQueryStringFilter("test", true)
+		filters.AddQueryStringFilter("test", true, "AND")
 
 		t.Run("When building search request", func(t *testing.T) {
 			sr, err := b.Build()

pkg/quickwit/data_query.go

@@ -91,7 +91,7 @@ func (e *elasticsearchDataQuery) processQuery(q *Query, ms *es.MultiSearchReques
 	b.Size(0)
 	filters := b.Query().Bool().Filter()
 	filters.AddDateRangeFilter(defaultTimeField, to, from)
-	filters.AddQueryStringFilter(q.RawQuery, true)
+	filters.AddQueryStringFilter(q.RawQuery, true, "AND")
 
 	if isLogsQuery(q) {
 		processLogsQuery(q, b, from, to, defaultTimeField)