這篇文章主要介紹elasticsearch3中g(shù)olang怎么用，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！

成都創(chuàng)新互聯(lián)主營牙克石網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營網(wǎng)站建設(shè)方案,重慶APP開發(fā),牙克石h5微信小程序定制開發(fā)搭建,牙克石網(wǎng)站營銷推廣歡迎牙克石等地區(qū)企業(yè)咨詢

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() {
	// 鏈接服務(wù)器
	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)

	// 創(chuàng)建索引
	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中g(shù)olang怎么用”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對(duì)大家有幫助，更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

文章標(biāo)題：elasticsearch3中g(shù)olang怎么用
網(wǎng)頁地址：http://chinadenli.net/article16/ipjhgg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供企業(yè)建站、全網(wǎng)營銷推廣、外貿(mào)建站、手機(jī)網(wǎng)站建設(shè)、網(wǎng)站內(nèi)鏈、品牌網(wǎng)站設(shè)計(jì)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)