Compare commits
No commits in common. "a3b95947b00119aedd8c3ede8a6fee6f59920948" and "663b93d52d917833b584b483375b50b3eb7bda9e" have entirely different histories.
a3b95947b0
...
663b93d52d
|
@ -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}
|
||||||
|
|
Loading…
Reference in New Issue