Compare commits

..

No commits in common. "a3b95947b00119aedd8c3ede8a6fee6f59920948" and "663b93d52d917833b584b483375b50b3eb7bda9e" have entirely different histories.

1 changed files with 1 additions and 3 deletions

View File

@ -143,10 +143,8 @@ func newMgoSession(user, password, host string, port int32, options string) (s *
// [mongodb://][user:pass@]host1[:port1][,host2[:port2],...][/database][?options] // [mongodb://][user:pass@]host1[:port1][,host2[:port2],...][/database][?options]
url := fmt.Sprintf("mongodb://%s%s:%d/admin%s", login, host, port, options) url := fmt.Sprintf("mongodb://%s%s:%d/admin%s", login, host, port, options)
//fmt.Println(url) //fmt.Println(url)
logger.Logger.Tracef("newMgoSession url:%s", url)
session, err := mgo.Dial(url) session, err := mgo.Dial(url)
if err != nil { if err != nil {
logger.Logger.Errorf("newMgoSession err:%v", err)
return nil, err return nil, err
} }
session.SetSafe(&mgo.Safe{}) session.SetSafe(&mgo.Safe{})
@ -242,7 +240,7 @@ func (msm *MgoSessionMgr) GetPltMgoSession(plt, key string) *Session {
if c, ok := msm.GetCfg(plt, key); ok { if c, ok := msm.GetCfg(plt, key); ok {
s, err := newMgoSession(c.Username, c.Password, c.HostName, c.HostPort, c.Options) s, err := newMgoSession(c.Username, c.Password, c.HostName, c.HostPort, c.Options)
if s == nil || err != nil { if s == nil || err != nil {
logger.Logger.Errorf("GetPltMgoSession(%s,%s) err:%v config:%+v", plt, key, err, *c) logger.Logger.Error("GetPltMgoSession(%s,%s) err:%v", plt, key, err)
return nil return nil
} }
ss := &Session{Session: s, cfg: c} ss := &Session{Session: s, cfg: c}