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