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