在这里记录一下Golang操作elastic的应用形式,本文应用的是第三方包github.com/olivere/elastic的v7版本。
1.准确匹配单个字段
应用term查问,
package mainimport ( "context" "fmt" "github.com/olivere/elastic/v7" "log" "os" "reflect" "time")type Article struct { Title string // 文章题目 Content string // 文章内容 Author string // 作者 Created time.Time // 公布工夫}func main() { // 创立Client, 连贯ES client, err := elastic.NewClient( // elasticsearch 服务地址,多个服务地址应用逗号分隔 elastic.SetURL("http://127.0.0.1:9200", "http://127.0.0.1:9201"), // 基于http base auth验证机制的账号和明码 elastic.SetBasicAuth("user", "secret"), // 启用gzip压缩 elastic.SetGzip(true), // 设置监控查看工夫距离 elastic.SetHealthcheckInterval(10*time.Second), // 设置申请失败最大重试次数 elastic.SetMaxRetries(5), // 设置谬误日志输入 elastic.SetErrorLog(log.New(os.Stderr, "ELASTIC ", log.LstdFlags)), // 设置info日志输入 elastic.SetInfoLog(log.New(os.Stdout, "", log.LstdFlags))) if err != nil { // Handle error fmt.Printf("连贯失败: %v\n", err) } else { fmt.Println("连贯胜利") } // 执行ES申请须要提供一个上下文对象 ctx := context.Background() // 创立term查问条件,用于准确查问 termQuery := elastic.NewTermQuery("Author", "tizi") searchResult, err := client.Search(). Index("blogs"). // 设置索引名 Query(termQuery). // 设置查问条件 Sort("Created", true). // 设置排序字段,依据Created字段升序排序,第二个参数false示意逆序 From(0). // 设置分页参数 - 起始偏移量,从第0行记录开始 Size(10). // 设置分页参数 - 每页大小 Pretty(true). // 查问后果返回可读性较好的JSON格局 Do(ctx) // 执行申请 if err != nil { // Handle error panic(err) } fmt.Printf("查问耗费工夫 %d ms, 后果总数: %d\n", searchResult.TookInMillis, searchResult.TotalHits()) if searchResult.TotalHits() > 0 { // 查问后果不为空,则遍历后果 var b1 Article // 通过Each办法,将es后果的json构造转换成struct对象 for _, item := range searchResult.Each(reflect.TypeOf(b1)) { // 转换成Article对象 if t, ok := item.(Article); ok { fmt.Println(t.Title) } } }}
后续示例只列举出外围代码,其余代码构造参考本节实现。
2.通过terms实现SQL的in查问
// 创立terms查问条件termsQuery := elastic.NewTermsQuery("Author", "tizi", "tizi365")searchResult, err := client.Search(). Index("blogs"). // 设置索引名 Query(termsQuery). // 设置查问条件 Sort("Created", true). // 设置排序字段,依据Created字段升序排序,第二个参数false示意逆序 From(0). // 设置分页参数 - 起始偏移量,从第0行记录开始 Size(10). // 设置分页参数 - 每页大小 Do(ctx) // 执行申请
3.匹配单个字段
某个字段应用全文搜寻
// 创立match查问条件matchQuery := elastic.NewMatchQuery("Title", "golang es教程")searchResult, err := client.Search(). Index("blogs"). // 设置索引名 Query(matchQuery). // 设置查问条件 Sort("Created", true). // 设置排序字段,依据Created字段升序排序,第二个参数false示意逆序 From(0). // 设置分页参数 - 起始偏移量,从第0行记录开始 Size(10). // 设置分页参数 - 每页大小 Do(ctx)
4.范畴查问
实现相似Created > '2020-07-20' and Created < '2020-07-22'的范畴查问条件// 例1 等价表达式:Created > "2020-07-20" and Created < "2020-07-29"rangeQuery := elastic.NewRangeQuery("Created"). Gt("2020-07-20"). Lt("2020-07-29")// 例2 等价表达式:id >= 1 and id < 10rangeQuery := elastic.NewRangeQuery("id"). Gte(1). Lte(10)
5.bool组合查问
bool的性能相似于Sql中的and和or,将查问条件组合起来。
5.1. must条件
must相似sql中的and性能,
// 创立bool查问
boolQuery := elastic.NewBoolQuery().Must()
// 创立term查问termQuery := elastic.NewTermQuery("Author", "tizi")matchQuery := elastic.NewMatchQuery("Title", "golang es教程")// 设置bool查问的must条件, 组合了两个子查问// 示意搜寻匹配Author=tizi且Title匹配"golang es教程"的文档boolQuery.Must(termQuery, matchQuery)searchResult, err := client.Search(). Index("blogs"). // 设置索引名 Query(boolQuery). // 设置查问条件 Sort("Created", true). // 设置排序字段,依据Created字段升序排序,第二个参数false示意逆序 From(0). // 设置分页参数 - 起始偏移量,从第0行记录开始 Size(10). // 设置分页参数 - 每页大小 Do(ctx) // 执行申请
5.2. must_not条件
跟must的作用相同,用法和must相似
// 创立bool查问boolQuery := elastic.NewBoolQuery().Must()// 创立term查问termQuery := elastic.NewTermQuery("Author", "tizi")// 设置bool查问的must not条件boolQuery.MustNot(termQuery)
5.3. should条件
相似SQL中的 or, 只有匹配其中一个条件即可。
// 创立bool查问boolQuery := elastic.NewBoolQuery().Must()// 创立term查问termQuery := elastic.NewTermQuery("Author", "tizi")matchQuery := elastic.NewMatchQuery("Title", "golang es教程")// 设置bool查问的should条件, 组合了两个子查问// 示意搜寻Author=tizi或者Title匹配"golang es教程"的文档boolQuery.Should(termQuery, matchQuery)
以上,应用简明扼要的形式来阐明在Go语言中应用ES查问的形式,包含准确查问,全文索引,范畴查问,组合查问等,心愿可能对大家有用。
转自:
juejin.cn/post/6978782173306290184
关注 获取更多好文
本文由mdnice多平台公布