From 58cdde93bbe0c913c0c45a63bb9d7307fac65962 Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期二, 25 六月 2019 19:57:05 +0800
Subject: [PATCH] add tablename by id
---
esutil/EsApi.go | 38 +++++++++++++++++++++++++++++++++++++-
1 files changed, 37 insertions(+), 1 deletions(-)
diff --git a/esutil/EsApi.go b/esutil/EsApi.go
index 046647c..835ff21 100644
--- a/esutil/EsApi.go
+++ b/esutil/EsApi.go
@@ -7,7 +7,8 @@
"basic.com/pubsub/protomsg.git"
)
-func DbPersoninfos( queryindex int, querynums int ) (dbpersoninfos []protomsg.Baseinfo, err error){
+// 鏌ヨ搴曞簱浜哄憳淇℃伅
+func DbPersoninfos( queryindex int, querynums int ) (dbpersoninfos []*protomsg.Baseinfo, err error){
point := strconv.Itoa(queryindex)
number := strconv.Itoa(querynums)
@@ -51,4 +52,39 @@
return dbpersoninfos, nil
}
+// 鏍规嵁tableid 鏌ヨtablename
+func Dbtablename(tableid string ) (tablename string, err error) {
+ 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 "" ,errors.New("http request dbtablename info is err!")
+ }
+ sources, err := Sourcelist(buf)
+ if err != nil {
+ return "",err
+ }
+ for _, source := range sources {
+ if name, ok := source["tableName"].(string); ok {
+ tablename = name
+ break
+ }
+ }
+ return tablename, nil
+}
--
Gitblit v1.8.0