554325746@qq.com
2019-06-25 4500e7b2b5fb79fbd0728af95133ce885bb74eda
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
}