GO語言操作Elasticsearch示例分享

更新時間：2023年01月17日 08:42:26 作者：93年的老男孩

這篇文章主要介紹了GO語言操作Elasticsearch示例分享的相關資料,需要的朋友可以參考下

Elasticsearch簡介

Elasticsearch 是一個開源的搜索引擎，建立在一個全文搜索引擎庫 Apache Lucene™ 基礎之上。 Lucene 可以說是當下最先進、高性能、全功能的搜索引擎庫–無論是開源還是私有。

連接Elasticsearch

// 引入g~
~~~~~-elasticsearch
import (
    es8 "github.com/elastic/go-elasticsearch/v8"
)

// go-es配置
conf := es8.Config{
    Addresses: "http://127.0.0.1:9200",
    Username:"elastic",
    Password:"jloMQ7ZCTlcZUr_hmDoB",
}

// 創(chuàng)建
client, err := es8.NewClient(conf);
if err != nil{
    fmt.Println("=============  創(chuàng)建 elasticsearch 失敗  =============")
    return 
}

// 連接
_, err1 := client.Info()
if err1 != nil{
    fmt.Println("=============  連接 elasticsearch 失敗  =============")
    return 
}

創(chuàng)建索引

創(chuàng)建model結構體

type Admin struct{
    Id int `gorm:"<-" json:"id"` 
    UserName string `gorm:"<-" json:"user_name"` 
    RealName string `gorm:"<-" json:"real_name"` 
    Mobile string `gorm:"<-" json:"mobile"` 
}

初始化model

admin := Admin{
    Id: 1,
    UserName: "test",
    RealName: "測試",
    Mobile: "15222222222",
}

創(chuàng)建索引

// 結構體json序列化
str,err := json.Marshal(admin);
if err != nil{
    return ;
}

// 創(chuàng)建索引
res1, err1 := client.Index(
    "db.table",
    bytes.NewReader(str),
    client.Index.WithDocumentID("1"), // 索引ID
    client.Index.WithRefresh("true") //是否立即創(chuàng)建
);

搜索數(shù)據(jù)

創(chuàng)建返回結構體

type EsResponse struct{
    Hits struct{
        Total struct{
            Value int `json:"value"` 
        } `json:"total"` 
        Hits []struct{
            Index string `json:"_index"` 
            Id string `json:"_id"` 
            Score float32 `json:"_score"` 
            Source map[string]any `json:"_source"` 
        } `json:"hits"` 
    } `json:"hits"` 
}

type EsData struct{
    Total int `json:"total"` 
    List []map[string]any `json:"list"` 
}

搜索數(shù)據(jù)

query := map[string]any{
    "query":map[string]any{
        "bool":map[string]any{
            "must":[]map[string]any{
                map[string]any{
                    "match_phrase":map[string]any{
                        "user_name": "test",
                    },
                },
                map[string]any{
                    "match_phrase":map[string]any{
                        "mobile": "15222222222",
                    },
                },
            },
        },
    },
}

str,err := json.Marshal(query);
if err != nil{
    return ;
}

res1,err1 := client.Search(client.Search.WithBody(bytes.NewReader(str)));
    
if err1 != nil{
    return ;
}

解析數(shù)據(jù)

var resData EsResponse;
err2 := json.NewDecoder(res1.Body).Decode(&resData);
if err2 != nil{
    return ;
}

var esData EsData;
esData.Total = resData.Hits.Total.Value;
    
for _, v := range resData.Hits.Hits {
    cache := v.Source
    cache["_index"] = v.Index;
    cache["_id"] = v.Id;
    cache["_score"] = v.Score;
    esData.List = append(esData.List,cache)
}

修改數(shù)據(jù)

單條修改

 update := map[string]any{
    "script": map[string]any{
        "source":"ctx._source.user_name='test1';ctx._source.mobile='15211111111';",
        "lang": "painless",
    },
}

str,err1 := json.Marshal(update)
if err1 != nil{
    return ;
}

res2,err2 := client.Update(
    "db.table",
    "1",
    bytes.NewReader(str),
    client.Update.WithRefresh("true")
)

if err2 != nil{
    return ;
}

批量修改

update := map[string]any{
    "query":map[string]any{
        "bool":map[string]any{
            "must":[]map[string]any{
                map[string]any{
                    "match_phrase":map[string]any{
                        "user_name": "test",
                    },
                },
                map[string]any{
                    "match_phrase":map[string]any{
                        "mobile": "15222222222",
                    },
                },
            },
        },
    },
    "script": map[string]any{
        "source":"ctx._source.user_name='test1';ctx._source.mobile='15211111111';",
        "lang": "painless",
    },
}

str,err1 := json.Marshal(update)
if err1 != nil{
    return ;
}

res2,err2 := client.UpdateByQuery(
    []string{
        "db.table",
    },
    client.UpdateByQuery.WithBody(bytes.NewReader(str)),
    client.UpdateByQuery.WithRefresh(true)
)

if err2 != nil{
    return ;
}

刪除數(shù)據(jù)

單條刪除

res,err := client.Delete(
    "db.table",
    "1",
    client.Delete.WithRefresh("true")
)
if err != nil{
    return ;
}

批量刪除

query := map[string]any{
    "query":map[string]any{
        "bool":map[string]any{
            "must":[]map[string]any{
                map[string]any{
                    "match_phrase":map[string]any{
                        "user_name": "test",
                    },
                },
                map[string]any{
                    "match_phrase":map[string]any{
                        "mobile": "15222222222",
                    },
                },
            },
        },
    },
}

str,err := json.Marshal(query);
if err != nil{
    return ;
}

res,err := client.DeleteByQuery(
    []string{
        "db.table",
    },
    bytes.NewReader(str),
    client.DeleteByQuery.WithRefresh(true)
)

到此這篇關于GO語言操作Elasticsearch示例分享的文章就介紹到這了,更多相關GO語言操作Elasticsearch內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

詳細介紹Go語言之數(shù)組與切片
這篇文章介紹Go語言之數(shù)組與切片，數(shù)組是具有相同唯一類型的一組已編號且長度固定的數(shù)據(jù)項序列，這種類型可是任意的原始類型如整形、字符串或自定義類型。切片是數(shù)組的一個引用，因此切片是引用類型，在進行傳遞時，遵守引用傳遞的機制，下面我們就來詳細了解一下該內(nèi)容
2021-10-10
Golang定制化zap日志庫使用過程分析
Zap是我個人比較喜歡的日志庫，是uber開源的，有較好的性能，在項目開發(fā)中，經(jīng)常需要把程序運行過程中各種信息記錄下來，有了詳細的日志有助于問題排查和功能優(yōu)化，但如何選擇和使用性能好功能強大的日志庫，這個就需要我們從多角度考慮
2023-03-03
go語言多線程操作實現(xiàn)
多線程是一種使程序能夠并行處理多個任務的技術,Go語言通過goroutine和channel提供了一種相比傳統(tǒng)線程更輕量級、易于管理的并發(fā)實現(xiàn)方式,本文就來介紹一下go語言多線程操作實現(xiàn),感興趣的可以了解一下
2024-11-11
go語言使用range來接收通道里面的數(shù)據(jù)
本文主要介紹了go語言使用range來接收通道里面的數(shù)據(jù),for ... range?循環(huán)會一直從通道中接收值,直到通道關閉并且所有值都被接收完畢,下面就來介紹一下,感興趣的可以了解一下
2025-04-04
Golang?WorkerPool線程池并發(fā)模式示例詳解
這篇文章主要為大家介紹了Golang?WorkerPool線程池并發(fā)模式示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
2022-08-08
這篇文章主要介紹了golang切片反序?qū)嵗?，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2020-12-12