阅读量:5
在Go中操作Elasticsearch进行查询,需要使用Elasticsearch的官方Go客户端库。以下是一个简单的示例,演示如何使用Go发送查询请求到Elasticsearch并获取结果:
package main import ( "context" "fmt" "log" "strings" "github.com/olivere/elastic" ) func main() { // 创建一个Elasticsearch客户端连接 client, err := elastic.NewClient(elastic.SetURL("http://localhost:9200")) if err != nil { log.Fatal(err) } // 构建查询条件 query := elastic.NewBoolQuery(). Must(elastic.NewMatchQuery("title", "go")). Filter(elastic.NewRangeQuery("year").Gte(2010)) // 执行查询请求 searchResult, err := client.Search(). Index("books"). Query(query). Do(context.Background()) if err != nil { log.Fatal(err) } // 遍历查询结果 for _, hit := range searchResult.Hits.Hits { fmt.Printf("ID: %s, Score: %f\n", hit.Id, hit.Score) } // 输出查询结果的总数 fmt.Printf("Total hits: %d\n", searchResult.Hits.TotalHits.Value) }
在这个示例中,我们首先创建一个Elasticsearch客户端连接,并指定Elasticsearch的URL。然后,我们构建一个查询条件,使用elastic.NewBoolQuery()
创建一个布尔查询对象,并使用Must()
和Filter()
方法添加查询条件。在这个示例中,我们使用MatchQuery
查询标题中包含"go"的文档,并使用RangeQuery
查询年份大于等于2010的文档。
接下来,我们使用client.Search()
方法执行查询请求,并指定索引名称为"books"。然后,使用Do()
方法发送请求并获取查询结果。
最后,我们遍历查询结果,并打印每个结果的ID和得分。同时,我们还打印出查询结果的总数。
请注意,这只是一个简单的示例,实际使用中可能需要根据具体需求进行更复杂的查询。你可以根据Elasticsearch的查询DSL文档,使用不同的查询构造器来构建更复杂的查询条件。