From 4500e7b2b5fb79fbd0728af95133ce885bb74eda Mon Sep 17 00:00:00 2001 From: 554325746@qq.com <554325746@qq.com> Date: 星期二, 25 六月 2019 17:12:55 +0800 Subject: [PATCH] add get tablename by id --- esutil/EsApi.go | 37 +++++++++++++++++++++++++++++++++++++ 1 files changed, 37 insertions(+), 0 deletions(-) diff --git a/esutil/EsApi.go b/esutil/EsApi.go index 6068a46..d5510da 100644 --- a/esutil/EsApi.go +++ b/esutil/EsApi.go @@ -7,6 +7,7 @@ "basic.com/pubsub/protomsg.git" ) +// 鏌ヨ搴曞簱浜哄憳淇℃伅 func DbPersoninfos( queryindex int, querynums int ) (dbpersoninfos []*protomsg.Baseinfo, err error){ point := strconv.Itoa(queryindex) number := strconv.Itoa(querynums) @@ -51,4 +52,40 @@ return dbpersoninfos, nil } +// 鏍规嵁tableid 鏌ヨtablename +func Dbtablename(tableid string ) (tablename string) { + var dbinfotable =` { + "query": { + "bool": { + "filter": [ + { + "term": { + "id":`+tableid+` + } + } + ] + } + }, + "_source": [ + "tableName" + ] + } + ` + buf, err := EsReq("POST", "http://192.168.1.182:9200/dbtables/_search",[]byte(dbinfotable)) + if err != nil { + return nil ,errors.New("http request dbtablename info is err!") + } + sources, err := Sourcelist(buf) + if err != nil { + return nil,err + } + + for _, source := range sources { + if name, ok := souce["tableName"].(string); ok { + tablename = name + break + } + } + return +} -- Gitblit v1.8.0