关于后端:Go-操作-ElasticSearch-实战

在这里记录一下 Golang 操作 elastic 的应用形式，本文应用的是第三方包 github.com/olivere/elastic 的 v7 版本。

1. 准确匹配单个字段
应用 term 查问，

package main

import (
    "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 < 10
rangeQuery := 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 多平台公布