| | |
|---|
| | | return dbpersoninfos, nil |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 根据底库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 {} |
|---|
| | | //} |
|---|
| | | |
|---|
| | | |
|---|
| | | // 根据tableid 查询tablename |
|---|
| | | func Dbtablename(tableid string ) (tablename string, err error) { |
|---|
| | | var dbinfotable =` { |
|---|
