一、ElasticSearch连接

1、引入"github.com/olivere/elastic/v7"包

2、连接

client,err :=elastic.NewClient(elastic.SetSniff(false),elastic.SetURL(“服务器地址”),elastic.SetBasicAuth("账号", "密码"))

二、日志上传

1、单条记录上传

_, err :=conn.GetESClient().Index().

Index(index).// 设置索引名称，索引必须为小写字母数字下划线等组成，不得包含大小字母

  Id(guid).// 设置文档id，此处id最好为小写字母或数字组成，否则日志虽然插入或查询可行，但是刷新字段时无效

  BodyJson(json).// 指定内容

  Do(c)// 执行请求，需要传入一个上下文对象

2、批量上传

builService :=conn.GetESClient().Bulk().Index(index)

for _, v :=range logs {

m := v.(map[string]interface{})

if m["guid"] !=nil {

id := m["id"].(string)

doc :=elastic.NewBulkIndexRequest().Id(id).Doc(v)

builService.Add(doc)

}

res, err := builService.Do(c)

三、查询

1、查询（组合）

k:查询字段，v：对应的字符串

boolQuery := elastic.NewBoolQuery().Must()

searchService :=conn.GetESClient().Search()

searchService = searchService.Index(Index).SearchType("query_then_fetch").Pretty(true)

2、分页查询

searchService.From(PageIndex * PageSize)

searchService.Size(PageSize)

3、匹配查询

querys := []elastic.Query{}

//q := elastic.NewMatchQuery(k,v)

//q := elastic.NewWildcardQuery(k,v)

//q := elastic.NewMatchPhraseQuery(k,v).Boost(0.7)

//q := elastic.NewMoreLikeThisQuery().LikeText(v).Field(k)

//q := elastic.NewTermQuery(k,v)

//有特殊字符的如，URL类型查询用此方法，不然查询不到，亲测有效

 q :=elastic.NewMatchPhrasePrefixQuery(k,v).MaxExpansions(10)

querys =append(querys,q)

//区间查询（多个）

//如果是字符串类型，字段后面需要加.keyword

k +=".keyword"

rQuery :=elastic.NewRangeQuery(k)

rQuery = rQuery.Gte(itemRange["gte"])

rQuery = rQuery.Lte(itemRange["lte"])

querys =append(querys,rQuery)

boolQuery = boolQuery.Must(querys...)

searchService = searchService.Query(boolQuery)

4、排序查询（多个）

sorters := []elastic.Sorter{}

//此处如果是字符串，后面需加.keyword

k +=".keyword"

sort :=elastic.NewFieldSort(k).Desc()

sorters =append(sorters,sort)

searchService = searchService.SortBy(sorters...)

searchResult, err := searchService.Do(c)

四、删除

1、删除索引

conn.GetESClient().DeleteIndex(indexs...).Do(c)

//删除并清空数据

delAll :=conn.GetESClient().DeleteByQuery()

delAll.Do(c)

2、删除某一条日志

deletService := conn.GetESClient().Delete().// 设置索引名

  Index(index)

deletService.Id(guid)

_,err := deletService.Do(c)

五、刷新某个字段值

//入刷新json数据中的status字段位1

script :=fmt.Sprintf("ctx._source['status']=%d",1)

es :=conn.GetESClient()

updateR, err := es.UpdateByQuery(queryIndex).

// 设置查询条件

  Query(elastic.NewTermQuery("id",id)).

//同步执行（不设置会异步执行，不能即时刷新，马上查询会没有变化）

Refresh("true").

// 通过脚本更新内容

  Script(elastic.NewScript(script)).

// 如果文档版本冲突继续执行

ProceedOnVersionConflict().Do(c)