elasticsearch3中golang怎么用

這篇文章主要介紹elasticsearch3中golang怎么用，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

package main

import (
	"context"
	"fmt"
	"github.com/olivere/elastic"
	"reflect"
	"time"
)

var (
	esUrl = "http://s100:9200"
	ctx   = context.Background()
)

type User struct {
	Name string `json:"name"`
	Age  int    `json:"age"`
}

func main() {
	// 鏈接服務器
	client, err := elastic.NewClient(
		elastic.SetSniff(false),
		elastic.SetURL(esUrl),
		elastic.SetHealthcheckInterval(10*time.Second),
		elastic.SetMaxRetries(5),
	)
	if err != nil {
		panic(err.Error())
	}

	// 獲取基本信息
	info, code, err := client.Ping(esUrl).Do(ctx)
	if err != nil {
		panic(err.Error())
	}
	fmt.Println(">>es-info>>", info.Version.Number, code)

	client.Delete().Index("user")

	// 是否存在索引
	exists, err := client.IndexExists("user").Do(ctx)
	if err != nil {
		panic(err.Error())
	}
	fmt.Println(">>index-exists>>", exists)

	// 創建索引
	if !exists {
		rst, err := client.CreateIndex("user").Do(ctx)
		if err != nil {
			panic(err.Error())
		}
		fmt.Println(">>index-index>>", rst.Index)
	}

	// 批量添加
	for i := 1; i <= 3; i++ {
		id := fmt.Sprintf("%d", i)
		rsp, err := client.Index().
			Index("user").
			Id(id).
			BodyJson(&User{Name: fmt.Sprintf("name%d", i), Age: i}).
			Do(ctx)
		if err != nil {
			panic(err.Error())
		}
		fmt.Println(">>doc-create>>", "id:", rsp.Id, "index:", rsp.Index, "type:", rsp.Type, "seqno:",
			rsp.SeqNo, "result:", rsp.Result, "status:", rsp.Status)
	}

	// 修改
	rsp, err := client.Update().Index("user").Id("1").Doc(&User{Name: "name100", Age: 100}).Do(ctx)
	if err != nil {
		panic(err.Error())
	}
	fmt.Println(">>doc-update>>", rsp)

	// 刪除
	rsp2, err2 := client.Delete().Index("user").Id("2").Do(ctx)
	if err2 != nil {
		panic(err2.Error())
	}
	fmt.Println(">>doc-delete>>", rsp2)

	// 查詢所有
	rst, err := client.Search().Index("user").Do(ctx)
	if err != nil {
		panic(err.Error())
	}
	for _, u := range rst.Each(reflect.TypeOf(User{})) {
		fmt.Println(">>search-all>>", u.(User).Name, u.(User).Age)
	}

	// 查詢條件 - 相等
	q := elastic.NewQueryStringQuery("name:name1")
	rst, err = client.Search().Index("user").Query(q).Do(ctx)
	if err != nil {
		panic(err.Error())
	}
	for _, u := range rst.Each(reflect.TypeOf(User{})) {
		fmt.Println(">>search-eq>>", u.(User).Name, u.(User).Age)
	}

	// // 查詢條件 - 大于 - 分頁
	q2 := elastic.NewBoolQuery()
	q2.Must(elastic.NewRangeQuery("age").Gt(3))
	rst, err = client.Search().
		Index("user").
		Size(2).
		From(1).
		Sort("age", false).
		Query(q2).
		Do(ctx)
	if err != nil {
		panic(err.Error())
	}
	for _, u := range rst.Each(reflect.TypeOf(User{})) {
		fmt.Println(">>search-eq2>>", u.(User).Name, u.(User).Age)
	}
}

以上是“elasticsearch3中golang怎么用”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！