使用Golang连接Elasticsearch数据库可以使用第三方库，如olivere/elastic。
首先需要安装该库：
go get github.com/olivere/elastic
然后在代码中引入该库：
import ("context""fmt""github.com/olivere/elastic/v7")
接下来就可以进行增删改查操作了。
连接数据库
ctx := context.Background()client, err := elastic.NewClient(elastic.SetURL("http://localhost:9200"))if err != nil {panic(err)}
插入数据
type User struct {Name string `json:"name"`Age int `json:"age"`}user := User{Name: "John", Age: 30}_, err = client.Index().Index("users").BodyJson(user).Do(ctx)if err != nil {panic(err)}
查询数据
查询所有数据
res, err := client.Search().Index("users").Query(elastic.MatchAllQuery{}).Do(ctx)if err != nil {panic(err)}var users []Userfor _, hit := range res.Hits.Hits {var user Userif err := json.Unmarshal(hit.Source, &user); err != nil {// handle error}users = append(users, user)}fmt.Printf("Found %d users\n", len(users))
根据条件查询数据
query := elastic.NewMatchQuery("name", "John")res, err := client.Search().Index("users").Query(query).Do(ctx)if err != nil {panic(err)}var users []Userfor _, hit := range res.Hits.Hits {var user Userif err := json.Unmarshal(hit.Source, &user); err != nil {// handle error}users = append(users, user)}fmt.Printf("Found %d users\n", len(users))
更新数据
update := elastic.NewUpdateRequest().Index("users").Id("1").Doc(map[string]interface{}{"age": 40})_, err = client.Update(update).Do(ctx)if err != nil {panic(err)}
删除数据
delete := elastic.NewDeleteRequest().Index("users").Id("1")_, err = client.Delete(delete).Do(ctx)if err != nil {panic(err)}
