add query dbperson info by id

554325746@qq.com

2019-07-08 d25f504c5fabb9eadb77c38f0df3cda983495be1

 esutil/EsApi.go

@@ -43,18 +43,33 @@
}

// 根据底库id查询底库信息
//func Dbpersoninfosbyid (id string) (protomsg.Baseinfo, error) {
//    var dbinfo protomsg.Baseinfo
//
//    url := fmt.Sprintf("http://192.168.1.182:9200/dbtablepersons/dbpersons/_search", id)
//    buf, err := EsReq("POST", "http://192.168.1.182:9200/dbtablepersons/dbpersons/_search",[]byte(dbinfoRequest))
//    if err != nil {
//        return dbinfo, nil 
//    }
//
//    sources, err := Sourcelist(buf)
//    if err != nil {}
//}
func Dbpersoninfosbyid (id string) (protomsg.Baseinfo, error) {
    var dbinfo protomsg.Baseinfo
    
        var dbinfoRequest = `
            {
                "query":{
                    "terms":{
                        "_id":[
                            "`+ id +`"
                        ]
                    }
                }
            }
        `
    buf, err := EsReq("POST", "http://192.168.1.182:9200/dbtablepersons/_search",[]byte(dbinfoRequest))
    if err != nil {
        return dbinfo,  err
    }

    sources, err := Sourcelist(buf)
    if err != nil {
        return dbinfo , err
    }

    baseinfo := Dbpersonbyid(sources) 
    return baseinfo, nil
}


// 根据tableid 查询tablename