| | |
| | | "basic.com/pubsub/protomsg.git" |
| | | ) |
| | | |
| | | // 查询底库人员信息 |
| | | func DbPersoninfos( queryindex int, querynums int ) (dbpersoninfos []*protomsg.Baseinfo, err error){ |
| | | point := strconv.Itoa(queryindex) |
| | | number := strconv.Itoa(querynums) |
| | |
| | | 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 |
| | | } |