这里我使用elasticsearch官方给的go语言包（[go-elasticsearch](https://github.com/elastic/go-elasticsearch)）
go-elasticsearch向前兼容，这意味着客户端支持与更大或同等次要版本的 Elasticsearch 通信。Elasticsearch 语言客户端仅向后兼容默认发行版，不提供任何保证。
- 包：https://github.com/elastic/go-elasticsearch
- Elasticsearch 权威指南：https://www.elastic.co/guide/cn/elasticsearch/guide/current/index.html
### 环境介绍：
版本
Elasticsearch:v7.15
### 安装
go.mod 文件中添加
```
require github.com/elastic/go-elasticsearch/v8 main
```
或者
````
git clone --branch main https://github.com/elastic/go-elasticsearch.git $GOPATH/src/github.com/elastic/go-elasticsearch
````
### 示例：
新建 es.go 存入 es目录
````
package es
import (
"bytes"
"context"
"encoding/json"
"fmt"
"github.com/elastic/go-elasticsearch/v8"
"github.com/elastic/go-elasticsearch/v8/esapi"
"log"
"net/http"
)
var EsClient *elasticsearch.Client
func init() {
cfg := elasticsearch.Config{
Addresses: []string{
"http://localhost:9200",
},
}
var err erro
EsClient, err = elasticsearch.NewClient(cfg)
if err != nil {
log.Fatalln("Failed to connect to es")
}
}
func failOnError(err error, msg string) {
if err != nil {
log.Fatalf("%s: %s", msg, err)
}
}
// idx 为空，默认随机唯一字符串
func Index(index, idx string, doc map[string]interface{}) {
//index:="my_index_name_v1"
res, err := EsClient.Info()
fmt.Println(res, err)
if err != nil {
log.Fatalf("Error getting response: %s", err)
}
var buf bytes.Buffe
//doc := map[string]interface{}{
// "title": "中国",
// "content": "中国早日统一台湾",
// "time": time.Now().Unix(),
// "date": time.Now(),
//}
if err = json.NewEncoder(&buf).Encode(doc); err != nil {
fmt.Println(err, "Error encoding doc")
return
}
res, err = EsClient.Index(
index, // Index name
&buf, // Document body
EsClient.Index.WithDocumentID(idx), // Document ID
// Document ID
EsClient.Index.WithRefresh("true"), // Refresh
)
//res, err = EsClient.Create(index, idx, &buf)
if err != nil {
fmt.Println(err, "Error create response")
}
defer res.Body.Close()
fmt.Println(res.String())
log.Println(res)
}
//struct 类型允许使用更实际的方法，您可以在其中创建一个新结构，将请求配置作为字段，并使用上下文和客户端作为参数调用 Do() 方法：
func IndexEspi(index, idx string, doc map[string]interface{}) {
//index:="my_index_name_v1"
res, err := EsClient.Info()
fmt.Println(res, err)
if err != nil {
log.Fatalf("Error getting response: %s", err)
}
var buf bytes.Buffe
//doc := map[string]interface{}{
// "title": "中国",
// "content": "中国早日统一台湾",
// "time": time.Now().Unix(),
// "date": time.Now(),
//}
if err = json.NewEncoder(&buf).Encode(doc); err != nil {
fmt.Println(err, "Error encoding doc")
return
}
req := esapi.IndexRequest{
Index: index, // Index name
Body: &buf, // Document body
DocumentID: idx, // Document ID
Refresh: "true", // Refresh
}
res, err = req.Do(context.Background(), EsClient)
if err != nil {
log.Fatalf("Error getting response: %s", err)
}
defer res.Body.Close()
fmt.Println(res.String())
log.Println(res)
}
func Search(index string, query map[string]interface{}) {
res, err := EsClient.Info()
if err != nil {
fmt.Println(err, "Error getting response")
}
//fmt.Println(res.String())
// search - highlight
var buf bytes.Buffe
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "match": map[string]interface{}{
// "title": title,
// },
// },
// "highlight": map[string]interface{}{
// "pre_tags": []string{"<font color='red'>"},
// "post_tags": []string{"</font>"},
// "fields": map[string]interface{}{
// "title": map[string]interface{}{},
// },
// },
//}
if err := json.NewEncoder(&buf).Encode(query); err != nil {
fmt.Println(err, "Error encoding query")
}
// Perform the search request.
res, err = EsClient.Search(
EsClient.Search.WithContext(context.Background()),
EsClient.Search.WithIndex(index),
EsClient.Search.WithBody(&buf),
EsClient.Search.WithTrackTotalHits(true),
EsClient.Search.WithFrom(0),
EsClient.Search.WithSize(10),
EsClient.Search.WithSort("time:desc"),
EsClient.Search.WithPretty(),
)
if err != nil {
fmt.Println(err, "Error getting response")
}
defer res.Body.Close()
fmt.Println(res.String())
}
//删除 index 根据 索引名 id
func Delete(index, idx string) {
//index:="my_index_name_v1"
res, err := EsClient.Info()
fmt.Println(res, err)
if err != nil {
log.Fatalf("Error getting response: %s", err)
}
res, err = EsClient.Delete(
index, // Index name
idx, // Document ID
EsClient.Delete.WithRefresh("true"),
)
if err != nil {
fmt.Println(err, "Error create response")
}
defer res.Body.Close()
fmt.Println(res.String())
log.Println(res)
}
func DeleteByQuery(index []string, query map[string]interface{}) {
res, err := EsClient.Info()
if err != nil {
fmt.Println(err, "Error getting response")
}
//fmt.Println(res.String())
// search - highlight
var buf bytes.Buffe
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "match": map[string]interface{}{
// "title": title,
// },
// },
// },
//}
if err := json.NewEncoder(&buf).Encode(query); err != nil {
fmt.Println(err, "Error encoding query")
}
// Perform the search request.
res, err = EsClient.DeleteByQuery(
index,
&buf,
)
if err != nil {
fmt.Println(err, "Error getting response")
}
defer res.Body.Close()
fmt.Println(res.String())
}
func SearchEsapiSql(query map[string]interface{}) {
jsonBody, _ := json.Marshal(query)
req := esapi.SQLQueryRequest{Body: bytes.NewReader(jsonBody)}
res, _ := req.Do(context.Background(), EsClient)
defer res.Body.Close()
fmt.Println(res.String())
}
func SearchHttp(method, url string, query map[string]interface{}) {
jsonBody, _ := json.Marshal(query)
req, _ := http.NewRequest(method, url, bytes.NewReader(jsonBody))
req.Header.Add("Content-type", "application/json")
res, err := EsClient.Perform(req)
if err != nil {
return
}
defer res.Body.Close()
buf := new(bytes.Buffer)
buf.ReadFrom(res.Body)
fmt.Println(buf.String())
}
````
新建 main.go
````
package main
import "demo/es"
func main() {
index := "my_index_name_v4"
//创建索引并设置映射
//query := map[string]interface{}{
// "mappings": map[string]interface{}{
// "properties": map[string]interface{}{
// "title": map[string]interface{}{
// "type": "text",
// },
// "content": map[string]interface{}{
// "type": "text",
// },
// "location": map[string]interface{}{
// "type": "geo_point",
// },
// "time": map[string]interface{}{
// "type": "long",
// },
// "date": map[string]interface{}{
// "type": "date",
// },
// "age": map[string]interface{}{
// "type": "keyword",
// },
// },
// },
//}
//url := index
//注意 映射信息不能更新
//es.SearchHttp("PUT", url, query)
//添加或修改文档，没有索引创建
//doc := map[string]interface{}{
// "title": "你好",
// "content": "中国美丽的城市",
// "location": "41.015, -75.011",
// "time": time.Now().Unix(),
// "date": time.Now(),
// "age": 20,
//}
//es.Index(index, "", doc)
//es.IndexEspi(index, "idx5", doc)
//删除索引
//es.Delete(index, "idx3")
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "match": map[string]interface{}{
// "title": "vvvvv我爱你！!!!",
// },
// },
//}
//indexArr := []string{index}
//es.DeleteByQuery(indexArr, query)
////搜索单个字段
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "match": map[string]interface{}{
// "title": "我爱你中国",
// },
// },
// "highlight": map[string]interface{}{
// "pre_tags": []string{"<font color='red'>"},
// "post_tags": []string{"</font>"},
// "fields": map[string]interface{}{
// "title": map[string]interface{}{},
// },
// },
//}
//搜索多个字段
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "multi_match": map[string]interface{}{
// "query": "中国",
// "fields": []string{"title", "content"},
// },
// },
// "highlight": map[string]interface{}{
// "pre_tags": []string{"<font color='red'>"},
// "post_tags": []string{"</font>"},
// "fields": map[string]interface{}{
// "title": map[string]interface{}{},
// },
// },
//}
//提高某个字段权重，可以使用 ^ 字符语法为单个字段提升权重，在字段名称的末尾添加 ^boost ，其中 boost 是一个浮点数：
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "multi_match": map[string]interface{}{
// "query": "中国",
// "fields": []string{"title", "content^2"},
// },
// },
// "highlight": map[string]interface{}{
// "pre_tags": []string{"<font color='red'>"},
// "post_tags": []string{"</font>"},
// "fields": map[string]interface{}{
// "title": map[string]interface{}{},
// },
// },
//}
//显示所有的
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "match_all": map[string]interface{}{},
// },
//}
//es.Search(index, query)
//地理距离过滤器（ geo_distance ）以给定位置为圆心画一个圆，来找出那些地理坐标落在其中的文档：
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "bool": map[string]interface{}{
// "must": map[string]interface{}{
// "match_all": map[string]interface{}{}, // 这里不设置其他查询条件，所以匹配全部文档
// },
// "filter": map[string]interface{}{
// "geo_distance": map[string]interface{}{
// "distance": "100km",
// "location": map[string]interface{}{
// "lat": 40.715,
// "lon": -73.988,
// },
// }},
// },
// },
// "sort": map[string]interface{}{ // 设置排序条件
// "_geo_distance": map[string]interface{}{ //_geo_distance代表根据距离排序
// "location": map[string]interface{}{ //根据location存储的经纬度计算距离。
// "lat": 40.715, //当前纬度
// "lon": -73.988, //当前经度
// },
// "order": "asc", // asc 表示升序，desc 表示降序
// }},
//}
//es.Search(index, query)
//精确值查询
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "match": map[string]interface{}{
// "age": "20",
// },
// },
//}
//es.Search(index, query)
//范围查询
//通过range实现范围查询，类似SQL语句中的>, >=, <, <=表达式。
//gte范围参数 - 等价于>=
//lte范围参数 - 等价于 <=
//范围参数可以只写一个，例如：仅保留 "gte": 10， 则代表 FIELD字段 >= 10
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "range": map[string]interface{}{
// "age": map[string]interface{}{
// "gte": "19",
// "lte": "20",
// },
// },
// },
//}
//es.Search(index, query)
//组合查询 如果需要编写类似SQL的Where语句，组合多个字段的查询条件，可以使用bool语句。
//"must": [], // must条件，类似SQL中的and, 代表必须匹配条件
//"must_not": [], // must_not条件，跟must相反，必须不匹配条件
//"should": [] // should条件，类似SQL中or, 代表匹配其中一个条件
query := map[string]interface{}{
"query": map[string]interface{}{
"bool": map[string]interface{}{
"must": []map[string]interface{}{
{
"match": map[string]interface{}{
"age": "19",
},
},
{
"match": map[string]interface{}{
"title": "中国",
},
},
},
},
},
}
es.Search(index, query)
//使用mysql的方式来请求
//query := map[string]interface{}{
// "query": "select title from " index " where title like '%中国%'", //这里使用mysql的方式来请求，非常简单，符合开发习惯，简化es入门门槛，支持order，支持Limit，那么排序和分页就自己写好了
//}
//query := map[string]interface{}{
// "query": "select title from " index " where title = '中国'", //这里使用mysql的方式来请求，非常简单，符合开发习惯，简化es入门门槛，支持order，支持Limit，那么排序和分页就自己写好了
//}
//es.SearchEsapiSql(query)
//测试分词
//query := map[string]interface{}{
// "analyzer": "ik_smart", //智能分词用：ik_smart，最大化分词用：ik_max_word
// "text": "中国华人民",
//}
//url := index "_analyze?pretty=true"
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "match": map[string]interface{}{
// "title": "我爱你中国",
// },
// },
// "highlight": map[string]interface{}{
// "pre_tags": []string{"<font color='red'>"},
// "post_tags": []string{"</font>"},
// "fields": map[string]interface{}{
// "title": map[string]interface{}{},
// },
// },
//}
//url := index "/_search"
//es.SearchHttp("GET", url, query)
}
````
### 参考资料
https://github.com/elastic/go-elasticsearch
https://www.tizi365.com/archives/590.html
https://www.elastic.co/guide/cn/elasticsearch/guide/current/_creating_an_index.html
## links
- [目录](https://github.com/guyan0319/golang_development_notes/blob/master/zh/preface.md)
- 上一节：
- 下一节：
