关于 golang 中使用 ES

需要使用到的包

gopkg.in/olivere/elastic.v6
golang.org/x/elasti

创建一个接口

controllers/base.go

package controllers
import (
 "context"
 "fmt"
 "log"
 "os"
 "gopkg.in/olivere/elastic.v6"
)
var EsClient *elastic.Client
var host = "http://127.0.0.1:9200/"
func init(){
 //es 配置
 errorlog := log.New(os.Stdout, "APP", log.LstdFlags)
 var err error
 EsClient, err =elastic.NewClient(elastic.SetErrorLog(errorlog), elastic.SetURL(host))
 if err != nil {
 panic(err)
 }
 info, code, err := EsClient.Ping(host).Do(context.Background())
 if err != nil {
 panic(err)
 }
 fmt.Printf("Elasticsearch returned with code %d and version %s\n", code, info.Version.Number)
 esversion, err := EsClient.ElasticsearchVersion(host)
 if err != nil {
 panic(err)
 }
 fmt.Printf("Elasticsearch version %s\n", esversion)
}

在其他接口上调用

controllers/question.go

import (
 "context"
 "encoding/json"
 "fmt"
 "github.com/astaxie/beego"
 "github.com/astaxie/beego/orm"
 "goGame/controllers"
 "golang.org/x/elastic"
 "zhihu/models"
)
//根据id查询
type ZhiHuGetWithIdController struct{
 beego.Controller
}
func (this *ZhiHuGetWithIdController) Get(){
 get ,err:= EsClient.Get().Index("elas_ar_zhihu_article").Type("elas_ar_zhihu_article_type").Id("1").Do(context.Background())
 if err != nil {
 panic(err)
 }
 if get.Found {
 this.Data["json"] = get.Source
 this.ServeJSON()
 }
}
//根据条件查询query
type ZhiHuSearchController struct {
 beego.Controller
}
//查询 es查询
type EsItem struct {
 Id int `json:"id"`
 OrContent string `json:"or_content"`
 ArContent string `json:"ar_content"`
}
type EsData struct {
 Total int64 `json:"total"`
 Items interface{} `json:"items"`
}
type EsResult struct {
 Status string `json:"status"`
 Data EsData `json:"data"`
}
func (this *ZhiHuSearchController) Get(){
 var q ,query elastic.Query
 or_value := this.GetString("or_content")
 if or_value!=""{
 query = elastic.NewMatchPhraseQuery("or_content",or_value)
 }
 ar_value := this.GetString("ar_content")
 if ar_value !=""{
 q =elastic.NewMatchPhraseQuery("ar_content",ar_value)
 }
 res ,err:= EsClient.Search().Index("elas_ar_zhihu_article").Type("elas_ar_zhihu_article_type").Query(query).Query(q).Do(context.Background())
 if err !=nil{
 println(err.Error())
 }
 var data EsData
 if res.Hits.TotalHits>0{
 var items []interface{}
 data.Total = res.Hits.TotalHits
 for _,hit :=range res.Hits.Hits{
 var item EsItem
 err := json.Unmarshal(*hit.Source, &item) //另外一种取数据的方法
 if err !=nil{
 fmt.Print(err.Error())
 }
 items = append(items,item)
 }
 data.Items = items
 }
 var result EsResult
 result.Status = "success"
 result.Data = data
 this.Data["json"] = result
 this.ServeJSON()
}

有疑问加站长微信联系(非本文作者)

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传