cache update

554325746@qq.com

2019-07-08 cdba449c8011d394bedc77453d179bd7c09b98cc

cache update

 dbpersoninfo.go

@@ -7,11 +7,8 @@
    "sync"
    "encoding/base64"

    "test/cache/esutil"
    "test/cache/shardmap"
//    "basic.com/pubsub/cache.git/esutil"
//  "basic.com/pubsub/cache.git/shardmap"
//  "basic.com/pubsub/protomsg.git"
    "cache/esutil"
    "cache/shardmap"

    "basic.com/valib/gosdk.git"
)

 esutil/EsApi.go

@@ -42,6 +42,21 @@
      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 =` {