ES---golang

ElasticSearch是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。

1.查询DSL（query DSL）和过滤DSL（filter DSL）

package elastic

import (

"boss/base"

"boss/models"

"context"

"fmt"

"gopkg.in/olivere/elastic.v5"

"log"

"os"

"reflect"

"strconv"

"strings"

)

var client *elastic.Client

var host = "http://127.0.0.1:9200/"

//初始化

func init() {

errorlog := log.New(os.Stdout, "APP", log.LstdFlags)

var err error

client, err = elastic.NewClient(elastic.SetErrorLog(errorlog), elastic.SetURL(host))

if err != nil {

base.LOG_INFO("client err:", err)

panic(err)

}

info, code, err := client.Ping(host).Do(context.Background())

if err != nil {

base.LOG_INFO("client err:", err)

panic(err)

}

base.LOG_INFO("client:", code, info.Version.Number)

//本地测试使用

create()

}

//创建

func create() {

var dao models.DetailDao

//获取除电台外数据

maps_ic := dao.GetCMSAudioAllExcept4()

if maps_ic != nil {

maps := maps_ic.(*models.MapsModel)

//base.LOG_INFO("maps:", *maps)

content_index := 0

for index := int64(0); index < maps.Counts; index++ {

gcontent := new(CmsAudiosets)

gcontent.Name = maps.GetString("id", index)

gcontent.Cid = maps.GetInt64("cid", index)

gcontent.Type = 4

gcontent.ImgUrl = maps.GetString("imgurl", index)

gcontent.LogoImg = maps.GetString("logoimg", index)

gcontent.Frequency = maps.GetString("frequency", index)

content_index++

put1, err := client.Index().Index("cmsaudio").Type("cmsaudiosets").

Id(strconv.Itoa(content_index)).BodyJson(gcontent).Do(context.Background())

if err != nil {

panic(err)

}

fmt.Printf("Indexed tweet %s to index s%s, type %s\n", put1.Id, put1.Index, put1.Type)

}

}

}

//搜索联想词4028

func AssociatWord(keyword string) ([]DetailAssociateContent, int, error) {

var res *elastic.SearchResult

var err error

//取所有 TODO context时间

res, err = client.Search("cmsaudio").Type("cmsaudiosets").Do(context.Background())

boolSearch := elastic.NewBoolQuery().Filter(elastic.NewQueryStringQuery(keyword))

res, err = client.Search("cmsaudio").Type("cmsaudiosets").Query(boolSearch).Do(context.Background())

var estyp CmsAudiosets

var content = make([]DetailAssociateContent, 0)

index := 0

for _, item := range res.Each(reflect.TypeOf(estyp)) { //从搜索结果中取数据的方法

t := item.(CmsAudiosets)

if strings.Index(t.Name, keyword) != -1 {

content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.Name})

index++
        if index >= 20 {
            return content, index, err
        }
    }
    if strings.Index(t.Summary, keyword) != -1 {
        content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.Summary})
        index++
        if index >= 20 {
            return content, index, err
        }
    }
    if strings.Index(t.Frequency, keyword) != -1 {
        content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.Frequency})
        index++
        if index >= 20 {
            return content, index, err
        }
    }
    if strings.Index(t.PublishName, keyword) != -1 {
        content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.PublishName})

        index++
        if index >= 20 {
            return content, index, err
        }
    }
    if strings.Index(t.AuthorName, keyword) != -1 {
        content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.AuthorName})
        index++
        if index >= 20 {
            return content, index, err
        }
    }
    if strings.Index(t.Detail, keyword) != -1 {
        content = append(content, DetailAssociateContent{Id: strconv.Itoa(index), Name: t.Detail})
        index++
        if index >= 20 {
            return content, index, err
        }
    }
}
return content, index, err

}

func EsSearch(keyword string, typ string) ([]DetailSearchContent, int, error) {

var res *elastic.SearchResult

var content = make([]DetailSearchContent, 0)

index := 0

var estyp CmsAudiosets

var err error

//取所有

res, err = client.Search("cmsaudio").Type("cmsaudiosets").Do(context.Background())

if typ == "0" {

boolSearch := elastic.NewBoolQuery().Filter(elastic.NewQueryStringQuery(keyword))

res, err = client.Search("cmsaudio").Type("cmsaudiosets").Query(boolSearch).Do(context.Background())

} else {

typint, er := strconv.Atoi(typ)

if er != nil {

return content, index, err

}

boolSearch := elastic.NewBoolQuery().Filter(elastic.NewQueryStringQuery(keyword)).Filter(elastic.NewTermQuery("type", typint))

res, err = client.Search("cmsaudio").Type("cmsaudiosets").Query(boolSearch).Do(context.Background())

}

for _, item := range res.Each(reflect.TypeOf(estyp)) {

t := item.(CmsAudiosets)

content = append(content, DetailSearchContent{

Name: t.Name,

Summary: t.Summary,

Cid: t.Cid,

Type: t.Type,

ImgUrl: t.ImgUrl,

Frequency: t.Frequency,

LogoImg: t.LogoImg,

})

if index >= 20 {

return content, index, err

}

index++

}

return content, index, err

}